Versions in this module Expand all Collapse all v1 v1.0.4 Apr 9, 2021 Changes in this version + type ILogger interface + Debugw func(mgs string, keysAndValues ...interface{}) + Errorw func(mgs string, keysAndValues ...interface{}) + Fatalw func(mgs string, keysAndValues ...interface{}) + Infow func(mgs string, keysAndValues ...interface{}) + Panicw func(mgs string, keysAndValues ...interface{}) + Warnw func(mgs string, keysAndValues ...interface{}) + type Irpc interface + EventServer func(ctx context.Context, request RequestRPC) (err error) + Publish func(ctx context.Context, request RequestMsgRPC) (err error) + type Options interface + URIConnection func() string + type RabbitURI string + func (this RabbitURI) URIConnection() string + type RequestMsgRPC interface + GetExchange func() string + GetMsg func() proto.Message + GetReplyMsg func() proto.Message + GetRoutingKey func() string + GetTimeout func() time.Duration + HaveReply func() bool + type RequestRPC interface + GetExchange func() string + GetRoutingKey func() string + GetRpcServer func() func(ctx context.Context) (msg proto.Message, err error)