Package mock provides a mock client for testing.

Package rpc provides an rpc client.

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.

Creates a new client with the options passed in.

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.

PoolSize sets the connection pool size.

Publishes a publication using the default client.

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.

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

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

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.

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.

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.

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.