MCPcopy Create free account

hub / github.com/chop-dbhi/nats-rpc / functions

Functions78 in github.com/chop-dbhi/nats-rpc

↓ 10 callersMethodString
()
example/service.pb.go:38
↓ 8 callersMethodClose
Close closes the transport connection and unsubscribes all subscribers.
transport/transport.go:102
↓ 6 callersMethodSubscribe
Subscribe creates a subscription to a subject.
transport/transport.go:96
↓ 5 callersMethodPublish
Publish publishes a message asynchronously to the specified subject. The wrapped message is returned or an error. The error would only be due to a con
transport/transport.go:88
↓ 5 callersMethodRequest
Request publishes a message synchronously and waits for a response that is decoded into the Protobuf message supplied. The wrapped message is returned
transport/transport.go:93
↓ 5 callersMethodString
()
transport/transport.pb.go:56
↓ 5 callersFunctionnewTransport
(t testing.TB)
transport/transport_test.go:16
↓ 4 callersMethodwrap
TODO: define as part of an Encoder interface.
transport/transport.go:156
↓ 3 callersFunctionerrorStatus
errorStatus takes an error and returns the internal status or wraps it.
transport/transport.go:285
↓ 2 callersMethodSetLogger
Set the logger.
transport/transport.go:105
↓ 2 callersFunctionSubscribeQueue
SubscribeQueue specifies the queue name of the subscriber.
transport/transport.go:66
↓ 2 callersMethodSum
(context.Context, *Req, ...transport.RequestOption)
example/service.pb.nats.go:22
↓ 2 callersFunctionstringPtr
(in string)
gen.go:36
↓ 2 callersMethodunwrap
TODO: define as part of a Decoder interface.
transport/transport.go:182
↓ 1 callersFunctionConnect
Connect is a convenience function establishing a connection with NATS and returning a transport.
transport/transport.go:110
↓ 1 callersMethodDecode
Decode decodes the message payload into a proto message.
transport/transport.go:73
↓ 1 callersFunctionPublishCause
PublishCause sets the cause of the publication.
transport/transport.go:30
↓ 1 callersFunctionRequestCause
RequestCause sets the cause of the request.
transport/transport.go:52
↓ 1 callersMethodReset
()
example/service.pb.go:37
↓ 1 callersMethodServe
(context.Context, ...transport.SubscribeOption)
server.go:10
↓ 1 callersFunctionnewTemplate
base and lower are template helper functions.
gen.go:81
↓ 1 callersFunctionoutName
(in *descriptor.FileDescriptorProto)
gen.go:43
↓ 1 callersFunctionpackageName
packageName determines the name of the package.
gen.go:55
↓ 1 callersFunctionpackagePath
(in *descriptor.FileDescriptorProto)
gen.go:69
MethodClose
()
transport/transport.go:148
MethodConn
Conn returns the underlying NATS connection.
transport/transport.go:99
MethodConn
()
transport/transport.go:144
MethodDescriptor
()
example/service.pb.go:40
MethodDescriptor
()
example/service.pb.go:63
MethodDescriptor
()
transport/transport.pb.go:58
FunctionFatal
Fatal calls Fatal on the stdlib logger.
log/log.go:54
FunctionFatalf
Fatalf calls Fatalf on the stdlib logger.
log/log.go:59
FunctionFatalln
Fatalln calls Fatalln on the stdlib logger.
log/log.go:64
MethodGetCause
()
transport/transport.pb.go:88
MethodGetError
()
transport/transport.pb.go:81
MethodGetId
()
transport/transport.pb.go:60
MethodGetLeft
()
example/service.pb.go:42
MethodGetPayload
()
transport/transport.pb.go:74
MethodGetQueue
()
transport/transport.pb.go:102
MethodGetReply
()
transport/transport.pb.go:109
MethodGetRight
()
example/service.pb.go:49
MethodGetStatus
()
transport/transport.pb.go:116
MethodGetSubject
()
transport/transport.pb.go:95
MethodGetSum
()
example/service.pb.go:65
MethodGetTimestamp
()
transport/transport.pb.go:67
FunctionNew
New returns a transport using an existing NATS connection.
transport/transport.go:124
FunctionNew
New initializes a new Zap logger with namespaced keys.
log/log.go:12
FunctionNewClient
NewClient creates a new Service client.
example/service.pb.nats.go:42
FunctionNewServer
(tp transport.Transport, svc Service)
example/service.pb.nats.go:81
FunctionNewService
()
example/service.go:13
FunctionParseFile
(in *descriptor.FileDescriptorProto, tmpl string, opts Options)
gen.go:133
FunctionParseOptions
(p string)
gen.go:110
MethodProtoMessage
()
example/service.pb.go:39
MethodProtoMessage
()
example/service.pb.go:62
MethodProtoMessage
()
transport/transport.pb.go:57
MethodPublish
(sub string, msg proto.Message, opts ...PublishOption)
transport/transport.go:196
MethodRequest
(sub string, req proto.Message, rep proto.Message, opts ...RequestOption)
transport/transport.go:225
FunctionRequestTimeout
RequestTimeout sets a request timeout duration.
transport/transport.go:45
MethodReset
()
example/service.pb.go:60
MethodReset
()
transport/transport.pb.go:55
MethodServe
(ctx context.Context, opts ...transport.SubscribeOption)
example/service.pb.nats.go:51
MethodSetLogger
(l *zap.Logger)
transport/transport.go:140
MethodString
()
example/service.pb.go:61
MethodSubscribe
Subscribe creates a subscription to a subject.
transport/transport.go:300
MethodSum
(ctx context.Context, req *Req)
example/service.go:7
MethodSum
(context.Context, *Req)
example/service.pb.nats.go:18
MethodSum
(ctx context.Context, req *Req, opts ...transport.RequestOption)
example/service.pb.nats.go:30
FunctionTestCustomError
(t *testing.T)
transport/transport_test.go:173
FunctionTestHandlerPanic
(t *testing.T)
transport/transport_test.go:141
FunctionTestPublish
(t *testing.T)
transport/transport_test.go:34
FunctionTestRequest
(t *testing.T)
transport/transport_test.go:105
FunctionTestSubscribe
(t *testing.T)
transport/transport_test.go:77
Functioninit
()
example/service.pb.go:72
Functioninit
()
transport/transport.pb.go:123
Functionmain
()
example/cmd/cli/main.go:39
Functionmain
()
example/cmd/server/main.go:17
Functionmain
()
cmd/protoc-gen-nats-rpc/main.go:13
Functionmain
()
cmd/protoc-gen-nats-rpc-cli/main.go:13