warden

package module
v0.0.0-...-73c4d73 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 7, 2014 License: Apache-2.0, BSD-3-Clause Imports: 10 Imported by: 0

README

Gordon

A simple Warden client. Handles automatic reconnection, and implicitly creates new connections for blocking calls like Run, Link, and Stream.

Installation

cd $GOPATH
go get github.com/vito/gordon

Usage

package main

import (
  "fmt"
  "github.com/vito/gordon"
  "os"
)

func main() {
  client := warden.NewClient(
    &warden.ConnectionInfo{
      SocketPath: "/tmp/warden.sock"
    }
  )

  err := client.Connect()
  if err != nil {
    fmt.Println("Failed to connect to Warden: ", err)
    os.Exit(1)
    return
  }

  createResponse, err := client.Create()
  if err != nil {
    fmt.Println("Failed to create container: ", err)
    os.Exit(1)
    return
  }

  handle := createResponse.GetHandle()
  defer client.Destroy(handle)

  fmt.Printf("Container: %s\n", handle)

  spawnResponse, err := client.Spawn(handle, `
    for i in $(seq 10); do
      echo out $i;
      echo err $i 1>&2;
      sleep 1;
    done
  `)

  if err != nil {
    fmt.Println("Failed to spawn process: ", err)
    os.Exit(1)
    return
  }

  fmt.Println("Spawned!", spawnResponse)

  responses, err := client.Stream(handle, spawnResponse.GetJobId())
  if err != nil {
    fmt.Println("Failed to stream output: ", err)
    os.Exit(1)
    return
  }

  fmt.Println("Streaming output...")

  for {
    res, ok := <-responses
    if !ok {
      break
    }

    if res.ExitStatus == nil {
      fmt.Printf("%s: %s", res.GetName(), res.GetData())
    } else {
      fmt.Printf("exited: %d\n", res.GetExitStatus())
    }
  }
}

Documentation

Index

Constants

View Source 
const Default_RunRequest_Privileged bool = false
View Source 
const Default_SpawnRequest_Privileged bool = false
View Source 
const Default_StopRequest_Background bool = false
View Source 
const Default_StopRequest_Kill bool = false

Variables

View Source 
var CreateRequest_BindMount_Mode_name = map[int32]string{
	0: "RO",
	1: "RW",
}
View Source 
var CreateRequest_BindMount_Mode_value = map[string]int32{
	"RO": 0,
	"RW": 1,
}
View Source 
var Message_Type_name = map[int32]string{
	1:  "Error",
	11: "Create",
	12: "Stop",
	13: "Destroy",
	14: "Info",
	21: "Spawn",
	22: "Link",
	23: "Run",
	24: "Stream",
	31: "NetIn",
	32: "NetOut",
	41: "CopyIn",
	42: "CopyOut",
	51: "LimitMemory",
	52: "LimitDisk",
	53: "LimitBandwidth",
	91: "Ping",
	92: "List",
	93: "Echo",
}
View Source 
var Message_Type_value = map[string]int32{
	"Error":          1,
	"Create":         11,
	"Stop":           12,
	"Destroy":        13,
	"Info":           14,
	"Spawn":          21,
	"Link":           22,
	"Run":            23,
	"Stream":         24,
	"NetIn":          31,
	"NetOut":         32,
	"CopyIn":         41,
	"CopyOut":        42,
	"LimitMemory":    51,
	"LimitDisk":      52,
	"LimitBandwidth": 53,
	"Ping":           91,
	"List":           92,
	"Echo":           93,
}

Functions

This section is empty.

Types

type Client 

type Client struct {
	SocketPath string
	// contains filtered or unexported fields
}

func NewClient 

func NewClient(cp ConnectionProvider) *Client

func (*Client) Connect 

func (c *Client) Connect() error

func (*Client) CopyIn 

func (c *Client) CopyIn(handle, src, dst string) (*CopyInResponse, error)

func (*Client) Create 

func (c *Client) Create() (*CreateResponse, error)

func (*Client) CreateByRequest 

func (c *Client) CreateByRequest(*CreateRequest) (*CreateResponse, error)

func (*Client) Destroy 

func (c *Client) Destroy(handle string) (*DestroyResponse, error)

func (*Client) GetDiskLimit 

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

func (*Client) GetMemoryLimit 

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

func (*Client) Info 

func (c *Client) Info(handle string) (*InfoResponse, error)

func (*Client) LimitDisk 

func (c *Client) LimitDisk(handle string, limit uint64) (*LimitDiskResponse, error)

func (*Client) LimitMemory 

func (c *Client) LimitMemory(handle string, limit uint64) (*LimitMemoryResponse, error)

func (*Client) List 

func (c *Client) List() (*ListResponse, error)

func (*Client) NetIn 

func (c *Client) NetIn(handle string) (*NetInResponse, error)

func (*Client) Run 

func (c *Client) Run(handle, script string) (*RunResponse, error)

func (*Client) Spawn 

func (c *Client) Spawn(handle, script string) (*SpawnResponse, error)

func (*Client) Stream 

func (c *Client) Stream(handle string, jobId uint32) (chan *StreamResponse, error)

type ConnectedWardenClient 

type ConnectedWardenClient interface {
	CreateByRequest(*CreateRequest) (*CreateResponse, error)
	LimitDisk(string, uint64) (*LimitDiskResponse, error)
	LimitMemory(string, uint64) (*LimitMemoryResponse, error)
}

type Connection 

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

func Connect 

func Connect(socket_path string) (*Connection, error)

func NewConnection 

func NewConnection(conn net.Conn) *Connection

func (*Connection) Close 

func (c *Connection) Close()

func (*Connection) CopyIn 

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

func (*Connection) Create 

func (c *Connection) Create() (*CreateResponse, error)

func (*Connection) Destroy 

func (c *Connection) Destroy(handle string) (*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) (*InfoResponse, error)

func (*Connection) LimitDisk 

func (c *Connection) LimitDisk(handle string, limit uint64) (*LimitDiskResponse, error)

func (*Connection) LimitMemory 

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

func (*Connection) List 

func (c *Connection) List() (*ListResponse, error)

func (*Connection) NetIn 

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

func (*Connection) Run 

func (c *Connection) Run(handle, script string) (*RunResponse, error)

func (*Connection) Spawn 

func (c *Connection) Spawn(handle, script string) (*SpawnResponse, error)

func (*Connection) Stream 

func (c *Connection) Stream(handle string, jobId uint32) (chan *StreamResponse, error)

type ConnectionInfo 

type ConnectionInfo struct {
	SocketPath string
}

func (*ConnectionInfo) ProvideConnection 

func (i *ConnectionInfo) ProvideConnection() (*Connection, error)

type ConnectionProvider 

type ConnectionProvider interface {
	ProvideConnection() (*Connection, error)
}

type CopyInRequest 

type CopyInRequest struct {
	Handle           *string `protobuf:"bytes,1,req,name=handle" json:"handle,omitempty"`
	SrcPath          *string `protobuf:"bytes,2,req,name=src_path" json:"src_path,omitempty"`
	DstPath          *string `protobuf:"bytes,3,req,name=dst_path" json:"dst_path,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*CopyInRequest) GetDstPath 

func (m *CopyInRequest) GetDstPath() string

func (*CopyInRequest) GetHandle 

func (m *CopyInRequest) GetHandle() string

func (*CopyInRequest) GetSrcPath 

func (m *CopyInRequest) GetSrcPath() string

func (*CopyInRequest) ProtoMessage 

func (*CopyInRequest) ProtoMessage()

func (*CopyInRequest) Reset 

func (m *CopyInRequest) Reset()

func (*CopyInRequest) String 

func (m *CopyInRequest) String() string

type CopyInResponse 

type CopyInResponse struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*CopyInResponse) ProtoMessage 

func (*CopyInResponse) ProtoMessage()

func (*CopyInResponse) Reset 

func (m *CopyInResponse) Reset()

func (*CopyInResponse) String 

func (m *CopyInResponse) String() string

type CopyOutRequest 

type CopyOutRequest struct {
	Handle           *string `protobuf:"bytes,1,req,name=handle" json:"handle,omitempty"`
	SrcPath          *string `protobuf:"bytes,2,req,name=src_path" json:"src_path,omitempty"`
	DstPath          *string `protobuf:"bytes,3,req,name=dst_path" json:"dst_path,omitempty"`
	Owner            *string `protobuf:"bytes,4,opt,name=owner" json:"owner,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*CopyOutRequest) GetDstPath 

func (m *CopyOutRequest) GetDstPath() string

func (*CopyOutRequest) GetHandle 

func (m *CopyOutRequest) GetHandle() string

func (*CopyOutRequest) GetOwner 

func (m *CopyOutRequest) GetOwner() string

func (*CopyOutRequest) GetSrcPath 

func (m *CopyOutRequest) GetSrcPath() string

func (*CopyOutRequest) ProtoMessage 

func (*CopyOutRequest) ProtoMessage()

func (*CopyOutRequest) Reset 

func (m *CopyOutRequest) Reset()

func (*CopyOutRequest) String 

func (m *CopyOutRequest) String() string

type CopyOutResponse 

type CopyOutResponse struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*CopyOutResponse) ProtoMessage 

func (*CopyOutResponse) ProtoMessage()

func (*CopyOutResponse) Reset 

func (m *CopyOutResponse) Reset()

func (*CopyOutResponse) String 

func (m *CopyOutResponse) String() string

type CreateRequest 

type CreateRequest struct {
	BindMounts       []*CreateRequest_BindMount `protobuf:"bytes,1,rep,name=bind_mounts" json:"bind_mounts,omitempty"`
	GraceTime        *uint32                    `protobuf:"varint,2,opt,name=grace_time" json:"grace_time,omitempty"`
	Handle           *string                    `protobuf:"bytes,3,opt,name=handle" json:"handle,omitempty"`
	Network          *string                    `protobuf:"bytes,4,opt,name=network" json:"network,omitempty"`
	Rootfs           *string                    `protobuf:"bytes,5,opt,name=rootfs" json:"rootfs,omitempty"`
	XXX_unrecognized []byte                     `json:"-"`
}

func (*CreateRequest) GetBindMounts 

func (m *CreateRequest) GetBindMounts() []*CreateRequest_BindMount

func (*CreateRequest) GetGraceTime 

func (m *CreateRequest) GetGraceTime() uint32

func (*CreateRequest) GetHandle 

func (m *CreateRequest) GetHandle() string

func (*CreateRequest) GetNetwork 

func (m *CreateRequest) GetNetwork() string

func (*CreateRequest) GetRootfs 

func (m *CreateRequest) GetRootfs() string

func (*CreateRequest) ProtoMessage 

func (*CreateRequest) ProtoMessage()

func (*CreateRequest) Reset 

func (m *CreateRequest) Reset()

func (*CreateRequest) String 

func (m *CreateRequest) String() string

type CreateRequest_BindMount 

type CreateRequest_BindMount struct {
	SrcPath          *string                       `protobuf:"bytes,1,req,name=src_path" json:"src_path,omitempty"`
	DstPath          *string                       `protobuf:"bytes,2,req,name=dst_path" json:"dst_path,omitempty"`
	Mode             *CreateRequest_BindMount_Mode `protobuf:"varint,3,req,name=mode,enum=warden.CreateRequest_BindMount_Mode" json:"mode,omitempty"`
	XXX_unrecognized []byte                        `json:"-"`
}

func (*CreateRequest_BindMount) GetDstPath 

func (m *CreateRequest_BindMount) GetDstPath() string

func (*CreateRequest_BindMount) GetMode 

func (m *CreateRequest_BindMount) GetMode() CreateRequest_BindMount_Mode

func (*CreateRequest_BindMount) GetSrcPath 

func (m *CreateRequest_BindMount) GetSrcPath() string

func (*CreateRequest_BindMount) ProtoMessage 

func (*CreateRequest_BindMount) ProtoMessage()

func (*CreateRequest_BindMount) Reset 

func (m *CreateRequest_BindMount) Reset()

func (*CreateRequest_BindMount) String 

func (m *CreateRequest_BindMount) String() string

type CreateRequest_BindMount_Mode 

type CreateRequest_BindMount_Mode int32
const (
	CreateRequest_BindMount_RO CreateRequest_BindMount_Mode = 0
	CreateRequest_BindMount_RW CreateRequest_BindMount_Mode = 1
)

func (CreateRequest_BindMount_Mode) Enum 

func (x CreateRequest_BindMount_Mode) Enum() *CreateRequest_BindMount_Mode

func (CreateRequest_BindMount_Mode) MarshalJSON 

func (x CreateRequest_BindMount_Mode) MarshalJSON() ([]byte, error)

func (CreateRequest_BindMount_Mode) String 

func (x CreateRequest_BindMount_Mode) String() string

func (*CreateRequest_BindMount_Mode) UnmarshalJSON 

func (x *CreateRequest_BindMount_Mode) UnmarshalJSON(data []byte) error

type CreateResponse 

type CreateResponse struct {
	Handle           *string `protobuf:"bytes,1,req,name=handle" json:"handle,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*CreateResponse) GetHandle 

func (m *CreateResponse) GetHandle() string

func (*CreateResponse) ProtoMessage 

func (*CreateResponse) ProtoMessage()

func (*CreateResponse) Reset 

func (m *CreateResponse) Reset()

func (*CreateResponse) String 

func (m *CreateResponse) String() string

type DestroyRequest 

type DestroyRequest struct {
	Handle           *string `protobuf:"bytes,1,req,name=handle" json:"handle,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*DestroyRequest) GetHandle 

func (m *DestroyRequest) GetHandle() string

func (*DestroyRequest) ProtoMessage 

func (*DestroyRequest) ProtoMessage()

func (*DestroyRequest) Reset 

func (m *DestroyRequest) Reset()

func (*DestroyRequest) String 

func (m *DestroyRequest) String() string

type DestroyResponse 

type DestroyResponse struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*DestroyResponse) ProtoMessage 

func (*DestroyResponse) ProtoMessage()

func (*DestroyResponse) Reset 

func (m *DestroyResponse) Reset()

func (*DestroyResponse) String 

func (m *DestroyResponse) String() string

type EchoRequest 

type EchoRequest struct {
	Message          *string `protobuf:"bytes,1,req,name=message" json:"message,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*EchoRequest) GetMessage 

func (m *EchoRequest) GetMessage() string

func (*EchoRequest) ProtoMessage 

func (*EchoRequest) ProtoMessage()

func (*EchoRequest) Reset 

func (m *EchoRequest) Reset()

func (*EchoRequest) String 

func (m *EchoRequest) String() string

type EchoResponse 

type EchoResponse struct {
	Message          *string `protobuf:"bytes,1,req,name=message" json:"message,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*EchoResponse) GetMessage 

func (m *EchoResponse) GetMessage() string

func (*EchoResponse) ProtoMessage 

func (*EchoResponse) ProtoMessage()

func (*EchoResponse) Reset 

func (m *EchoResponse) Reset()

func (*EchoResponse) String 

func (m *EchoResponse) String() string

type ErrorResponse 

type ErrorResponse struct {
	Message          *string  `protobuf:"bytes,2,opt,name=message" json:"message,omitempty"`
	Data             *string  `protobuf:"bytes,4,opt,name=data" json:"data,omitempty"`
	Backtrace        []string `protobuf:"bytes,3,rep,name=backtrace" json:"backtrace,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

func (*ErrorResponse) GetBacktrace 

func (m *ErrorResponse) GetBacktrace() []string

func (*ErrorResponse) GetData 

func (m *ErrorResponse) GetData() string

func (*ErrorResponse) GetMessage 

func (m *ErrorResponse) GetMessage() string

func (*ErrorResponse) ProtoMessage 

func (*ErrorResponse) ProtoMessage()

func (*ErrorResponse) Reset 

func (m *ErrorResponse) Reset()

func (*ErrorResponse) String 

func (m *ErrorResponse) String() string

type InfoRequest 

type InfoRequest struct {
	Handle           *string `protobuf:"bytes,1,req,name=handle" json:"handle,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*InfoRequest) GetHandle 

func (m *InfoRequest) GetHandle() string

func (*InfoRequest) ProtoMessage 

func (*InfoRequest) ProtoMessage()

func (*InfoRequest) Reset 

func (m *InfoRequest) Reset()

func (*InfoRequest) String 

func (m *InfoRequest) String() string

type InfoResponse 

type InfoResponse struct {
	State            *string                     `protobuf:"bytes,10,opt,name=state" json:"state,omitempty"`
	Events           []string                    `protobuf:"bytes,20,rep,name=events" json:"events,omitempty"`
	HostIp           *string                     `protobuf:"bytes,30,opt,name=host_ip" json:"host_ip,omitempty"`
	ContainerIp      *string                     `protobuf:"bytes,31,opt,name=container_ip" json:"container_ip,omitempty"`
	ContainerPath    *string                     `protobuf:"bytes,32,opt,name=container_path" json:"container_path,omitempty"`
	MemoryStat       *InfoResponse_MemoryStat    `protobuf:"bytes,40,opt,name=memory_stat" json:"memory_stat,omitempty"`
	CpuStat          *InfoResponse_CpuStat       `protobuf:"bytes,41,opt,name=cpu_stat" json:"cpu_stat,omitempty"`
	DiskStat         *InfoResponse_DiskStat      `protobuf:"bytes,42,opt,name=disk_stat" json:"disk_stat,omitempty"`
	BandwidthStat    *InfoResponse_BandwidthStat `protobuf:"bytes,43,opt,name=bandwidth_stat" json:"bandwidth_stat,omitempty"`
	JobIds           []uint64                    `protobuf:"varint,44,rep,name=job_ids" json:"job_ids,omitempty"`
	XXX_unrecognized []byte                      `json:"-"`
}

func (*InfoResponse) GetBandwidthStat 

func (m *InfoResponse) GetBandwidthStat() *InfoResponse_BandwidthStat

func (*InfoResponse) GetContainerIp 

func (m *InfoResponse) GetContainerIp() string

func (*InfoResponse) GetContainerPath 

func (m *InfoResponse) GetContainerPath() string

func (*InfoResponse) GetCpuStat 

func (m *InfoResponse) GetCpuStat() *InfoResponse_CpuStat

func (*InfoResponse) GetDiskStat 

func (m *InfoResponse) GetDiskStat() *InfoResponse_DiskStat

func (*InfoResponse) GetEvents 

func (m *InfoResponse) GetEvents() []string

func (*InfoResponse) GetHostIp 

func (m *InfoResponse) GetHostIp() string

func (*InfoResponse) GetJobIds 

func (m *InfoResponse) GetJobIds() []uint64

func (*InfoResponse) GetMemoryStat 

func (m *InfoResponse) GetMemoryStat() *InfoResponse_MemoryStat

func (*InfoResponse) GetState 

func (m *InfoResponse) GetState() string

func (*InfoResponse) ProtoMessage 

func (*InfoResponse) ProtoMessage()

func (*InfoResponse) Reset 

func (m *InfoResponse) Reset()

func (*InfoResponse) String 

func (m *InfoResponse) String() string

type InfoResponse_BandwidthStat 

type InfoResponse_BandwidthStat struct {
	InRate           *uint64 `protobuf:"varint,1,opt,name=in_rate" json:"in_rate,omitempty"`
	InBurst          *uint64 `protobuf:"varint,2,opt,name=in_burst" json:"in_burst,omitempty"`
	OutRate          *uint64 `protobuf:"varint,3,opt,name=out_rate" json:"out_rate,omitempty"`
	OutBurst         *uint64 `protobuf:"varint,4,opt,name=out_burst" json:"out_burst,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*InfoResponse_BandwidthStat) GetInBurst 

func (m *InfoResponse_BandwidthStat) GetInBurst() uint64

func (*InfoResponse_BandwidthStat) GetInRate 

func (m *InfoResponse_BandwidthStat) GetInRate() uint64

func (*InfoResponse_BandwidthStat) GetOutBurst 

func (m *InfoResponse_BandwidthStat) GetOutBurst() uint64

func (*InfoResponse_BandwidthStat) GetOutRate 

func (m *InfoResponse_BandwidthStat) GetOutRate() uint64

func (*InfoResponse_BandwidthStat) ProtoMessage 

func (*InfoResponse_BandwidthStat) ProtoMessage()

func (*InfoResponse_BandwidthStat) Reset 

func (m *InfoResponse_BandwidthStat) Reset()

func (*InfoResponse_BandwidthStat) String 

func (m *InfoResponse_BandwidthStat) String() string

type InfoResponse_CpuStat 

type InfoResponse_CpuStat struct {
	Usage            *uint64 `protobuf:"varint,1,opt,name=usage" json:"usage,omitempty"`
	User             *uint64 `protobuf:"varint,2,opt,name=user" json:"user,omitempty"`
	System           *uint64 `protobuf:"varint,3,opt,name=system" json:"system,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*InfoResponse_CpuStat) GetSystem 

func (m *InfoResponse_CpuStat) GetSystem() uint64

func (*InfoResponse_CpuStat) GetUsage 

func (m *InfoResponse_CpuStat) GetUsage() uint64

func (*InfoResponse_CpuStat) GetUser 

func (m *InfoResponse_CpuStat) GetUser() uint64

func (*InfoResponse_CpuStat) ProtoMessage 

func (*InfoResponse_CpuStat) ProtoMessage()

func (*InfoResponse_CpuStat) Reset 

func (m *InfoResponse_CpuStat) Reset()

func (*InfoResponse_CpuStat) String 

func (m *InfoResponse_CpuStat) String() string

type InfoResponse_DiskStat 

type InfoResponse_DiskStat struct {
	BytesUsed        *uint64 `protobuf:"varint,1,opt,name=bytes_used" json:"bytes_used,omitempty"`
	InodesUsed       *uint64 `protobuf:"varint,2,opt,name=inodes_used" json:"inodes_used,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*InfoResponse_DiskStat) GetBytesUsed 

func (m *InfoResponse_DiskStat) GetBytesUsed() uint64

func (*InfoResponse_DiskStat) GetInodesUsed 

func (m *InfoResponse_DiskStat) GetInodesUsed() uint64

func (*InfoResponse_DiskStat) ProtoMessage 

func (*InfoResponse_DiskStat) ProtoMessage()

func (*InfoResponse_DiskStat) Reset 

func (m *InfoResponse_DiskStat) Reset()

func (*InfoResponse_DiskStat) String 

func (m *InfoResponse_DiskStat) String() string

type InfoResponse_MemoryStat 

type InfoResponse_MemoryStat struct {
	Cache                   *uint64 `protobuf:"varint,1,opt,name=cache" json:"cache,omitempty"`
	Rss                     *uint64 `protobuf:"varint,2,opt,name=rss" json:"rss,omitempty"`
	MappedFile              *uint64 `protobuf:"varint,3,opt,name=mapped_file" json:"mapped_file,omitempty"`
	Pgpgin                  *uint64 `protobuf:"varint,4,opt,name=pgpgin" json:"pgpgin,omitempty"`
	Pgpgout                 *uint64 `protobuf:"varint,5,opt,name=pgpgout" json:"pgpgout,omitempty"`
	Swap                    *uint64 `protobuf:"varint,6,opt,name=swap" json:"swap,omitempty"`
	Pgfault                 *uint64 `protobuf:"varint,7,opt,name=pgfault" json:"pgfault,omitempty"`
	Pgmajfault              *uint64 `protobuf:"varint,8,opt,name=pgmajfault" json:"pgmajfault,omitempty"`
	InactiveAnon            *uint64 `protobuf:"varint,9,opt,name=inactive_anon" json:"inactive_anon,omitempty"`
	ActiveAnon              *uint64 `protobuf:"varint,10,opt,name=active_anon" json:"active_anon,omitempty"`
	InactiveFile            *uint64 `protobuf:"varint,11,opt,name=inactive_file" json:"inactive_file,omitempty"`
	ActiveFile              *uint64 `protobuf:"varint,12,opt,name=active_file" json:"active_file,omitempty"`
	Unevictable             *uint64 `protobuf:"varint,13,opt,name=unevictable" json:"unevictable,omitempty"`
	HierarchicalMemoryLimit *uint64 `protobuf:"varint,14,opt,name=hierarchical_memory_limit" json:"hierarchical_memory_limit,omitempty"`
	HierarchicalMemswLimit  *uint64 `protobuf:"varint,15,opt,name=hierarchical_memsw_limit" json:"hierarchical_memsw_limit,omitempty"`
	TotalCache              *uint64 `protobuf:"varint,16,opt,name=total_cache" json:"total_cache,omitempty"`
	TotalRss                *uint64 `protobuf:"varint,17,opt,name=total_rss" json:"total_rss,omitempty"`
	TotalMappedFile         *uint64 `protobuf:"varint,18,opt,name=total_mapped_file" json:"total_mapped_file,omitempty"`
	TotalPgpgin             *uint64 `protobuf:"varint,19,opt,name=total_pgpgin" json:"total_pgpgin,omitempty"`
	TotalPgpgout            *uint64 `protobuf:"varint,20,opt,name=total_pgpgout" json:"total_pgpgout,omitempty"`
	TotalSwap               *uint64 `protobuf:"varint,21,opt,name=total_swap" json:"total_swap,omitempty"`
	TotalPgfault            *uint64 `protobuf:"varint,22,opt,name=total_pgfault" json:"total_pgfault,omitempty"`
	TotalPgmajfault         *uint64 `protobuf:"varint,23,opt,name=total_pgmajfault" json:"total_pgmajfault,omitempty"`
	TotalInactiveAnon       *uint64 `protobuf:"varint,24,opt,name=total_inactive_anon" json:"total_inactive_anon,omitempty"`
	TotalActiveAnon         *uint64 `protobuf:"varint,25,opt,name=total_active_anon" json:"total_active_anon,omitempty"`
	TotalInactiveFile       *uint64 `protobuf:"varint,26,opt,name=total_inactive_file" json:"total_inactive_file,omitempty"`
	TotalActiveFile         *uint64 `protobuf:"varint,27,opt,name=total_active_file" json:"total_active_file,omitempty"`
	TotalUnevictable        *uint64 `protobuf:"varint,28,opt,name=total_unevictable" json:"total_unevictable,omitempty"`
	XXX_unrecognized        []byte  `json:"-"`
}

func (*InfoResponse_MemoryStat) GetActiveAnon 

func (m *InfoResponse_MemoryStat) GetActiveAnon() uint64

func (*InfoResponse_MemoryStat) GetActiveFile 

func (m *InfoResponse_MemoryStat) GetActiveFile() uint64

func (*InfoResponse_MemoryStat) GetCache 

func (m *InfoResponse_MemoryStat) GetCache() uint64

func (*InfoResponse_MemoryStat) GetHierarchicalMemoryLimit 

func (m *InfoResponse_MemoryStat) GetHierarchicalMemoryLimit() uint64

func (*InfoResponse_MemoryStat) GetHierarchicalMemswLimit 

func (m *InfoResponse_MemoryStat) GetHierarchicalMemswLimit() uint64

func (*InfoResponse_MemoryStat) GetInactiveAnon 

func (m *InfoResponse_MemoryStat) GetInactiveAnon() uint64

func (*InfoResponse_MemoryStat) GetInactiveFile 

func (m *InfoResponse_MemoryStat) GetInactiveFile() uint64

func (*InfoResponse_MemoryStat) GetMappedFile 

func (m *InfoResponse_MemoryStat) GetMappedFile() uint64

func (*InfoResponse_MemoryStat) GetPgfault 

func (m *InfoResponse_MemoryStat) GetPgfault() uint64

func (*InfoResponse_MemoryStat) GetPgmajfault 

func (m *InfoResponse_MemoryStat) GetPgmajfault() uint64

func (*InfoResponse_MemoryStat) GetPgpgin 

func (m *InfoResponse_MemoryStat) GetPgpgin() uint64

func (*InfoResponse_MemoryStat) GetPgpgout 

func (m *InfoResponse_MemoryStat) GetPgpgout() uint64

func (*InfoResponse_MemoryStat) GetRss 

func (m *InfoResponse_MemoryStat) GetRss() uint64

func (*InfoResponse_MemoryStat) GetSwap 

func (m *InfoResponse_MemoryStat) GetSwap() uint64

func (*InfoResponse_MemoryStat) GetTotalActiveAnon 

func (m *InfoResponse_MemoryStat) GetTotalActiveAnon() uint64

func (*InfoResponse_MemoryStat) GetTotalActiveFile 

func (m *InfoResponse_MemoryStat) GetTotalActiveFile() uint64

func (*InfoResponse_MemoryStat) GetTotalCache 

func (m *InfoResponse_MemoryStat) GetTotalCache() uint64

func (*InfoResponse_MemoryStat) GetTotalInactiveAnon 

func (m *InfoResponse_MemoryStat) GetTotalInactiveAnon() uint64

func (*InfoResponse_MemoryStat) GetTotalInactiveFile 

func (m *InfoResponse_MemoryStat) GetTotalInactiveFile() uint64

func (*InfoResponse_MemoryStat) GetTotalMappedFile 

func (m *InfoResponse_MemoryStat) GetTotalMappedFile() uint64

func (*InfoResponse_MemoryStat) GetTotalPgfault 

func (m *InfoResponse_MemoryStat) GetTotalPgfault() uint64

func (*InfoResponse_MemoryStat) GetTotalPgmajfault 

func (m *InfoResponse_MemoryStat) GetTotalPgmajfault() uint64

func (*InfoResponse_MemoryStat) GetTotalPgpgin 

func (m *InfoResponse_MemoryStat) GetTotalPgpgin() uint64

func (*InfoResponse_MemoryStat) GetTotalPgpgout 

func (m *InfoResponse_MemoryStat) GetTotalPgpgout() uint64

func (*InfoResponse_MemoryStat) GetTotalRss 

func (m *InfoResponse_MemoryStat) GetTotalRss() uint64

func (*InfoResponse_MemoryStat) GetTotalSwap 

func (m *InfoResponse_MemoryStat) GetTotalSwap() uint64

func (*InfoResponse_MemoryStat) GetTotalUnevictable 

func (m *InfoResponse_MemoryStat) GetTotalUnevictable() uint64

func (*InfoResponse_MemoryStat) GetUnevictable 

func (m *InfoResponse_MemoryStat) GetUnevictable() uint64

func (*InfoResponse_MemoryStat) ProtoMessage 

func (*InfoResponse_MemoryStat) ProtoMessage()

func (*InfoResponse_MemoryStat) Reset 

func (m *InfoResponse_MemoryStat) Reset()

func (*InfoResponse_MemoryStat) String 

func (m *InfoResponse_MemoryStat) String() string

type LimitBandwidthRequest 

type LimitBandwidthRequest struct {
	Handle           *string `protobuf:"bytes,1,req,name=handle" json:"handle,omitempty"`
	Rate             *uint64 `protobuf:"varint,2,req,name=rate" json:"rate,omitempty"`
	Burst            *uint64 `protobuf:"varint,3,req,name=burst" json:"burst,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*LimitBandwidthRequest) GetBurst 

func (m *LimitBandwidthRequest) GetBurst() uint64

func (*LimitBandwidthRequest) GetHandle 

func (m *LimitBandwidthRequest) GetHandle() string

func (*LimitBandwidthRequest) GetRate 

func (m *LimitBandwidthRequest) GetRate() uint64

func (*LimitBandwidthRequest) ProtoMessage 

func (*LimitBandwidthRequest) ProtoMessage()

func (*LimitBandwidthRequest) Reset 

func (m *LimitBandwidthRequest) Reset()

func (*LimitBandwidthRequest) String 

func (m *LimitBandwidthRequest) String() string

type LimitBandwidthResponse 

type LimitBandwidthResponse struct {
	Rate             *uint64 `protobuf:"varint,1,req,name=rate" json:"rate,omitempty"`
	Burst            *uint64 `protobuf:"varint,2,req,name=burst" json:"burst,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*LimitBandwidthResponse) GetBurst 

func (m *LimitBandwidthResponse) GetBurst() uint64

func (*LimitBandwidthResponse) GetRate 

func (m *LimitBandwidthResponse) GetRate() uint64

func (*LimitBandwidthResponse) ProtoMessage 

func (*LimitBandwidthResponse) ProtoMessage()

func (*LimitBandwidthResponse) Reset 

func (m *LimitBandwidthResponse) Reset()

func (*LimitBandwidthResponse) String 

func (m *LimitBandwidthResponse) String() string

type LimitDiskRequest 

type LimitDiskRequest struct {
	Handle           *string `protobuf:"bytes,1,req,name=handle" json:"handle,omitempty"`
	BlockLimit       *uint64 `protobuf:"varint,10,opt,name=block_limit" json:"block_limit,omitempty"`
	Block            *uint64 `protobuf:"varint,11,opt,name=block" json:"block,omitempty"`
	BlockSoft        *uint64 `protobuf:"varint,12,opt,name=block_soft" json:"block_soft,omitempty"`
	BlockHard        *uint64 `protobuf:"varint,13,opt,name=block_hard" json:"block_hard,omitempty"`
	InodeLimit       *uint64 `protobuf:"varint,20,opt,name=inode_limit" json:"inode_limit,omitempty"`
	Inode            *uint64 `protobuf:"varint,21,opt,name=inode" json:"inode,omitempty"`
	InodeSoft        *uint64 `protobuf:"varint,22,opt,name=inode_soft" json:"inode_soft,omitempty"`
	InodeHard        *uint64 `protobuf:"varint,23,opt,name=inode_hard" json:"inode_hard,omitempty"`
	ByteLimit        *uint64 `protobuf:"varint,30,opt,name=byte_limit" json:"byte_limit,omitempty"`
	Byte             *uint64 `protobuf:"varint,31,opt,name=byte" json:"byte,omitempty"`
	ByteSoft         *uint64 `protobuf:"varint,32,opt,name=byte_soft" json:"byte_soft,omitempty"`
	ByteHard         *uint64 `protobuf:"varint,33,opt,name=byte_hard" json:"byte_hard,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*LimitDiskRequest) GetBlock 

func (m *LimitDiskRequest) GetBlock() uint64

func (*LimitDiskRequest) GetBlockHard 

func (m *LimitDiskRequest) GetBlockHard() uint64

func (*LimitDiskRequest) GetBlockLimit 

func (m *LimitDiskRequest) GetBlockLimit() uint64

func (*LimitDiskRequest) GetBlockSoft 

func (m *LimitDiskRequest) GetBlockSoft() uint64

func (*LimitDiskRequest) GetByte 

func (m *LimitDiskRequest) GetByte() uint64

func (*LimitDiskRequest) GetByteHard 

func (m *LimitDiskRequest) GetByteHard() uint64

func (*LimitDiskRequest) GetByteLimit 

func (m *LimitDiskRequest) GetByteLimit() uint64

func (*LimitDiskRequest) GetByteSoft 

func (m *LimitDiskRequest) GetByteSoft() uint64

func (*LimitDiskRequest) GetHandle 

func (m *LimitDiskRequest) GetHandle() string

func (*LimitDiskRequest) GetInode 

func (m *LimitDiskRequest) GetInode() uint64

func (*LimitDiskRequest) GetInodeHard 

func (m *LimitDiskRequest) GetInodeHard() uint64

func (*LimitDiskRequest) GetInodeLimit 

func (m *LimitDiskRequest) GetInodeLimit() uint64

func (*LimitDiskRequest) GetInodeSoft 

func (m *LimitDiskRequest) GetInodeSoft() uint64

func (*LimitDiskRequest) ProtoMessage 

func (*LimitDiskRequest) ProtoMessage()

func (*LimitDiskRequest) Reset 

func (m *LimitDiskRequest) Reset()

func (*LimitDiskRequest) String 

func (m *LimitDiskRequest) String() string

type LimitDiskResponse 

type LimitDiskResponse struct {
	BlockLimit       *uint64 `protobuf:"varint,10,opt,name=block_limit" json:"block_limit,omitempty"`
	Block            *uint64 `protobuf:"varint,11,opt,name=block" json:"block,omitempty"`
	BlockSoft        *uint64 `protobuf:"varint,12,opt,name=block_soft" json:"block_soft,omitempty"`
	BlockHard        *uint64 `protobuf:"varint,13,opt,name=block_hard" json:"block_hard,omitempty"`
	InodeLimit       *uint64 `protobuf:"varint,20,opt,name=inode_limit" json:"inode_limit,omitempty"`
	Inode            *uint64 `protobuf:"varint,21,opt,name=inode" json:"inode,omitempty"`
	InodeSoft        *uint64 `protobuf:"varint,22,opt,name=inode_soft" json:"inode_soft,omitempty"`
	InodeHard        *uint64 `protobuf:"varint,23,opt,name=inode_hard" json:"inode_hard,omitempty"`
	ByteLimit        *uint64 `protobuf:"varint,30,opt,name=byte_limit" json:"byte_limit,omitempty"`
	Byte             *uint64 `protobuf:"varint,31,opt,name=byte" json:"byte,omitempty"`
	ByteSoft         *uint64 `protobuf:"varint,32,opt,name=byte_soft" json:"byte_soft,omitempty"`
	ByteHard         *uint64 `protobuf:"varint,33,opt,name=byte_hard" json:"byte_hard,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*LimitDiskResponse) GetBlock 

func (m *LimitDiskResponse) GetBlock() uint64

func (*LimitDiskResponse) GetBlockHard 

func (m *LimitDiskResponse) GetBlockHard() uint64

func (*LimitDiskResponse) GetBlockLimit 

func (m *LimitDiskResponse) GetBlockLimit() uint64

func (*LimitDiskResponse) GetBlockSoft 

func (m *LimitDiskResponse) GetBlockSoft() uint64

func (*LimitDiskResponse) GetByte 

func (m *LimitDiskResponse) GetByte() uint64

func (*LimitDiskResponse) GetByteHard 

func (m *LimitDiskResponse) GetByteHard() uint64

func (*LimitDiskResponse) GetByteLimit 

func (m *LimitDiskResponse) GetByteLimit() uint64

func (*LimitDiskResponse) GetByteSoft 

func (m *LimitDiskResponse) GetByteSoft() uint64

func (*LimitDiskResponse) GetInode 

func (m *LimitDiskResponse) GetInode() uint64

func (*LimitDiskResponse) GetInodeHard 

func (m *LimitDiskResponse) GetInodeHard() uint64

func (*LimitDiskResponse) GetInodeLimit 

func (m *LimitDiskResponse) GetInodeLimit() uint64

func (*LimitDiskResponse) GetInodeSoft 

func (m *LimitDiskResponse) GetInodeSoft() uint64

func (*LimitDiskResponse) ProtoMessage 

func (*LimitDiskResponse) ProtoMessage()

func (*LimitDiskResponse) Reset 

func (m *LimitDiskResponse) Reset()

func (*LimitDiskResponse) String 

func (m *LimitDiskResponse) String() string

type LimitMemoryRequest 

type LimitMemoryRequest struct {
	Handle           *string `protobuf:"bytes,1,req,name=handle" json:"handle,omitempty"`
	LimitInBytes     *uint64 `protobuf:"varint,2,opt,name=limit_in_bytes" json:"limit_in_bytes,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*LimitMemoryRequest) GetHandle 

func (m *LimitMemoryRequest) GetHandle() string

func (*LimitMemoryRequest) GetLimitInBytes 

func (m *LimitMemoryRequest) GetLimitInBytes() uint64

func (*LimitMemoryRequest) ProtoMessage 

func (*LimitMemoryRequest) ProtoMessage()

func (*LimitMemoryRequest) Reset 

func (m *LimitMemoryRequest) Reset()

func (*LimitMemoryRequest) String 

func (m *LimitMemoryRequest) String() string

type LimitMemoryResponse 

type LimitMemoryResponse struct {
	LimitInBytes     *uint64 `protobuf:"varint,1,opt,name=limit_in_bytes" json:"limit_in_bytes,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*LimitMemoryResponse) GetLimitInBytes 

func (m *LimitMemoryResponse) GetLimitInBytes() uint64

func (*LimitMemoryResponse) ProtoMessage 

func (*LimitMemoryResponse) ProtoMessage()

func (*LimitMemoryResponse) Reset 

func (m *LimitMemoryResponse) Reset()

func (*LimitMemoryResponse) String 

func (m *LimitMemoryResponse) String() string

type LinkRequest 

type LinkRequest struct {
	Handle           *string `protobuf:"bytes,1,req,name=handle" json:"handle,omitempty"`
	JobId            *uint32 `protobuf:"varint,2,req,name=job_id" json:"job_id,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*LinkRequest) GetHandle 

func (m *LinkRequest) GetHandle() string

func (*LinkRequest) GetJobId 

func (m *LinkRequest) GetJobId() uint32

func (*LinkRequest) ProtoMessage 

func (*LinkRequest) ProtoMessage()

func (*LinkRequest) Reset 

func (m *LinkRequest) Reset()

func (*LinkRequest) String 

func (m *LinkRequest) String() string

type LinkResponse 

type LinkResponse struct {
	ExitStatus       *uint32       `protobuf:"varint,1,opt,name=exit_status" json:"exit_status,omitempty"`
	Stdout           *string       `protobuf:"bytes,2,opt,name=stdout" json:"stdout,omitempty"`
	Stderr           *string       `protobuf:"bytes,3,opt,name=stderr" json:"stderr,omitempty"`
	Info             *InfoResponse `protobuf:"bytes,4,opt,name=info" json:"info,omitempty"`
	XXX_unrecognized []byte        `json:"-"`
}

func (*LinkResponse) GetExitStatus 

func (m *LinkResponse) GetExitStatus() uint32

func (*LinkResponse) GetInfo 

func (m *LinkResponse) GetInfo() *InfoResponse

func (*LinkResponse) GetStderr 

func (m *LinkResponse) GetStderr() string

func (*LinkResponse) GetStdout 

func (m *LinkResponse) GetStdout() string

func (*LinkResponse) ProtoMessage 

func (*LinkResponse) ProtoMessage()

func (*LinkResponse) Reset 

func (m *LinkResponse) Reset()

func (*LinkResponse) String 

func (m *LinkResponse) String() string

type ListRequest 

type ListRequest struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*ListRequest) ProtoMessage 

func (*ListRequest) ProtoMessage()

func (*ListRequest) Reset 

func (m *ListRequest) Reset()

func (*ListRequest) String 

func (m *ListRequest) String() string

type ListResponse 

type ListResponse struct {
	Handles          []string `protobuf:"bytes,1,rep,name=handles" json:"handles,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

func (*ListResponse) GetHandles 

func (m *ListResponse) GetHandles() []string

func (*ListResponse) ProtoMessage 

func (*ListResponse) ProtoMessage()

func (*ListResponse) Reset 

func (m *ListResponse) Reset()

func (*ListResponse) String 

func (m *ListResponse) String() string

type Message 

type Message struct {
	Type             *Message_Type `protobuf:"varint,1,req,name=type,enum=warden.Message_Type" json:"type,omitempty"`
	Payload          []byte        `protobuf:"bytes,2,req,name=payload" json:"payload,omitempty"`
	XXX_unrecognized []byte        `json:"-"`
}

func (*Message) GetPayload 

func (m *Message) GetPayload() []byte

func (*Message) GetType 

func (m *Message) GetType() Message_Type

func (*Message) ProtoMessage 

func (*Message) ProtoMessage()

func (*Message) Reset 

func (m *Message) Reset()

func (*Message) String 

func (m *Message) String() string

type Message_Type 

type Message_Type int32
const (
	Message_Error          Message_Type = 1
	Message_Create         Message_Type = 11
	Message_Stop           Message_Type = 12
	Message_Destroy        Message_Type = 13
	Message_Info           Message_Type = 14
	Message_Spawn          Message_Type = 21
	Message_Link           Message_Type = 22
	Message_Run            Message_Type = 23
	Message_Stream         Message_Type = 24
	Message_NetIn          Message_Type = 31
	Message_NetOut         Message_Type = 32
	Message_CopyIn         Message_Type = 41
	Message_CopyOut        Message_Type = 42
	Message_LimitMemory    Message_Type = 51
	Message_LimitDisk      Message_Type = 52
	Message_LimitBandwidth Message_Type = 53
	Message_Ping           Message_Type = 91
	Message_List           Message_Type = 92
	Message_Echo           Message_Type = 93
)

func (Message_Type) Enum 

func (x Message_Type) Enum() *Message_Type

func (Message_Type) MarshalJSON 

func (x Message_Type) MarshalJSON() ([]byte, error)

func (Message_Type) String 

func (x Message_Type) String() string

func (*Message_Type) UnmarshalJSON 

func (x *Message_Type) UnmarshalJSON(data []byte) error

type NetInRequest 

type NetInRequest struct {
	Handle           *string `protobuf:"bytes,1,req,name=handle" json:"handle,omitempty"`
	HostPort         *uint32 `protobuf:"varint,3,opt,name=host_port" json:"host_port,omitempty"`
	ContainerPort    *uint32 `protobuf:"varint,2,opt,name=container_port" json:"container_port,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*NetInRequest) GetContainerPort 

func (m *NetInRequest) GetContainerPort() uint32

func (*NetInRequest) GetHandle 

func (m *NetInRequest) GetHandle() string

func (*NetInRequest) GetHostPort 

func (m *NetInRequest) GetHostPort() uint32

func (*NetInRequest) ProtoMessage 

func (*NetInRequest) ProtoMessage()

func (*NetInRequest) Reset 

func (m *NetInRequest) Reset()

func (*NetInRequest) String 

func (m *NetInRequest) String() string

type NetInResponse 

type NetInResponse struct {
	HostPort         *uint32 `protobuf:"varint,1,req,name=host_port" json:"host_port,omitempty"`
	ContainerPort    *uint32 `protobuf:"varint,2,req,name=container_port" json:"container_port,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*NetInResponse) GetContainerPort 

func (m *NetInResponse) GetContainerPort() uint32

func (*NetInResponse) GetHostPort 

func (m *NetInResponse) GetHostPort() uint32

func (*NetInResponse) ProtoMessage 

func (*NetInResponse) ProtoMessage()

func (*NetInResponse) Reset 

func (m *NetInResponse) Reset()

func (*NetInResponse) String 

func (m *NetInResponse) String() string

type NetOutRequest 

type NetOutRequest struct {
	Handle           *string `protobuf:"bytes,1,req,name=handle" json:"handle,omitempty"`
	Network          *string `protobuf:"bytes,2,opt,name=network" json:"network,omitempty"`
	Port             *uint32 `protobuf:"varint,3,opt,name=port" json:"port,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*NetOutRequest) GetHandle 

func (m *NetOutRequest) GetHandle() string

func (*NetOutRequest) GetNetwork 

func (m *NetOutRequest) GetNetwork() string

func (*NetOutRequest) GetPort 

func (m *NetOutRequest) GetPort() uint32

func (*NetOutRequest) ProtoMessage 

func (*NetOutRequest) ProtoMessage()

func (*NetOutRequest) Reset 

func (m *NetOutRequest) Reset()

func (*NetOutRequest) String 

func (m *NetOutRequest) String() string

type NetOutResponse 

type NetOutResponse struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*NetOutResponse) ProtoMessage 

func (*NetOutResponse) ProtoMessage()

func (*NetOutResponse) Reset 

func (m *NetOutResponse) Reset()

func (*NetOutResponse) String 

func (m *NetOutResponse) String() string

type PingRequest 

type PingRequest struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*PingRequest) ProtoMessage 

func (*PingRequest) ProtoMessage()

func (*PingRequest) Reset 

func (m *PingRequest) Reset()

func (*PingRequest) String 

func (m *PingRequest) String() string

type PingResponse 

type PingResponse struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*PingResponse) ProtoMessage 

func (*PingResponse) ProtoMessage()

func (*PingResponse) Reset 

func (m *PingResponse) Reset()

func (*PingResponse) String 

func (m *PingResponse) String() string

type ResourceLimits 

type ResourceLimits struct {
	As               *uint64 `protobuf:"varint,1,opt,name=as" json:"as,omitempty"`
	Core             *uint64 `protobuf:"varint,2,opt,name=core" json:"core,omitempty"`
	Cpu              *uint64 `protobuf:"varint,3,opt,name=cpu" json:"cpu,omitempty"`
	Data             *uint64 `protobuf:"varint,4,opt,name=data" json:"data,omitempty"`
	Fsize            *uint64 `protobuf:"varint,5,opt,name=fsize" json:"fsize,omitempty"`
	Locks            *uint64 `protobuf:"varint,6,opt,name=locks" json:"locks,omitempty"`
	Memlock          *uint64 `protobuf:"varint,7,opt,name=memlock" json:"memlock,omitempty"`
	Msgqueue         *uint64 `protobuf:"varint,8,opt,name=msgqueue" json:"msgqueue,omitempty"`
	Nice             *uint64 `protobuf:"varint,9,opt,name=nice" json:"nice,omitempty"`
	Nofile           *uint64 `protobuf:"varint,10,opt,name=nofile" json:"nofile,omitempty"`
	Nproc            *uint64 `protobuf:"varint,11,opt,name=nproc" json:"nproc,omitempty"`
	Rss              *uint64 `protobuf:"varint,12,opt,name=rss" json:"rss,omitempty"`
	Rtprio           *uint64 `protobuf:"varint,13,opt,name=rtprio" json:"rtprio,omitempty"`
	Sigpending       *uint64 `protobuf:"varint,14,opt,name=sigpending" json:"sigpending,omitempty"`
	Stack            *uint64 `protobuf:"varint,15,opt,name=stack" json:"stack,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*ResourceLimits) GetAs 

func (m *ResourceLimits) GetAs() uint64

func (*ResourceLimits) GetCore 

func (m *ResourceLimits) GetCore() uint64

func (*ResourceLimits) GetCpu 

func (m *ResourceLimits) GetCpu() uint64

func (*ResourceLimits) GetData 

func (m *ResourceLimits) GetData() uint64

func (*ResourceLimits) GetFsize 

func (m *ResourceLimits) GetFsize() uint64

func (*ResourceLimits) GetLocks 

func (m *ResourceLimits) GetLocks() uint64

func (*ResourceLimits) GetMemlock 

func (m *ResourceLimits) GetMemlock() uint64

func (*ResourceLimits) GetMsgqueue 

func (m *ResourceLimits) GetMsgqueue() uint64

func (*ResourceLimits) GetNice 

func (m *ResourceLimits) GetNice() uint64

func (*ResourceLimits) GetNofile 

func (m *ResourceLimits) GetNofile() uint64

func (*ResourceLimits) GetNproc 

func (m *ResourceLimits) GetNproc() uint64

func (*ResourceLimits) GetRss 

func (m *ResourceLimits) GetRss() uint64

func (*ResourceLimits) GetRtprio 

func (m *ResourceLimits) GetRtprio() uint64

func (*ResourceLimits) GetSigpending 

func (m *ResourceLimits) GetSigpending() uint64

func (*ResourceLimits) GetStack 

func (m *ResourceLimits) GetStack() uint64

func (*ResourceLimits) ProtoMessage 

func (*ResourceLimits) ProtoMessage()

func (*ResourceLimits) Reset 

func (m *ResourceLimits) Reset()

func (*ResourceLimits) String 

func (m *ResourceLimits) String() string

type RunRequest 

type RunRequest struct {
	Handle           *string         `protobuf:"bytes,1,req,name=handle" json:"handle,omitempty"`
	Script           *string         `protobuf:"bytes,2,req,name=script" json:"script,omitempty"`
	Privileged       *bool           `protobuf:"varint,3,opt,name=privileged,def=0" json:"privileged,omitempty"`
	Rlimits          *ResourceLimits `protobuf:"bytes,4,opt,name=rlimits" json:"rlimits,omitempty"`
	XXX_unrecognized []byte          `json:"-"`
}

func (*RunRequest) GetHandle 

func (m *RunRequest) GetHandle() string

func (*RunRequest) GetPrivileged 

func (m *RunRequest) GetPrivileged() bool

func (*RunRequest) GetRlimits 

func (m *RunRequest) GetRlimits() *ResourceLimits

func (*RunRequest) GetScript 

func (m *RunRequest) GetScript() string

func (*RunRequest) ProtoMessage 

func (*RunRequest) ProtoMessage()

func (*RunRequest) Reset 

func (m *RunRequest) Reset()

func (*RunRequest) String 

func (m *RunRequest) String() string

type RunResponse 

type RunResponse struct {
	ExitStatus       *uint32       `protobuf:"varint,1,opt,name=exit_status" json:"exit_status,omitempty"`
	Stdout           *string       `protobuf:"bytes,2,opt,name=stdout" json:"stdout,omitempty"`
	Stderr           *string       `protobuf:"bytes,3,opt,name=stderr" json:"stderr,omitempty"`
	Info             *InfoResponse `protobuf:"bytes,4,opt,name=info" json:"info,omitempty"`
	XXX_unrecognized []byte        `json:"-"`
}

func (*RunResponse) GetExitStatus 

func (m *RunResponse) GetExitStatus() uint32

func (*RunResponse) GetInfo 

func (m *RunResponse) GetInfo() *InfoResponse

func (*RunResponse) GetStderr 

func (m *RunResponse) GetStderr() string

func (*RunResponse) GetStdout 

func (m *RunResponse) GetStdout() string

func (*RunResponse) ProtoMessage 

func (*RunResponse) ProtoMessage()

func (*RunResponse) Reset 

func (m *RunResponse) Reset()

func (*RunResponse) String 

func (m *RunResponse) String() string

type SpawnRequest 

type SpawnRequest struct {
	Handle           *string         `protobuf:"bytes,1,req,name=handle" json:"handle,omitempty"`
	Script           *string         `protobuf:"bytes,2,req,name=script" json:"script,omitempty"`
	Privileged       *bool           `protobuf:"varint,3,opt,name=privileged,def=0" json:"privileged,omitempty"`
	Rlimits          *ResourceLimits `protobuf:"bytes,4,opt,name=rlimits" json:"rlimits,omitempty"`
	XXX_unrecognized []byte          `json:"-"`
}

func (*SpawnRequest) GetHandle 

func (m *SpawnRequest) GetHandle() string

func (*SpawnRequest) GetPrivileged 

func (m *SpawnRequest) GetPrivileged() bool

func (*SpawnRequest) GetRlimits 

func (m *SpawnRequest) GetRlimits() *ResourceLimits

func (*SpawnRequest) GetScript 

func (m *SpawnRequest) GetScript() string

func (*SpawnRequest) ProtoMessage 

func (*SpawnRequest) ProtoMessage()

func (*SpawnRequest) Reset 

func (m *SpawnRequest) Reset()

func (*SpawnRequest) String 

func (m *SpawnRequest) String() string

type SpawnResponse 

type SpawnResponse struct {
	JobId            *uint32 `protobuf:"varint,1,req,name=job_id" json:"job_id,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*SpawnResponse) GetJobId 

func (m *SpawnResponse) GetJobId() uint32

func (*SpawnResponse) ProtoMessage 

func (*SpawnResponse) ProtoMessage()

func (*SpawnResponse) Reset 

func (m *SpawnResponse) Reset()

func (*SpawnResponse) String 

func (m *SpawnResponse) String() string

type StopRequest 

type StopRequest struct {
	Handle           *string `protobuf:"bytes,1,req,name=handle" json:"handle,omitempty"`
	Background       *bool   `protobuf:"varint,10,opt,name=background,def=0" json:"background,omitempty"`
	Kill             *bool   `protobuf:"varint,20,opt,name=kill,def=0" json:"kill,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*StopRequest) GetBackground 

func (m *StopRequest) GetBackground() bool

func (*StopRequest) GetHandle 

func (m *StopRequest) GetHandle() string

func (*StopRequest) GetKill 

func (m *StopRequest) GetKill() bool

func (*StopRequest) ProtoMessage 

func (*StopRequest) ProtoMessage()

func (*StopRequest) Reset 

func (m *StopRequest) Reset()

func (*StopRequest) String 

func (m *StopRequest) String() string

type StopResponse 

type StopResponse struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*StopResponse) ProtoMessage 

func (*StopResponse) ProtoMessage()

func (*StopResponse) Reset 

func (m *StopResponse) Reset()

func (*StopResponse) String 

func (m *StopResponse) String() string

type StreamRequest 

type StreamRequest struct {
	Handle           *string `protobuf:"bytes,1,req,name=handle" json:"handle,omitempty"`
	JobId            *uint32 `protobuf:"varint,2,req,name=job_id" json:"job_id,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*StreamRequest) GetHandle 

func (m *StreamRequest) GetHandle() string

func (*StreamRequest) GetJobId 

func (m *StreamRequest) GetJobId() uint32

func (*StreamRequest) ProtoMessage 

func (*StreamRequest) ProtoMessage()

func (*StreamRequest) Reset 

func (m *StreamRequest) Reset()

func (*StreamRequest) String 

func (m *StreamRequest) String() string

type StreamResponse 

type StreamResponse struct {
	Name             *string       `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
	Data             *string       `protobuf:"bytes,2,opt,name=data" json:"data,omitempty"`
	ExitStatus       *uint32       `protobuf:"varint,3,opt,name=exit_status" json:"exit_status,omitempty"`
	Info             *InfoResponse `protobuf:"bytes,4,opt,name=info" json:"info,omitempty"`
	XXX_unrecognized []byte        `json:"-"`
}

func (*StreamResponse) GetData 

func (m *StreamResponse) GetData() string

func (*StreamResponse) GetExitStatus 

func (m *StreamResponse) GetExitStatus() uint32

func (*StreamResponse) GetInfo 

func (m *StreamResponse) GetInfo() *InfoResponse

func (*StreamResponse) GetName 

func (m *StreamResponse) GetName() string

func (*StreamResponse) ProtoMessage 

func (*StreamResponse) ProtoMessage()

func (*StreamResponse) Reset 

func (m *StreamResponse) Reset()

func (*StreamResponse) String 

func (m *StreamResponse) String() string

type WardenError 

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

func (*WardenError) Error 

func (e *WardenError) Error() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.