# Packages
Package binlogmsg contains BinlogMsgPipe which is used as a publisher pipeline from MySQL-8 to downstream publisher.
Package dbpipe contains DBMsgPublisherPipe which is used as a publisher pipeline from RDBMS to downstream publisher (deprecating).
No description provided by the author
Package natsrpc contains NatsRPCServer/NatsRPCClient which implement nproto.RPCServer and nproto.RPCClient.
No description provided by the author
No description provided by the author
Package stanmsg contains DurConn which implements nproto.MsgPublisher/nproto.MsgAsyncPublisher and nproto.MsgSubscriber.
Package tracing contains middlewares for RPCServer/RPCClient/MsgPublisher/MsgSubscriber to add opentracing support.
No description provided by the author
# Functions
MDFromIncomingCont extracts incoming MD from context or nil if not found.
MDFromOutgoingContext extracts outgoing MD from context or nil if not found.
NewIncomingContextWithMD creates a new context with incoming MD attached.
NewMetaDataFromMD creates a MetaData from MD.
NewMetaDataPairs creates a MetaData from key/value pairs.
NewMsgAsyncPublisherWithMWs wraps a MsgAsyncPublisher with middlewares.
NewMsgPublisherWithMWs wraps a MsgPublisher with middlewares.
NewMsgSubscriberWithMWs creates a new MsgSubscriberWithMWs.
NewOutgoingContextWithMD creates a new context with outgoing MD attached.
NewRPCClientWithMWs creates a new RPCClientWithMWs.
NewRPCServerWithMWs creates a new RPCServerWithMWs.
# Variables
EmptyMD is an empty MD.
# Structs
MsgSubscriberWithMWs wraps a MsgSubscriber with middlewares.
PBPublisher is used to publish protobuf message.
RPCClientWithMWs wraps an RPCClient with RPCMiddlewares.
RPCMethod contains meta information of a given method.
RPCServerWithMWs wraps an RPCServer with RPCMiddlewares.
# Interfaces
MD is used to carry extra key/value context data (meta data) from outgoing side to incoming side.
MsgAsyncPublisher is similar to MsgPublisher but in async manner.
MsgPublisher is used to publish messages reliably, e.g.
MsgSubscriber is used to consume messages.
RPCClient is used to invoke rpc services.
RPCServer is used to serve rpc services.
# Type aliases
MetaData is the default implementation of MD.
MsgAsyncPublisherFunc is an adapter to allow the use of ordinary functions as MsgAsyncPublisher.
MsgAsyncPublisherMiddleware wraps MsgAsyncPublisherFunc into another one.
MsgHandler handles messages.
MsgMiddleware wraps a MsgHandler into another one.
MsgPublisherFunc is an adapter to allow th use of ordinary functions as MsgPublisher.
MsgPublisherMiddleware wraps MsgPublisherFunc into another one.
RPCHandler do the real job.
RPCMiddleware wraps an RPCHandler into another one.