Package grpc provides a gRPC options.

Package mucp provides an mucp client.

Package selector is a way to pick a list of service nodes.

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

Broker to be used for pub/sub.

Makes a synchronous call to a service using the default client.

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

Default content type of the client.

Transport dial timeout.

NewCache returns an initialised cache.

Creates a new message using the default client.

Creates a new request using the default client.

Creates a streaming connection with a service and returns responses on the channel passed in.

PoolSize sets the connection pool size.

PoolTTL sets the connection pool ttl.

Publishes a publication using the default client.

PublishContext sets the context in publish options.

Registry to find nodes for a given service.

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.

Select is used to select a node to route a request to.

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.

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

WithCache is a CallOption which sets the duration the response shoull be cached for.

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.

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 client router.

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

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.

DefaultClient is a default client to use out of the box.

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.

NewClient returns a new client.

Cache for responses.

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.

Router manages request routing.

Stream is the inteface 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.

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.