testutil

Documentation

Index

• type MessageCollector
  • func AcceptControl(id string, uf channel.UnderlayFactory, assertions *require.Assertions) (channel.Channel, *MessageCollector)
  • func NewMessageCollector(id string) *MessageCollector
  • func (self *MessageCollector) HandleReceive(m *channel.Message, ch channel.Channel)
  • func (self *MessageCollector) Next(timeout time.Duration) (*channel.Message, error)
  • func (self *MessageCollector) NoMessages(timeout time.Duration, req require.Assertions)
• type UnderlayFactoryWrapper
  • func NewTimeoutUnderlayFactory(factory channel.UnderlayFactory, timeout time.Duration) *UnderlayFactoryWrapper
  • func (self *UnderlayFactoryWrapper) Create(timeout time.Duration, tcfg transport.Configuration) (channel.Underlay, error)

Types

type MessageCollector

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

func AcceptControl

func AcceptControl(id string, uf channel.UnderlayFactory, assertions *require.Assertions) (channel.Channel, *MessageCollector)

func NewMessageCollector

func NewMessageCollector(id string) *MessageCollector

func (*MessageCollector) HandleReceive

func (self *MessageCollector) HandleReceive(m *channel.Message, ch channel.Channel)

func (*MessageCollector) Next

func (self *MessageCollector) Next(timeout time.Duration) (*channel.Message, error)

func (*MessageCollector) NoMessages

func (self *MessageCollector) NoMessages(timeout time.Duration, req require.Assertions)

type UnderlayFactoryWrapper

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

func NewTimeoutUnderlayFactory

func NewTimeoutUnderlayFactory(factory channel.UnderlayFactory, timeout time.Duration) *UnderlayFactoryWrapper

func (*UnderlayFactoryWrapper) Create

func (self *UnderlayFactoryWrapper) Create(timeout time.Duration, tcfg transport.Configuration) (channel.Underlay, error)