connection

Documentation

Index

• Variables
• type Connection
  • func Connect(network, addr string) (*Connection, error)
  • func New(conn net.Conn) *Connection
  • func (c *Connection) Attach(handle string, processID uint32) (chan *warden.ProcessPayload, error)
  • func (c *Connection) Close()
  • func (c *Connection) CopyIn(handle, src, dst string) (*warden.CopyInResponse, error)
  • func (c *Connection) CopyOut(handle, src, dst, owner string) (*warden.CopyOutResponse, error)
  • func (c *Connection) Create(properties map[string]string) (*warden.CreateResponse, error)
  • func (c *Connection) Destroy(handle string) (*warden.DestroyResponse, error)
  • func (c *Connection) GetDiskLimit(handle string) (uint64, error)
  • func (c *Connection) GetMemoryLimit(handle string) (uint64, error)
  • func (c *Connection) Info(handle string) (*warden.InfoResponse, error)
  • func (c *Connection) LimitCPU(request *warden.LimitCpuRequest) (*warden.LimitCpuResponse, error)
  • func (c *Connection) LimitDisk(request *warden.LimitDiskRequest) (*warden.LimitDiskResponse, error)
  • func (c *Connection) LimitMemory(handle string, limit uint64) (*warden.LimitMemoryResponse, error)
  • func (c *Connection) List(filterProperties map[string]string) (*warden.ListResponse, error)
  • func (c *Connection) NetIn(handle string) (*warden.NetInResponse, error)
  • func (c *Connection) ReadResponse(response proto.Message) (proto.Message, error)
  • func (c *Connection) RoundTrip(request proto.Message, response proto.Message) (proto.Message, error)
  • func (c *Connection) Run(handle, script string, resourceLimits *warden.ResourceLimits, ...) (uint32, chan *warden.ProcessPayload, error)
  • func (c *Connection) SendMessage(req proto.Message) error
  • func (c *Connection) Stop(handle string, background, kill bool) (*warden.StopResponse, error)
• type WardenError
  • func (e *WardenError) Error() string

Variables

var DisconnectedError = errors.New("disconnected")

Types

type Connection

type Connection struct {
	Disconnected chan bool
	// contains filtered or unexported fields
}

func Connect

func Connect(network, addr string) (*Connection, error)

func New

func New(conn net.Conn) *Connection

func (*Connection) Attach

func (c *Connection) Attach(handle string, processID uint32) (chan *warden.ProcessPayload, error)

func (*Connection) Close

func (c *Connection) Close()

func (*Connection) CopyIn

func (c *Connection) CopyIn(handle, src, dst string) (*warden.CopyInResponse, error)

func (*Connection) CopyOut

func (c *Connection) CopyOut(handle, src, dst, owner string) (*warden.CopyOutResponse, error)

func (*Connection) Create

func (c *Connection) Create(properties map[string]string) (*warden.CreateResponse, error)

func (*Connection) Destroy

func (c *Connection) Destroy(handle string) (*warden.DestroyResponse, error)

func (*Connection) GetDiskLimit

func (c *Connection) GetDiskLimit(handle string) (uint64, error)

func (*Connection) GetMemoryLimit

func (c *Connection) GetMemoryLimit(handle string) (uint64, error)

func (*Connection) Info

func (c *Connection) Info(handle string) (*warden.InfoResponse, error)

func (*Connection) LimitCPU

func (c *Connection) LimitCPU(request *warden.LimitCpuRequest) (*warden.LimitCpuResponse, error)

func (*Connection) LimitDisk

func (c *Connection) LimitDisk(request *warden.LimitDiskRequest) (*warden.LimitDiskResponse, error)

func (*Connection) LimitMemory

func (c *Connection) LimitMemory(handle string, limit uint64) (*warden.LimitMemoryResponse, error)

func (*Connection) List

func (c *Connection) List(filterProperties map[string]string) (*warden.ListResponse, error)

func (*Connection) NetIn

func (c *Connection) NetIn(handle string) (*warden.NetInResponse, error)

func (*Connection) ReadResponse

func (c *Connection) ReadResponse(response proto.Message) (proto.Message, error)

func (*Connection) RoundTrip

func (c *Connection) RoundTrip(request proto.Message, response proto.Message) (proto.Message, error)

func (*Connection) Run

func (c *Connection) Run(handle, script string, resourceLimits *warden.ResourceLimits, environmentVariables []*warden.EnvironmentVariable) (uint32, chan *warden.ProcessPayload, error)

func (*Connection) SendMessage

func (c *Connection) SendMessage(req proto.Message) error

func (*Connection) Stop

func (c *Connection) Stop(handle string, background, kill bool) (*warden.StopResponse, error)

type WardenError

type WardenError struct {
	Message   string
	Data      string
	Backtrace []string
}

func (*WardenError) Error

func (e *WardenError) Error() string