Package rpc provides an rpc server.

Address to bind to - host:port.

The address to advertise for discovery - host:port.

Broker to use for pub/sub.

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

DebugHandler for this server.

DefaultOptions returns config options for the default service.

EndpointMetadata is a Handler option that allows metadata to be added to individual endpoints.

Handle registers a handler interface with the default server to handle inbound requests.

Unique server id.

Init initialises the default server with options passed in.

Internal Handler options specifies that a handler is not advertised to the discovery system.

Internal Subscriber options specifies that a subscriber is not advertised to the discovery system.

Metadata associated with the server.

Server name.

NewHandler creates a new handler interface using the default server Handlers are required to be a public object with public endpoints.

NewServer returns a new server with options passed in.

NewSubscriber creates a new subscriber interface with the given topic and handler using the default server.

Register the service with at interval.

Register the service with a TTL.

Registry used for discovery.

Run starts the default server and waits for a kill signal before exiting.

Start starts the default server.

Stop stops the default server.

String returns name of Server implementation.

Subscribe registers a subscriber interface with the default server which subscribes to specified topic with the broker.

SubscriberContext set context options to allow broker SubscriberOption passed.

Shared queue name distributed messages across subscribers.

Transport mechanism for communication e.g http, rabbitmq, etc.

Version of the service.

Wait tells the server to wait for requests to finish before exiting.

WithRouter sets the request router.

Adds a handler Wrapper to a list of options passed into the server.

Adds a subscriber Wrapper to a list of options passed into the server.

We use this to wrap any debug handlers so we preserve the signature Debug.{Method}.

Handler interface represents a request handler.

Message is an async message interface.

Request is a synchronous request interface.

Response is the response writer for unencoded messages.

Router handle serving messages.

Server is a simple micro server abstraction.

Stream represents a stream established with a client.

Subscriber interface represents a subscription to a given topic using a specific subscriber function or object with endpoints.

HandlerFunc represents a single method of a handler.

HandlerWrapper wraps the HandlerFunc and returns the equivalent.

StreamWrapper wraps a Stream interface and returns the equivalent.

SubscriberFunc represents a single method of a subscriber.

SubscriberWrapper wraps the SubscriberFunc and returns the equivalent.