testutil

Documentation

Index

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

Functions

func StartLinkTest

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

Types

type LinkStateChecker

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

func NewLinkChecker

func NewLinkChecker(assertions *require.Assertions) *LinkStateChecker

func (*LinkStateChecker) HandleFault

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

func (*LinkStateChecker) HandleLink

func (self *LinkStateChecker) HandleLink(msg *channel.Message, ch 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
	Src        string
	Dest       string
	FaultCount int
	Valid      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)