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.

ContentType sets the default content type of the client.

DialTimeout sets the transport dial timeout.

NewCache returns an initialized cache.

Creates a new message using the default client.

NewOptions creates new Client options.

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.

RequestTimeout set the request timeout.

Retries set the 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.

WithConnClose sets the Connection header to close.

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

WithExchange sets the exchange to route a message through.

WithLogger sets the underline logger.

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

WithRetries sets the number of tries for a call.

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.

DefaultCodecs map.

DefaultConnectionTimeout is the default connection timeout.

DefaultContentType header.

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.

CallOptions are options used to make calls to a server.

Options are the Client options.

Client is the interface used to make requests to services.

Closer handle client close.

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.