Package grpc provides a gRPC options.

Package mucp provides a transport agnostic RPC client.

Backoff is used to set the backoff function used when retrying Calls.

Broker to be used for pub/sub.

Codec to be used to encode/decode requests for a given content type.

Default content type of the client.

Transport dial timeout.

Lookup sets the lookup function to use for resolving service names.

LookupRoute for a request using the router and then choose one using the selector.

PoolSize sets the connection pool size.

PoolTTL sets the connection pool ttl.

Proxy sets the proxy address.

PublishContext sets the context in publish options.

Registry sets the routers registry.

The request timeout.

Number of retries when making the request.

Retry sets the retry function to be used when re-trying.

RetryAlways always retry on error.

RetryOnError retries a request on a 500 or timeout error.

Router is used to lookup routes for a service.

Selector is used to select a route.

StreamTimeout sets the stream timeout.

Transport to use for communication e.g http, rabbitmq, etc.

WithAddress sets the remote addresses to use rather than using service discovery.

WithAuthToken is a CallOption which overrides the authorization header with the services own auth token.

WithBackoff is a CallOption which overrides that which set in Options.CallOptions.

WithCallWrapper is a CallOption which adds to the existing CallFunc wrappers.

WithDialTimeout is a CallOption which overrides that which set in Options.CallOptions.

WithExchange sets the exchange to route a message through.

WithNetwork is a CallOption which sets the network attribute.

WithRequestTimeout is a CallOption which overrides that which set in Options.CallOptions.

WithRetries is a CallOption which overrides that which set in Options.CallOptions.

WithRetry is a CallOption which overrides that which set in Options.CallOptions.

WithRouter sets the router to use for this call.

WithSelectOptions sets the options to pass to the selector for this call.

WithSelector sets the selector to use for this call.

WithStreamTimeout sets the stream timeout.

Adds a Wrapper to a list of options passed into the client.

Adds a Wrapper to the list of CallFunc wrappers.

DefaultBackoff is the default backoff function for retries.

DefaultPoolSize sets the connection pool size.

DefaultPoolTTL sets the connection pool ttl.

DefaultRequestTimeout is the default request timeout.

DefaultRetries is the default number of times a request is tried.

DefaultRetry is the default check-for-retry function for retries.

Client is the interface used to make requests to services.

Message is the interface for publishing asynchronously.

Request is the interface for a synchronous request used by Call or Stream.

Response is the response received from a service.

Stream is the interface for a bidirectional synchronous stream.

CallFunc represents the individual call func.

CallOption used by Call or Stream.

CallWrapper is a low level wrapper for the CallFunc.

LookupFunc is used to lookup routes for a service.

MessageOption used by NewMessage.

Option used by the Client.

PublishOption used by Publish.

RequestOption used by NewRequest.

note that returning either false or a non-nil error will result in the call not being retried.

StreamWrapper wraps a Stream and returns the equivalent.

Wrapper wraps a client and returns a client.