Documentation ¶
Index ¶
- Constants
- Variables
- type Client
- func (c *Client) Connect() error
- func (c *Client) CopyIn(handle, src, dst string) (*CopyInResponse, error)
- func (c *Client) Create() (*CreateResponse, error)
- func (c *Client) CreateByRequest(*CreateRequest) (*CreateResponse, error)
- func (c *Client) Destroy(handle string) (*DestroyResponse, error)
- func (c *Client) GetDiskLimit(handle string) (uint64, error)
- func (c *Client) GetMemoryLimit(handle string) (uint64, error)
- func (c *Client) Info(handle string) (*InfoResponse, error)
- func (c *Client) LimitDisk(handle string, limit uint64) (*LimitDiskResponse, error)
- func (c *Client) LimitMemory(handle string, limit uint64) (*LimitMemoryResponse, error)
- func (c *Client) List() (*ListResponse, error)
- func (c *Client) NetIn(handle string) (*NetInResponse, error)
- func (c *Client) Run(handle, script string) (*RunResponse, error)
- func (c *Client) Spawn(handle, script string) (*SpawnResponse, error)
- func (c *Client) Stream(handle string, jobId uint32) (chan *StreamResponse, error)
- type ConnectedWardenClient
- type Connection
- func (c *Connection) Close()
- func (c *Connection) CopyIn(handle, src, dst string) (*CopyInResponse, error)
- func (c *Connection) Create() (*CreateResponse, error)
- func (c *Connection) Destroy(handle string) (*DestroyResponse, error)
- func (c *Connection) GetDiskLimit(handle string) (uint64, error)
- func (c *Connection) GetMemoryLimit(handle string) (uint64, error)
- func (c *Connection) Info(handle string) (*InfoResponse, error)
- func (c *Connection) LimitDisk(handle string, limit uint64) (*LimitDiskResponse, error)
- func (c *Connection) LimitMemory(handle string, limit uint64) (*LimitMemoryResponse, error)
- func (c *Connection) List() (*ListResponse, error)
- func (c *Connection) NetIn(handle string) (*NetInResponse, error)
- func (c *Connection) Run(handle, script string) (*RunResponse, error)
- func (c *Connection) Spawn(handle, script string) (*SpawnResponse, error)
- func (c *Connection) Stream(handle string, jobId uint32) (chan *StreamResponse, error)
- type ConnectionInfo
- type ConnectionProvider
- type CopyInRequest
- type CopyInResponse
- type CopyOutRequest
- type CopyOutResponse
- type CreateRequest
- func (m *CreateRequest) GetBindMounts() []*CreateRequest_BindMount
- func (m *CreateRequest) GetGraceTime() uint32
- func (m *CreateRequest) GetHandle() string
- func (m *CreateRequest) GetNetwork() string
- func (m *CreateRequest) GetRootfs() string
- func (*CreateRequest) ProtoMessage()
- func (m *CreateRequest) Reset()
- func (m *CreateRequest) String() string
- type CreateRequest_BindMount
- func (m *CreateRequest_BindMount) GetDstPath() string
- func (m *CreateRequest_BindMount) GetMode() CreateRequest_BindMount_Mode
- func (m *CreateRequest_BindMount) GetSrcPath() string
- func (*CreateRequest_BindMount) ProtoMessage()
- func (m *CreateRequest_BindMount) Reset()
- func (m *CreateRequest_BindMount) String() string
- type CreateRequest_BindMount_Mode
- type CreateResponse
- type DestroyRequest
- type DestroyResponse
- type EchoRequest
- type EchoResponse
- type ErrorResponse
- type InfoRequest
- type InfoResponse
- func (m *InfoResponse) GetBandwidthStat() *InfoResponse_BandwidthStat
- func (m *InfoResponse) GetContainerIp() string
- func (m *InfoResponse) GetContainerPath() string
- func (m *InfoResponse) GetCpuStat() *InfoResponse_CpuStat
- func (m *InfoResponse) GetDiskStat() *InfoResponse_DiskStat
- func (m *InfoResponse) GetEvents() []string
- func (m *InfoResponse) GetHostIp() string
- func (m *InfoResponse) GetJobIds() []uint64
- func (m *InfoResponse) GetMemoryStat() *InfoResponse_MemoryStat
- func (m *InfoResponse) GetState() string
- func (*InfoResponse) ProtoMessage()
- func (m *InfoResponse) Reset()
- func (m *InfoResponse) String() string
- type InfoResponse_BandwidthStat
- func (m *InfoResponse_BandwidthStat) GetInBurst() uint64
- func (m *InfoResponse_BandwidthStat) GetInRate() uint64
- func (m *InfoResponse_BandwidthStat) GetOutBurst() uint64
- func (m *InfoResponse_BandwidthStat) GetOutRate() uint64
- func (*InfoResponse_BandwidthStat) ProtoMessage()
- func (m *InfoResponse_BandwidthStat) Reset()
- func (m *InfoResponse_BandwidthStat) String() string
- type InfoResponse_CpuStat
- type InfoResponse_DiskStat
- type InfoResponse_MemoryStat
- func (m *InfoResponse_MemoryStat) GetActiveAnon() uint64
- func (m *InfoResponse_MemoryStat) GetActiveFile() uint64
- func (m *InfoResponse_MemoryStat) GetCache() uint64
- func (m *InfoResponse_MemoryStat) GetHierarchicalMemoryLimit() uint64
- func (m *InfoResponse_MemoryStat) GetHierarchicalMemswLimit() uint64
- func (m *InfoResponse_MemoryStat) GetInactiveAnon() uint64
- func (m *InfoResponse_MemoryStat) GetInactiveFile() uint64
- func (m *InfoResponse_MemoryStat) GetMappedFile() uint64
- func (m *InfoResponse_MemoryStat) GetPgfault() uint64
- func (m *InfoResponse_MemoryStat) GetPgmajfault() uint64
- func (m *InfoResponse_MemoryStat) GetPgpgin() uint64
- func (m *InfoResponse_MemoryStat) GetPgpgout() uint64
- func (m *InfoResponse_MemoryStat) GetRss() uint64
- func (m *InfoResponse_MemoryStat) GetSwap() uint64
- func (m *InfoResponse_MemoryStat) GetTotalActiveAnon() uint64
- func (m *InfoResponse_MemoryStat) GetTotalActiveFile() uint64
- func (m *InfoResponse_MemoryStat) GetTotalCache() uint64
- func (m *InfoResponse_MemoryStat) GetTotalInactiveAnon() uint64
- func (m *InfoResponse_MemoryStat) GetTotalInactiveFile() uint64
- func (m *InfoResponse_MemoryStat) GetTotalMappedFile() uint64
- func (m *InfoResponse_MemoryStat) GetTotalPgfault() uint64
- func (m *InfoResponse_MemoryStat) GetTotalPgmajfault() uint64
- func (m *InfoResponse_MemoryStat) GetTotalPgpgin() uint64
- func (m *InfoResponse_MemoryStat) GetTotalPgpgout() uint64
- func (m *InfoResponse_MemoryStat) GetTotalRss() uint64
- func (m *InfoResponse_MemoryStat) GetTotalSwap() uint64
- func (m *InfoResponse_MemoryStat) GetTotalUnevictable() uint64
- func (m *InfoResponse_MemoryStat) GetUnevictable() uint64
- func (*InfoResponse_MemoryStat) ProtoMessage()
- func (m *InfoResponse_MemoryStat) Reset()
- func (m *InfoResponse_MemoryStat) String() string
- type LimitBandwidthRequest
- type LimitBandwidthResponse
- type LimitDiskRequest
- func (m *LimitDiskRequest) GetBlock() uint64
- func (m *LimitDiskRequest) GetBlockHard() uint64
- func (m *LimitDiskRequest) GetBlockLimit() uint64
- func (m *LimitDiskRequest) GetBlockSoft() uint64
- func (m *LimitDiskRequest) GetByte() uint64
- func (m *LimitDiskRequest) GetByteHard() uint64
- func (m *LimitDiskRequest) GetByteLimit() uint64
- func (m *LimitDiskRequest) GetByteSoft() uint64
- func (m *LimitDiskRequest) GetHandle() string
- func (m *LimitDiskRequest) GetInode() uint64
- func (m *LimitDiskRequest) GetInodeHard() uint64
- func (m *LimitDiskRequest) GetInodeLimit() uint64
- func (m *LimitDiskRequest) GetInodeSoft() uint64
- func (*LimitDiskRequest) ProtoMessage()
- func (m *LimitDiskRequest) Reset()
- func (m *LimitDiskRequest) String() string
- type LimitDiskResponse
- func (m *LimitDiskResponse) GetBlock() uint64
- func (m *LimitDiskResponse) GetBlockHard() uint64
- func (m *LimitDiskResponse) GetBlockLimit() uint64
- func (m *LimitDiskResponse) GetBlockSoft() uint64
- func (m *LimitDiskResponse) GetByte() uint64
- func (m *LimitDiskResponse) GetByteHard() uint64
- func (m *LimitDiskResponse) GetByteLimit() uint64
- func (m *LimitDiskResponse) GetByteSoft() uint64
- func (m *LimitDiskResponse) GetInode() uint64
- func (m *LimitDiskResponse) GetInodeHard() uint64
- func (m *LimitDiskResponse) GetInodeLimit() uint64
- func (m *LimitDiskResponse) GetInodeSoft() uint64
- func (*LimitDiskResponse) ProtoMessage()
- func (m *LimitDiskResponse) Reset()
- func (m *LimitDiskResponse) String() string
- type LimitMemoryRequest
- type LimitMemoryResponse
- type LinkRequest
- type LinkResponse
- type ListRequest
- type ListResponse
- type Message
- type Message_Type
- type NetInRequest
- type NetInResponse
- type NetOutRequest
- type NetOutResponse
- type PingRequest
- type PingResponse
- type ResourceLimits
- func (m *ResourceLimits) GetAs() uint64
- func (m *ResourceLimits) GetCore() uint64
- func (m *ResourceLimits) GetCpu() uint64
- func (m *ResourceLimits) GetData() uint64
- func (m *ResourceLimits) GetFsize() uint64
- func (m *ResourceLimits) GetLocks() uint64
- func (m *ResourceLimits) GetMemlock() uint64
- func (m *ResourceLimits) GetMsgqueue() uint64
- func (m *ResourceLimits) GetNice() uint64
- func (m *ResourceLimits) GetNofile() uint64
- func (m *ResourceLimits) GetNproc() uint64
- func (m *ResourceLimits) GetRss() uint64
- func (m *ResourceLimits) GetRtprio() uint64
- func (m *ResourceLimits) GetSigpending() uint64
- func (m *ResourceLimits) GetStack() uint64
- func (*ResourceLimits) ProtoMessage()
- func (m *ResourceLimits) Reset()
- func (m *ResourceLimits) String() string
- type RunRequest
- type RunResponse
- type SpawnRequest
- type SpawnResponse
- type StopRequest
- type StopResponse
- type StreamRequest
- type StreamResponse
- type WardenError
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) Create ¶
func (c *Client) Create() (*CreateResponse, error)
func (*Client) CreateByRequest ¶
func (c *Client) CreateByRequest(*CreateRequest) (*CreateResponse, 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)
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 (*Message) GetType ¶
func (m *Message) GetType() Message_Type
func (*Message) ProtoMessage ¶
func (*Message) ProtoMessage()
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 ¶
func (*WardenError) Error ¶
func (e *WardenError) Error() string
Source Files ¶
- client.go
- connection.go
- connection_provider.go
- copy_in.pb.go
- copy_out.pb.go
- create.pb.go
- destroy.pb.go
- echo.pb.go
- error.pb.go
- info.pb.go
- limit_bandwidth.pb.go
- limit_disk.pb.go
- limit_memory.pb.go
- link.pb.go
- list.pb.go
- message.pb.go
- net_in.pb.go
- net_out.pb.go
- ping.pb.go
- resource_limits.pb.go
- run.pb.go
- spawn.pb.go
- stop.pb.go
- stream.pb.go
Click to show internal directories.
Click to hide internal directories.