aboutsummaryrefslogtreecommitdiff
path: root/example/main.go
diff options
context:
space:
mode:
authorAlexander Kiryukhin <a.kiryukhin@mail.ru>2022-05-21 20:38:21 +0300
committerAlexander Kiryukhin <a.kiryukhin@mail.ru>2022-05-21 20:38:21 +0300
commit81389df9484c28dfcec1cf7592b8d0f8b7e4e8e1 (patch)
tree7a7d0440481e45b999e828b1e5ba2b28129658bc /example/main.go
parentd4708a3665e546eea57611b17441ad9b8c89e9a4 (diff)
Improvments. Breaking changes
Diffstat (limited to 'example/main.go')
-rw-r--r--example/main.go53
1 files changed, 53 insertions, 0 deletions
diff --git a/example/main.go b/example/main.go
new file mode 100644
index 0000000..9f25e61
--- /dev/null
+++ b/example/main.go
@@ -0,0 +1,53 @@
+package main
+
+import (
+ "context"
+ "errors"
+ "log"
+ "os"
+ "os/signal"
+
+ "go.neonxp.dev/jsonrpc2/rpc"
+ "go.neonxp.dev/jsonrpc2/transport"
+)
+
+func main() {
+ s := rpc.New()
+
+ s.AddTransport(&transport.HTTP{Bind: ":8000"})
+ s.AddTransport(&transport.TCP{Bind: ":3000"})
+
+ s.Register("multiply", rpc.H(Multiply))
+ s.Register("divide", rpc.H(Divide))
+
+ ctx, cancel := signal.NotifyContext(context.Background(), os.Interrupt, os.Kill)
+ defer cancel()
+
+ if err := s.Run(ctx); err != nil {
+ log.Fatal(err)
+ }
+}
+
+func Multiply(ctx context.Context, args *Args) (int, error) {
+ return args.A * args.B, nil
+}
+
+func Divide(ctx context.Context, args *Args) (*Quotient, error) {
+ if args.B == 0 {
+ return nil, errors.New("divide by zero")
+ }
+ quo := new(Quotient)
+ quo.Quo = args.A / args.B
+ quo.Rem = args.A % args.B
+ return quo, nil
+}
+
+type Args struct {
+ A int `json:"a"`
+ B int `json:"b"`
+}
+
+type Quotient struct {
+ Quo int `json:"quo"`
+ Rem int `json:"rem"`
+}