testutil

Documentation

Index

• type LinkStateChecker
  • func StartLinkTest(id string, uf channel.UnderlayFactory, assertions *require.Assertions) (channel.Channel, *LinkStateChecker)
  • func (self *LinkStateChecker) HandleFault(msg *channel.Message, _ channel.Channel)
  • func (self *LinkStateChecker) HandleLink(msg *channel.Message, _ channel.Channel)
  • func (self *LinkStateChecker) HandleOther(msg *channel.Message, _ channel.Channel)
  • func (self *LinkStateChecker) RequireNoErrors()
  • func (self *LinkStateChecker) RequireOneActiveLink() *TestLink
• 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 TestLink
• 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 LinkStateChecker

type LinkStateChecker struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func StartLinkTest

func StartLinkTest(id string, uf channel.UnderlayFactory, assertions *require.Assertions) (channel.Channel, *LinkStateChecker)

func (*LinkStateChecker) HandleFault

func (self *LinkStateChecker) HandleFault(msg *channel.Message, _ channel.Channel)

func (*LinkStateChecker) HandleLink

func (self *LinkStateChecker) HandleLink(msg *channel.Message, _ channel.Channel)

func (*LinkStateChecker) HandleOther

func (self *LinkStateChecker) HandleOther(msg *channel.Message, _ channel.Channel)

func (*LinkStateChecker) RequireNoErrors

func (self *LinkStateChecker) RequireNoErrors()

func (*LinkStateChecker) RequireOneActiveLink

func (self *LinkStateChecker) RequireOneActiveLink() *TestLink

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 TestLink

type TestLink struct {
	Id     string
	Dest   string
	Failed bool
}

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)