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.

Context specifies a context for the service.

DefaultOptions returns config options for the default service.

DisableAutoAck will disable auto acking of messages after they have been handled.

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.

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.

Add transport.ListenOption to the ListenOptions list, when using it, it will be passed to the httpTransport.Listen() method.

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.

NewOptions creates new server options.

NewRouter returns a new router.

NewRPCServer will create a new default RPC server.

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

NewWaitGroup returns a new double waitgroup for global management of processes.

RegisterCheck run func before registry service.

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.

TLSConfig specifies a *tls.Config.

Tracer mechanism for distributed tracking.

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 If `wg` is nil, server only wait for completion of rpc handler.

WithLogger sets the underline logger.

WithRouter sets the request router.

WithRouterLogger sets the underline router logger.

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.

DefaultContentType is the default codec content type.

NewServer creates a new server.

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.