listeners

Documentation

Index

• type DefaultOutboundChannels
  • func (channels *DefaultOutboundChannels) Get(name string) (channel OutboundChannel, has bool)
  • func (channels *DefaultOutboundChannels) Set(name string, channel OutboundChannel)
• type Listener
• type ListenerOptions
• type Message
  • func NewMessage() Message
• type MessageHeader
• type OutboundChannel
• type OutboundChannels
  • func NewDefaultOutboundChannels() OutboundChannels

Types

type DefaultOutboundChannels

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

func (*DefaultOutboundChannels) Get

func (channels *DefaultOutboundChannels) Get(name string) (channel OutboundChannel, has bool)

func (*DefaultOutboundChannels) Set

func (channels *DefaultOutboundChannels) Set(name string, channel OutboundChannel)

type Listener

type Listener interface {
	Name() (name string)
	OutboundChannels() (channels OutboundChannels)
	Listen(ctx context.Context, options ListenerOptions) (err error)
	Close() (err error)
}

type ListenerOptions

type ListenerOptions struct {
	Log    logs.Logger
	Config configures.Config
}

type Message

type Message interface {
	Header() (header MessageHeader)
	SetBody(body []byte)
	Body() (body []byte)
}

func NewMessage

func NewMessage() Message

type MessageHeader

type MessageHeader interface {
	Get(key string) (value interface{})
	Set(key string, value interface{})
}

type OutboundChannel

type OutboundChannel interface {
	Name() (name string)
	Send(ctx context.Context, msg Message) (err errors.CodeError)
}

type OutboundChannels

type OutboundChannels interface {
	Get(name string) (channel OutboundChannel, has bool)
	Set(name string, channel OutboundChannel)
}

func NewDefaultOutboundChannels

func NewDefaultOutboundChannels() OutboundChannels