Package grpc provides a grpc server.

Package mucp provides an mucp server.

Address to bind to - host:port.

The address to advertise for discovery - host:port.

Auth mechanism for role based access control.

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.

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.

NewRouter returns a new router.

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

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.

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.

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.