Documentation
¶
Index ¶
- Constants
- type Bus
- func (b *Bus) Publish(ctx context.Context, msg bus.Message) error
- func (b *Bus) Reply(ctx context.Context, msgNamespace bus.MessageNamespace, ...) error
- func (b *Bus) Request(ctx context.Context, msg bus.Message) (bus.Message, error)
- func (b *Bus) Subscribe(ctx context.Context, ns bus.MessageNamespace, messageType bus.MessageType) (<-chan bus.Message, error)
- func (b *Bus) Unsubscribe(ctx context.Context, ns bus.MessageNamespace, messageType bus.MessageType, ...)
- type Option
- type OptionFunc
- type ReplyMessage
- type RequestHandler
- type RequestMessage
Constants ¶
View Source
const ( MessageNamespaceReqRep bus.MessageNamespace = "requestReply" MessageTypeRequest bus.MessageType = "request" MessageTypeReply bus.MessageType = "reply" )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Bus ¶
type Bus struct {
// contains filtered or unexported fields
}
func NewBus ¶
func NewBus(funcs ...OptionFunc) *Bus
func (*Bus) Reply ¶
func (b *Bus) Reply(ctx context.Context, msgNamespace bus.MessageNamespace, msgType bus.MessageType, h bus.RequestHandler) error
func (*Bus) Subscribe ¶
func (b *Bus) Subscribe(ctx context.Context, ns bus.MessageNamespace, messageType bus.MessageType) (<-chan bus.Message, error)
func (*Bus) Unsubscribe ¶
func (b *Bus) Unsubscribe(ctx context.Context, ns bus.MessageNamespace, messageType bus.MessageType, ch <-chan bus.Message)
type Option ¶
type Option struct {
BufferSize int64
}
func DefaultOption ¶
func DefaultOption() *Option
type OptionFunc ¶
type OptionFunc func(*Option)
func WithBufferSize ¶
func WithBufferSize(size int64) OptionFunc
type ReplyMessage ¶
type ReplyMessage struct {
RequestID uint64
Message bus.Message
Error error
// contains filtered or unexported fields
}
func (*ReplyMessage) MessageNamespace ¶
func (m *ReplyMessage) MessageNamespace() bus.MessageNamespace
func (*ReplyMessage) MessageType ¶
func (m *ReplyMessage) MessageType() bus.MessageType
type RequestMessage ¶
type RequestMessage struct {
RequestID uint64
Message bus.Message
// contains filtered or unexported fields
}
func (*RequestMessage) MessageNamespace ¶
func (m *RequestMessage) MessageNamespace() bus.MessageNamespace
func (*RequestMessage) MessageType ¶
func (m *RequestMessage) MessageType() bus.MessageType
Source Files
Click to show internal directories.
Click to hide internal directories.