diff options
author | Alexander Kiryukhin <a.kiryukhin@mail.ru> | 2022-05-21 20:38:21 +0300 |
---|---|---|
committer | Alexander Kiryukhin <a.kiryukhin@mail.ru> | 2022-05-21 20:38:21 +0300 |
commit | 81389df9484c28dfcec1cf7592b8d0f8b7e4e8e1 (patch) | |
tree | 7a7d0440481e45b999e828b1e5ba2b28129658bc /example/main.go | |
parent | d4708a3665e546eea57611b17441ad9b8c89e9a4 (diff) |
Improvments. Breaking changes
Diffstat (limited to 'example/main.go')
-rw-r--r-- | example/main.go | 53 |
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"` +} |