proxyutils

Documentation

Index

• func Disconnect(t *testing.T, proxyName string, duration time.Duration) (started, stopped func())
• func DisconnectWithStartStartedStopped(t *testing.T, proxyName string, duration time.Duration) (disconnect, awaitStarted, awaitStopped func())
• func DisconnectWithStartedStopped(t *testing.T, proxyName string, block, startIn, duration time.Duration) (awaitStarted, awaitStopped func())
• func DisconnectWithStopped(t *testing.T, proxyName string, block, timeout, duration time.Duration) (wait func())
• type Proxy
  • func NewProxy(t *testing.T, proxyName string) *Proxy
  • func (p *Proxy) Close() error
  • func (p *Proxy) Disable() error
  • func (p *Proxy) Enable() error

Functions

func Disconnect

func Disconnect(t *testing.T, proxyName string, duration time.Duration) (started, stopped func())

func DisconnectWithStartStartedStopped

func DisconnectWithStartStartedStopped(t *testing.T, proxyName string, duration time.Duration) (disconnect, awaitStarted, awaitStopped func())

block current thread timeout: how long the asynchronous goroutine needs to wait until it disables the connection duration: how long the asynchronous goroutine wait suntil it reenables the connection

func DisconnectWithStartedStopped

func DisconnectWithStartedStopped(t *testing.T, proxyName string, block, startIn, duration time.Duration) (awaitStarted, awaitStopped func())

https://github.com/Shopify/toxiproxy#toxics block current thread timeout: how long the asynchronous goroutine needs to wait until it disables the connection duration: how long the asynchronous goroutine wait suntil it reenables the connection

func DisconnectWithStopped

func DisconnectWithStopped(t *testing.T, proxyName string, block, timeout, duration time.Duration) (wait func())

https://github.com/Shopify/toxiproxy#toxics block current thread timeout: how long the asynchronous goroutine needs to wait until it disables the connection duration: how long the asynchronous goroutine wait suntil it reenables the connection

Types

type Proxy

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

func NewProxy

func NewProxy(t *testing.T, proxyName string) *Proxy

func (*Proxy) Close

func (p *Proxy) Close() error

func (*Proxy) Disable

func (p *Proxy) Disable() error

func (*Proxy) Enable

func (p *Proxy) Enable() error