simplechannel

Documentation

Index

• type ChannelAdapter
  • func New(done <-chan bool, wg *sync.WaitGroup) *ChannelAdapter
  • func (ca *ChannelAdapter) GetInputChannel(name string) (chan<- []byte, error)
  • func (ca *ChannelAdapter) GetMode(name string) (channel.Mode, error)
  • func (ca *ChannelAdapter) GetOutputChannel(name string) (<-chan channel.Message, error)
  • func (ca *ChannelAdapter) NewChannel(name string, mode channel.Mode, bufferSize, maxRetryPolicy int) error

Types

type ChannelAdapter

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

func New

func New(done <-chan bool, wg *sync.WaitGroup) *ChannelAdapter

func (*ChannelAdapter) GetInputChannel

func (ca *ChannelAdapter) GetInputChannel(name string) (chan<- []byte, error)

func (*ChannelAdapter) GetMode

func (ca *ChannelAdapter) GetMode(name string) (channel.Mode, error)

func (*ChannelAdapter) GetOutputChannel

func (ca *ChannelAdapter) GetOutputChannel(name string) (<-chan channel.Message, error)

func (*ChannelAdapter) NewChannel

func (ca *ChannelAdapter) NewChannel(name string, mode channel.Mode, bufferSize, maxRetryPolicy int) error