swarmtest

Documentation

Index

• type CustomNetTransport
  • func NewCustomNetTransport(config *memberlist.NetTransportConfig) (*CustomNetTransport, error)
  • func (t *CustomNetTransport) DialTimeout(addr string, timeout time.Duration) (net.Conn, error)
  • func (t *CustomNetTransport) Exit()
  • func (t *CustomNetTransport) FinalAdvertiseAddr(ip string, port int) (net.IP, int, error)
  • func (t *CustomNetTransport) PacketCh() <-chan *memberlist.Packet
  • func (t *CustomNetTransport) Shutdown() error
  • func (t *CustomNetTransport) StreamCh() <-chan net.Conn
  • func (t *CustomNetTransport) WriteTo(b []byte, addr string) (time.Time, error)
• type TestNode
  • func NewTestNode(name string, addr string, port int) (*TestNode, error)
  • func (node *TestNode) Addr() string
  • func (node *TestNode) Exit() error
  • func (node *TestNode) Join(nodesToJoin []string) error
  • func (node *TestNode) ListMembers() error
  • func (node *TestNode) ShutDown() error

Types

type CustomNetTransport

type CustomNetTransport struct {
	NetTransport *memberlist.NetTransport
	// contains filtered or unexported fields
}

func NewCustomNetTransport

func NewCustomNetTransport(config *memberlist.NetTransportConfig) (*CustomNetTransport, error)

func (*CustomNetTransport) DialTimeout

func (t *CustomNetTransport) DialTimeout(addr string, timeout time.Duration) (net.Conn, error)

func (*CustomNetTransport) Exit

func (t *CustomNetTransport) Exit()

func (*CustomNetTransport) FinalAdvertiseAddr

func (t *CustomNetTransport) FinalAdvertiseAddr(ip string, port int) (net.IP, int, error)

func (*CustomNetTransport) PacketCh

func (t *CustomNetTransport) PacketCh() <-chan *memberlist.Packet

func (*CustomNetTransport) Shutdown

func (t *CustomNetTransport) Shutdown() error

func (*CustomNetTransport) StreamCh

func (t *CustomNetTransport) StreamCh() <-chan net.Conn

func (*CustomNetTransport) WriteTo

func (t *CustomNetTransport) WriteTo(b []byte, addr string) (time.Time, error)

type TestNode

type TestNode struct {
	ShutDownAfter time.Duration
	// contains filtered or unexported fields
}

func NewTestNode

func NewTestNode(name string, addr string, port int) (*TestNode, error)

func (*TestNode) Addr

func (node *TestNode) Addr() string

func (*TestNode) Exit

func (node *TestNode) Exit() error

func (*TestNode) Join

func (node *TestNode) Join(nodesToJoin []string) error

func (*TestNode) ListMembers

func (node *TestNode) ListMembers() error

func (*TestNode) ShutDown

func (node *TestNode) ShutDown() error