systemtest

Documentation

Index

• type Conn
  • func (c *Conn) Close() error
  • func (c *Conn) Read(b []byte) (int, error)
  • func (c *Conn) Write(b []byte) (int, error)
• type FIProxy
  • func NewFIProxy() *FIProxy
  • func (fip *FIProxy) Dial(network, addr string) (c net.Conn, err error)
  • func (fip *FIProxy) ResetErrors()
  • func (fip *FIProxy) SetReadError(err error)
  • func (fip *FIProxy) SetWriteError(err error)
  • func (fip *FIProxy) String() string

Types

type Conn

type Conn struct {
	net.Conn
	// contains filtered or unexported fields
}

func (*Conn) Close

func (c *Conn) Close() error

func (*Conn) Read

func (c *Conn) Read(b []byte) (int, error)

func (*Conn) Write

func (c *Conn) Write(b []byte) (int, error)

type FIProxy

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

FIProxy is a fault injecting proxy hooked into the sarama-config to proxy connections to kafka and inject connection loss etc.

func NewFIProxy

func NewFIProxy() *FIProxy

func (*FIProxy) Dial

func (fip *FIProxy) Dial(network, addr string) (c net.Conn, err error)

func (*FIProxy) ResetErrors

func (fip *FIProxy) ResetErrors()

func (*FIProxy) SetReadError

func (fip *FIProxy) SetReadError(err error)

func (*FIProxy) SetWriteError

func (fip *FIProxy) SetWriteError(err error)

func (*FIProxy) String

func (fip *FIProxy) String() string