skipper: github.com/zalando/skipper/swarm/swarmtest Index | Files

package swarmtest

import "github.com/zalando/skipper/swarm/swarmtest"

Index

Package Files

swarmtestutil.go transport.go

type CustomNetTransport Uses

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

func NewCustomNetTransport Uses

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

func (*CustomNetTransport) DialTimeout Uses

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

func (*CustomNetTransport) Exit Uses

func (t *CustomNetTransport) Exit()

func (*CustomNetTransport) FinalAdvertiseAddr Uses

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

func (*CustomNetTransport) PacketCh Uses

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

func (*CustomNetTransport) Shutdown Uses

func (t *CustomNetTransport) Shutdown() error

func (*CustomNetTransport) StreamCh Uses

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

func (*CustomNetTransport) WriteTo Uses

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

type TestNode Uses

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

func NewTestNode Uses

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

func (*TestNode) Addr Uses

func (node *TestNode) Addr() string

func (*TestNode) Exit Uses

func (node *TestNode) Exit() error

func (*TestNode) Join Uses

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

func (*TestNode) ListMembers Uses

func (node *TestNode) ListMembers() error

func (*TestNode) ShutDown Uses

func (node *TestNode) ShutDown() error

Package swarmtest imports 6 packages (graph). Updated 2019-02-07. Refresh now. Tools for package owners.