Package pubsub defines the Publisher and Subscriber interfaces.

Package testproto contains the generated testproto grpc code.

NewClient creates a new pub-sub based grpc client.

NewServer creates a new pub-sub based grpc server.

StatsHandler returns a ServerOption that sets the StatsHandler for the server.

StreamInterceptor returns a ServerOption that sets the StreamServerInterceptor for the server.

UnaryInterceptor returns a ServerOption that sets the UnaryServerInterceptor for the server.

WithLogger sets the logger for the client or server.

Enum value maps for MessageType.

Enum value maps for MessageType.

Client implements a pub-sub based grpc client.

Server implements the grpc.ServiceRegistrar interface.

StandardLogger implements the Logger interface using the standard library logger.

Logger defines the interface for logging.

Option defines an option for configuring the server.