testhelpers

Documentation

Index

• Constants
• type RetryingConnection
  • func (c *RetryingConnection) Attach(handle string, processID string, io garden.ProcessIO) (garden.Process, error)
  • func (c *RetryingConnection) BulkInfo(handles []string) (map[string]garden.ContainerInfoEntry, error)
  • func (c *RetryingConnection) BulkMetrics(handles []string) (map[string]garden.ContainerMetricsEntry, error)
  • func (c *RetryingConnection) BulkNetOut(handle string, rules []garden.NetOutRule) error
  • func (c *RetryingConnection) Capacity() (garden.Capacity, error)
  • func (c *RetryingConnection) Create(spec garden.ContainerSpec) (string, error)
  • func (c *RetryingConnection) CurrentBandwidthLimits(handle string) (garden.BandwidthLimits, error)
  • func (c *RetryingConnection) CurrentCPULimits(handle string) (garden.CPULimits, error)
  • func (c *RetryingConnection) CurrentDiskLimits(handle string) (garden.DiskLimits, error)
  • func (c *RetryingConnection) CurrentMemoryLimits(handle string) (garden.MemoryLimits, error)
  • func (c *RetryingConnection) Destroy(handle string) error
  • func (c *RetryingConnection) Info(handle string) (garden.ContainerInfo, error)
  • func (c *RetryingConnection) List(properties garden.Properties) ([]string, error)
  • func (c *RetryingConnection) Metrics(handle string) (garden.Metrics, error)
  • func (c *RetryingConnection) NetIn(handle string, hostPort, containerPort uint32) (uint32, uint32, error)
  • func (c *RetryingConnection) NetOut(handle string, rule garden.NetOutRule) error
  • func (c *RetryingConnection) Ping() error
  • func (c *RetryingConnection) Properties(handle string) (garden.Properties, error)
  • func (c *RetryingConnection) Property(handle string, name string) (string, error)
  • func (c *RetryingConnection) RemoveProperty(handle string, name string) error
  • func (c *RetryingConnection) Run(handle string, spec garden.ProcessSpec, io garden.ProcessIO) (garden.Process, error)
  • func (c *RetryingConnection) SetGraceTime(handle string, graceTime time.Duration) error
  • func (c *RetryingConnection) SetProperty(handle string, name string, value string) error
  • func (c *RetryingConnection) Stop(handle string, kill bool) error
  • func (c *RetryingConnection) StreamIn(handle string, spec garden.StreamInSpec) error
  • func (c *RetryingConnection) StreamOut(handle string, spec garden.StreamOutSpec) (io.ReadCloser, error)
• type RetryingProcess
  • func (p *RetryingProcess) ID() string
  • func (p *RetryingProcess) SetTTY(ttySpec garden.TTYSpec) error
  • func (p *RetryingProcess) Signal(signal garden.Signal) error
  • func (p *RetryingProcess) Wait() (int, error)

Constants

const MAX_WAIT_RETRIES = 5

Types

type RetryingConnection

type RetryingConnection struct {
	Connection connection.Connection
}

func (*RetryingConnection) Attach

func (c *RetryingConnection) Attach(handle string, processID string, io garden.ProcessIO) (garden.Process, error)

func (*RetryingConnection) BulkInfo

func (c *RetryingConnection) BulkInfo(handles []string) (map[string]garden.ContainerInfoEntry, error)

func (*RetryingConnection) BulkMetrics

func (c *RetryingConnection) BulkMetrics(handles []string) (map[string]garden.ContainerMetricsEntry, error)

func (*RetryingConnection) BulkNetOut

func (c *RetryingConnection) BulkNetOut(handle string, rules []garden.NetOutRule) error

func (*RetryingConnection) Capacity

func (c *RetryingConnection) Capacity() (garden.Capacity, error)

func (*RetryingConnection) Create

func (c *RetryingConnection) Create(spec garden.ContainerSpec) (string, error)

func (*RetryingConnection) CurrentBandwidthLimits

func (c *RetryingConnection) CurrentBandwidthLimits(handle string) (garden.BandwidthLimits, error)

func (*RetryingConnection) CurrentCPULimits

func (c *RetryingConnection) CurrentCPULimits(handle string) (garden.CPULimits, error)

func (*RetryingConnection) CurrentDiskLimits

func (c *RetryingConnection) CurrentDiskLimits(handle string) (garden.DiskLimits, error)

func (*RetryingConnection) CurrentMemoryLimits

func (c *RetryingConnection) CurrentMemoryLimits(handle string) (garden.MemoryLimits, error)

func (*RetryingConnection) Destroy

func (c *RetryingConnection) Destroy(handle string) error

func (*RetryingConnection) Info

func (c *RetryingConnection) Info(handle string) (garden.ContainerInfo, error)

func (*RetryingConnection) List

func (c *RetryingConnection) List(properties garden.Properties) ([]string, error)

func (*RetryingConnection) Metrics

func (c *RetryingConnection) Metrics(handle string) (garden.Metrics, error)

func (*RetryingConnection) NetIn

func (c *RetryingConnection) NetIn(handle string, hostPort, containerPort uint32) (uint32, uint32, error)

func (*RetryingConnection) NetOut

func (c *RetryingConnection) NetOut(handle string, rule garden.NetOutRule) error

func (*RetryingConnection) Ping

func (c *RetryingConnection) Ping() error

func (*RetryingConnection) Properties

func (c *RetryingConnection) Properties(handle string) (garden.Properties, error)

func (*RetryingConnection) Property

func (c *RetryingConnection) Property(handle string, name string) (string, error)

func (*RetryingConnection) RemoveProperty

func (c *RetryingConnection) RemoveProperty(handle string, name string) error

func (*RetryingConnection) Run

func (c *RetryingConnection) Run(handle string, spec garden.ProcessSpec, io garden.ProcessIO) (garden.Process, error)

func (*RetryingConnection) SetGraceTime

func (c *RetryingConnection) SetGraceTime(handle string, graceTime time.Duration) error

func (*RetryingConnection) SetProperty

func (c *RetryingConnection) SetProperty(handle string, name string, value string) error

func (*RetryingConnection) Stop

func (c *RetryingConnection) Stop(handle string, kill bool) error

func (*RetryingConnection) StreamIn

func (c *RetryingConnection) StreamIn(handle string, spec garden.StreamInSpec) error

func (*RetryingConnection) StreamOut

func (c *RetryingConnection) StreamOut(handle string, spec garden.StreamOutSpec) (io.ReadCloser, error)

type RetryingProcess

type RetryingProcess struct {
	Process garden.Process
}

func (*RetryingProcess) ID

func (p *RetryingProcess) ID() string

func (*RetryingProcess) SetTTY

func (p *RetryingProcess) SetTTY(ttySpec garden.TTYSpec) error

func (*RetryingProcess) Signal

func (p *RetryingProcess) Signal(signal garden.Signal) error

func (*RetryingProcess) Wait

func (p *RetryingProcess) Wait() (int, error)