From 81389df9484c28dfcec1cf7592b8d0f8b7e4e8e1 Mon Sep 17 00:00:00 2001 From: Alexander Kiryukhin Date: Sat, 21 May 2022 20:38:21 +0300 Subject: Improvments. Breaking changes --- example/main.go | 53 +++++++++++++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 53 insertions(+) create mode 100644 example/main.go (limited to 'example/main.go') 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"` +} -- cgit v1.2.3