ChainStreamInterceptor is short hand for grpc.ChainStreamInterceptor.

ChainUnaryInterceptor is short hand for ChainUnaryInterceptor.

NewServeMux.

WithAuthentication creates client option with given application id and secret.

ActionCreate requires to create resource.

ActionDelete requires to delete resource.

ActionGet requires resource data.

ActionUpdate requires to update data.

ExclusiveMode is RPC where conversation one to one.

Fanout is default subscription mode where each consumer recieves message.

RPCMode is subscription where in the topic is one consumer and many publishers.

ErrConflict is returned when new item conflicts with existing.

ErrRequired is returned when some item was missed.

Message represents data preset to be send or receive through gRPC api.Message.

ActionType is action type.

HandlerFunc represents function to proccess with incoming message.

Middleware is function type to return Handler.

ModeType describes subscription type.