memory

Documentation

Index

• Constants
• type Bus
  • func NewBus(funcs ...OptionFunc) *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
  • func DefaultOption() *Option
• type OptionFunc
  • func WithBufferSize(size int64) OptionFunc
• type ReplyMessage
  • func (m *ReplyMessage) MessageNamespace() bus.MessageNamespace
  • func (m *ReplyMessage) MessageType() bus.MessageType
• type RequestHandler
• type RequestMessage
  • func (m *RequestMessage) MessageNamespace() bus.MessageNamespace
  • func (m *RequestMessage) MessageType() bus.MessageType

Constants

const (
	MessageNamespaceReqRep bus.MessageNamespace = "requestReply"
	MessageTypeRequest     bus.MessageType      = "request"
	MessageTypeReply       bus.MessageType      = "reply"
)

Types

type Bus

type Bus struct {
	// contains filtered or unexported fields
}

func NewBus

func NewBus(funcs ...OptionFunc) *Bus

func (*Bus) Publish

func (b *Bus) Publish(ctx context.Context, msg bus.Message) error

func (*Bus) Reply

func (b *Bus) Reply(ctx context.Context, msgNamespace bus.MessageNamespace, msgType bus.MessageType, h bus.RequestHandler) error

func (*Bus) Request

func (b *Bus) Request(ctx context.Context, msg bus.Message) (bus.Message, 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 RequestHandler

type RequestHandler func(evt bus.Message) (bus.Message, error)

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