inmem

Documentation

Index

• type Channel
  • func NewChannel(name string) *Channel
• type Receiver
  • func NewReceiver(r *Registry, o ...ReceiverOption) *Receiver
  • func (r *Receiver) Channels() []string
  • func (r *Receiver) Close() error
  • func (r *Receiver) Receive(ctx context.Context, channel string, h messaging.Handler) error
  • func (r *Receiver) Suspend(ctx context.Context, channel string) error
• type ReceiverOption
  • func ReceiverErrorHandler(h messaging.ErrorHandler) ReceiverOption
• type Registry
  • func NewRegistry() *Registry
  • func (r *Registry) Close() error
• type Sender
  • func NewSender(r *Registry) *Sender
  • func (s *Sender) Close() error
  • func (s *Sender) Send(ctx context.Context, channel string, h messaging.Header, route string, ...) (err error)

Types

type Channel

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

func NewChannel

func NewChannel(name string) *Channel

type Receiver

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

func NewReceiver

func NewReceiver(r *Registry, o ...ReceiverOption) *Receiver

func (*Receiver) Channels

func (r *Receiver) Channels() []string

func (*Receiver) Close

func (r *Receiver) Close() error

func (*Receiver) Receive

func (r *Receiver) Receive(ctx context.Context, channel string, h messaging.Handler) error

func (*Receiver) Suspend

func (r *Receiver) Suspend(ctx context.Context, channel string) error

type ReceiverOption

type ReceiverOption func(*Receiver)

func ReceiverErrorHandler

func ReceiverErrorHandler(h messaging.ErrorHandler) ReceiverOption

type Registry

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

func NewRegistry

func NewRegistry() *Registry

func (*Registry) Close

func (r *Registry) Close() error

type Sender

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

func NewSender

func NewSender(r *Registry) *Sender

func (*Sender) Close

func (s *Sender) Close() error

func (*Sender) Send

func (s *Sender) Send(ctx context.Context, channel string, h messaging.Header, route string, message []byte) (err error)