Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/chop-dbhi/nats-rpc
/ functions
Functions
78 in github.com/chop-dbhi/nats-rpc
⨍
Functions
78
◇
Types & classes
22
↓ 10 callers
Method
String
()
example/service.pb.go:38
↓ 8 callers
Method
Close
Close closes the transport connection and unsubscribes all subscribers.
transport/transport.go:102
↓ 6 callers
Method
Subscribe
Subscribe creates a subscription to a subject.
transport/transport.go:96
↓ 5 callers
Method
Publish
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 callers
Method
Request
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 callers
Method
String
()
transport/transport.pb.go:56
↓ 5 callers
Function
newTransport
(t testing.TB)
transport/transport_test.go:16
↓ 4 callers
Method
wrap
TODO: define as part of an Encoder interface.
transport/transport.go:156
↓ 3 callers
Function
errorStatus
errorStatus takes an error and returns the internal status or wraps it.
transport/transport.go:285
↓ 2 callers
Method
SetLogger
Set the logger.
transport/transport.go:105
↓ 2 callers
Function
SubscribeQueue
SubscribeQueue specifies the queue name of the subscriber.
transport/transport.go:66
↓ 2 callers
Method
Sum
(context.Context, *Req, ...transport.RequestOption)
example/service.pb.nats.go:22
↓ 2 callers
Function
stringPtr
(in string)
gen.go:36
↓ 2 callers
Method
unwrap
TODO: define as part of a Decoder interface.
transport/transport.go:182
↓ 1 callers
Function
Connect
Connect is a convenience function establishing a connection with NATS and returning a transport.
transport/transport.go:110
↓ 1 callers
Method
Decode
Decode decodes the message payload into a proto message.
transport/transport.go:73
↓ 1 callers
Function
PublishCause
PublishCause sets the cause of the publication.
transport/transport.go:30
↓ 1 callers
Function
RequestCause
RequestCause sets the cause of the request.
transport/transport.go:52
↓ 1 callers
Method
Reset
()
example/service.pb.go:37
↓ 1 callers
Method
Serve
(context.Context, ...transport.SubscribeOption)
server.go:10
↓ 1 callers
Function
newTemplate
base and lower are template helper functions.
gen.go:81
↓ 1 callers
Function
outName
(in *descriptor.FileDescriptorProto)
gen.go:43
↓ 1 callers
Function
packageName
packageName determines the name of the package.
gen.go:55
↓ 1 callers
Function
packagePath
(in *descriptor.FileDescriptorProto)
gen.go:69
Method
Close
()
transport/transport.go:148
Method
Conn
Conn returns the underlying NATS connection.
transport/transport.go:99
Method
Conn
()
transport/transport.go:144
Method
Descriptor
()
example/service.pb.go:40
Method
Descriptor
()
example/service.pb.go:63
Method
Descriptor
()
transport/transport.pb.go:58
Function
Fatal
Fatal calls Fatal on the stdlib logger.
log/log.go:54
Function
Fatalf
Fatalf calls Fatalf on the stdlib logger.
log/log.go:59
Function
Fatalln
Fatalln calls Fatalln on the stdlib logger.
log/log.go:64
Method
GetCause
()
transport/transport.pb.go:88
Method
GetError
()
transport/transport.pb.go:81
Method
GetId
()
transport/transport.pb.go:60
Method
GetLeft
()
example/service.pb.go:42
Method
GetPayload
()
transport/transport.pb.go:74
Method
GetQueue
()
transport/transport.pb.go:102
Method
GetReply
()
transport/transport.pb.go:109
Method
GetRight
()
example/service.pb.go:49
Method
GetStatus
()
transport/transport.pb.go:116
Method
GetSubject
()
transport/transport.pb.go:95
Method
GetSum
()
example/service.pb.go:65
Method
GetTimestamp
()
transport/transport.pb.go:67
Function
New
New returns a transport using an existing NATS connection.
transport/transport.go:124
Function
New
New initializes a new Zap logger with namespaced keys.
log/log.go:12
Function
NewClient
NewClient creates a new Service client.
example/service.pb.nats.go:42
Function
NewServer
(tp transport.Transport, svc Service)
example/service.pb.nats.go:81
Function
NewService
()
example/service.go:13
Function
ParseFile
(in *descriptor.FileDescriptorProto, tmpl string, opts Options)
gen.go:133
Function
ParseOptions
(p string)
gen.go:110
Method
ProtoMessage
()
example/service.pb.go:39
Method
ProtoMessage
()
example/service.pb.go:62
Method
ProtoMessage
()
transport/transport.pb.go:57
Method
Publish
(sub string, msg proto.Message, opts ...PublishOption)
transport/transport.go:196
Method
Request
(sub string, req proto.Message, rep proto.Message, opts ...RequestOption)
transport/transport.go:225
Function
RequestTimeout
RequestTimeout sets a request timeout duration.
transport/transport.go:45
Method
Reset
()
example/service.pb.go:60
Method
Reset
()
transport/transport.pb.go:55
Method
Serve
(ctx context.Context, opts ...transport.SubscribeOption)
example/service.pb.nats.go:51
Method
SetLogger
(l *zap.Logger)
transport/transport.go:140
Method
String
()
example/service.pb.go:61
Method
Subscribe
Subscribe creates a subscription to a subject.
transport/transport.go:300
Method
Sum
(ctx context.Context, req *Req)
example/service.go:7
Method
Sum
(context.Context, *Req)
example/service.pb.nats.go:18
Method
Sum
(ctx context.Context, req *Req, opts ...transport.RequestOption)
example/service.pb.nats.go:30
Function
TestCustomError
(t *testing.T)
transport/transport_test.go:173
Function
TestHandlerPanic
(t *testing.T)
transport/transport_test.go:141
Function
TestPublish
(t *testing.T)
transport/transport_test.go:34
Function
TestRequest
(t *testing.T)
transport/transport_test.go:105
Function
TestSubscribe
(t *testing.T)
transport/transport_test.go:77
Function
init
()
example/service.pb.go:72
Function
init
()
transport/transport.pb.go:123
Function
main
()
example/cmd/cli/main.go:39
Function
main
()
example/cmd/server/main.go:17
Function
main
()
cmd/protoc-gen-nats-rpc/main.go:13
Function
main
()
cmd/protoc-gen-nats-rpc-cli/main.go:13