Method Call

client/client.go:25–25 · view source on GitHub ↗

(ctx context.Context, req Request, rsp interface{}, opts ...CallOption)

Source from the content-addressed store, hash-verified

23	NewMessage(topic string, msg interface{}, opts ...MessageOption) Message
24	NewRequest(service, endpoint string, req interface{}, reqOpts ...RequestOption) Request
25	Call(ctx context.Context, req Request, rsp interface{}, opts ...CallOption) error
26	Stream(ctx context.Context, req Request, opts ...CallOption) (Stream, error)
27	Publish(ctx context.Context, msg Message, opts ...PublishOption) error
28	String() string

TestCallAddressFunction · 0.95

TestCallRetryFunction · 0.95

TestCallWrapperFunction · 0.95

TestGRPCClientFunction · 0.95

CallFunction · 0.65

callAgentMethod · 0.65

CallFunction · 0.65

DispatchFunction · 0.65

testRequestFunction · 0.65

CallContextMethod · 0.65

CallMethod · 0.65

rpcClientclient/rpc_client.go

grpcClientclient/grpc/grpc.go

no outgoing calls

TestCallAddressFunction · 0.76

TestCallRetryFunction · 0.76

TestCallWrapperFunction · 0.76

TestGRPCClientFunction · 0.76

TestGracefulStopRejectsNewRPCsButAllowsInFlightRPCsFunction · 0.52