aranyagopb

package
v0.1.4 Latest Latest
Warning

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

 Go to latest Published: Oct 26, 2020 License: Apache-2.0 Imports: 20 Imported by: 23

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthCmdCredential        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowCmdCredential          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupCmdCredential = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthCmdImage        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowCmdImage          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupCmdImage = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthCmdMetrics        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowCmdMetrics          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupCmdMetrics = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthCmdPeripheral        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowCmdPeripheral          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupCmdPeripheral = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthCmdPod        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowCmdPod          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupCmdPod = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthCmdStorage        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowCmdStorage          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupCmdStorage = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthConnectivity        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowConnectivity          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupConnectivity = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthMsgCredential        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowMsgCredential          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupMsgCredential = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthMsgImage        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowMsgImage          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupMsgImage = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthMsgNode        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowMsgNode          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupMsgNode = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthMsgPeripheral        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowMsgPeripheral          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupMsgPeripheral = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthMsgPod        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowMsgPod          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupMsgPod = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthMsgStorage        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowMsgStorage          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupMsgStorage = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthProto        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowProto          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupProto = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var CmdType_name = map[int32]string{
	0:  "CMD_DATA_UPSTREAM",
	5:  "CMD_SESSION_CLOSE",
	6:  "CMD_REJECT",
	10: "CMD_NET",
	11: "CMD_NODE_INFO_GET",
	12: "CMD_EXEC",
	13: "CMD_ATTACH",
	14: "CMD_LOGS",
	15: "CMD_TTY_RESIZE",
	16: "CMD_PORT_FORWARD",
	21: "CMD_METRICS_CONFIG",
	22: "CMD_METRICS_COLLECT",
	31: "CMD_CRED_ENSURE",
	41: "CMD_IMAGE_LIST",
	42: "CMD_IMAGE_ENSURE",
	43: "CMD_IMAGE_DELETE",
	51: "CMD_STORAGE_LIST",
	52: "CMD_STORAGE_ENSURE",
	53: "CMD_STORAGE_DELETE",
	61: "CMD_POD_LIST",
	62: "CMD_POD_ENSURE",
	63: "CMD_POD_DELETE",
	71: "CMD_PERIPHERAL_LIST",
	72: "CMD_PERIPHERAL_ENSURE",
	73: "CMD_PERIPHERAL_DELETE",
	74: "CMD_PERIPHERAL_OPERATE",
	75: "CMD_PERIPHERAL_COLLECT_METRICS",
}
View Source 
var CmdType_value = map[string]int32{
	"CMD_DATA_UPSTREAM":              0,
	"CMD_SESSION_CLOSE":              5,
	"CMD_REJECT":                     6,
	"CMD_NET":                        10,
	"CMD_NODE_INFO_GET":              11,
	"CMD_EXEC":                       12,
	"CMD_ATTACH":                     13,
	"CMD_LOGS":                       14,
	"CMD_TTY_RESIZE":                 15,
	"CMD_PORT_FORWARD":               16,
	"CMD_METRICS_CONFIG":             21,
	"CMD_METRICS_COLLECT":            22,
	"CMD_CRED_ENSURE":                31,
	"CMD_IMAGE_LIST":                 41,
	"CMD_IMAGE_ENSURE":               42,
	"CMD_IMAGE_DELETE":               43,
	"CMD_STORAGE_LIST":               51,
	"CMD_STORAGE_ENSURE":             52,
	"CMD_STORAGE_DELETE":             53,
	"CMD_POD_LIST":                   61,
	"CMD_POD_ENSURE":                 62,
	"CMD_POD_DELETE":                 63,
	"CMD_PERIPHERAL_LIST":            71,
	"CMD_PERIPHERAL_ENSURE":          72,
	"CMD_PERIPHERAL_DELETE":          73,
	"CMD_PERIPHERAL_OPERATE":         74,
	"CMD_PERIPHERAL_COLLECT_METRICS": 75,
}
View Source 
var ContainerSecuritySpec_ProcMountKind_name = map[int32]string{
	0: "PROC_MOUNT_DEFAULT",
	1: "PROC_MOUNT_UNMASKED",
}
View Source 
var ContainerSecuritySpec_ProcMountKind_value = map[string]int32{
	"PROC_MOUNT_DEFAULT":  0,
	"PROC_MOUNT_UNMASKED": 1,
}
View Source 
var (
	EmptyCmdSize int
)
View Source 
var (
	EmptyMsgSize int
)
View Source 
var ErrorMsg_Kind_name = map[int32]string{
	0: "ERR_COMMON",
	1: "ERR_NOT_FOUND",
	2: "ERR_ALREADY_EXISTS",
	3: "ERR_NOT_SUPPORTED",
	4: "ERR_TIMEOUT",
}
View Source 
var ErrorMsg_Kind_value = map[string]int32{
	"ERR_COMMON":         0,
	"ERR_NOT_FOUND":      1,
	"ERR_ALREADY_EXISTS": 2,
	"ERR_NOT_SUPPORTED":  3,
	"ERR_TIMEOUT":        4,
}
View Source 
var ImagePullPolicy_name = map[int32]string{
	0: "IMAGE_PULL_ALWAYS",
	1: "IMAGE_PULL_IF_NOT_PRESENT",
	2: "IMAGE_PULL_NEVER",
}
View Source 
var ImagePullPolicy_value = map[string]int32{
	"IMAGE_PULL_ALWAYS":         0,
	"IMAGE_PULL_IF_NOT_PRESENT": 1,
	"IMAGE_PULL_NEVER":          2,
}
View Source 
var MetricsTarget_name = map[int32]string{
	0: "METRICS_TARGET_NODE",
	1: "METRICS_TARGET_CONTAINER",
}
View Source 
var MetricsTarget_value = map[string]int32{
	"METRICS_TARGET_NODE":      0,
	"METRICS_TARGET_CONTAINER": 1,
}
View Source 
var MsgType_name = map[int32]string{
	0: "MSG_DATA",

	1:  "MSG_DATA_STDERR",
	5:  "MSG_DONE",
	6:  "MSG_STATE",
	7:  "MSG_ERROR",
	10: "MSG_NET",
	11: "MSG_NODE_STATUS",
	31: "MSG_CRED_STATUS",
	41: "MSG_IMAGE_STATUS",
	42: "MSG_IMAGE_STATUS_LIST",
	51: "MSG_STORAGE_STATUS",
	52: "MSG_STORAGE_STATUS_LIST",
	61: "MSG_POD_STATUS",
	62: "MSG_POD_STATUS_LIST",
	71: "MSG_PERIPHERAL_STATUS",
	72: "MSG_PERIPHERAL_STATUS_LIST",
	73: "MSG_PERIPHERAL_OPERATION_RESULT",
}
View Source 
var MsgType_value = map[string]int32{
	"MSG_DATA":                        0,
	"MSG_DATA_DEFAULT":                0,
	"MSG_DATA_STDOUT":                 0,
	"MSG_DATA_METRICS":                0,
	"MSG_DATA_STDERR":                 1,
	"MSG_DONE":                        5,
	"MSG_STATE":                       6,
	"MSG_ERROR":                       7,
	"MSG_NET":                         10,
	"MSG_NODE_STATUS":                 11,
	"MSG_CRED_STATUS":                 31,
	"MSG_IMAGE_STATUS":                41,
	"MSG_IMAGE_STATUS_LIST":           42,
	"MSG_STORAGE_STATUS":              51,
	"MSG_STORAGE_STATUS_LIST":         52,
	"MSG_POD_STATUS":                  61,
	"MSG_POD_STATUS_LIST":             62,
	"MSG_PERIPHERAL_STATUS":           71,
	"MSG_PERIPHERAL_STATUS_LIST":      72,
	"MSG_PERIPHERAL_OPERATION_RESULT": 73,
}
View Source 
var NodeCondition_name = map[int32]string{
	0: "NODE_CONDITION_UNKNOWN",
	1: "NODE_CONDITION_HEALTHY",
	2: "NODE_CONDITION_UNHEALTHY",
}
View Source 
var NodeCondition_value = map[string]int32{
	"NODE_CONDITION_UNKNOWN":   0,
	"NODE_CONDITION_HEALTHY":   1,
	"NODE_CONDITION_UNHEALTHY": 2,
}
View Source 
var NodeExtInfo_Operator_name = map[int32]string{
	0: "NODE_EXT_INFO_OPERATOR_SET",
	1: "NODE_EXT_INFO_OPERATOR_ADD",
	2: "NODE_EXT_INFO_OPERATOR_MINUS",
}
View Source 
var NodeExtInfo_Operator_value = map[string]int32{
	"NODE_EXT_INFO_OPERATOR_SET":   0,
	"NODE_EXT_INFO_OPERATOR_ADD":   1,
	"NODE_EXT_INFO_OPERATOR_MINUS": 2,
}
View Source 
var NodeExtInfo_Target_name = map[int32]string{
	0: "NODE_EXT_INFO_TARGET_ANNOTATION",
	1: "NODE_EXT_INFO_TARGET_LABEL",
}
View Source 
var NodeExtInfo_Target_value = map[string]int32{
	"NODE_EXT_INFO_TARGET_ANNOTATION": 0,
	"NODE_EXT_INFO_TARGET_LABEL":      1,
}
View Source 
var NodeExtInfo_ValueType_name = map[int32]string{
	0: "NODE_EXT_INFO_TYPE_STRING",
	1: "NODE_EXT_INFO_TYPE_INTEGER",
	2: "NODE_EXT_INFO_TYPE_FLOAT",
}
View Source 
var NodeExtInfo_ValueType_value = map[string]int32{
	"NODE_EXT_INFO_TYPE_STRING":  0,
	"NODE_EXT_INFO_TYPE_INTEGER": 1,
	"NODE_EXT_INFO_TYPE_FLOAT":   2,
}
View Source 
var NodeInfoGetCmd_Kind_name = map[int32]string{
	0: "NODE_INFO_DYN",
	1: "NODE_INFO_ALL",
}
View Source 
var NodeInfoGetCmd_Kind_value = map[string]int32{
	"NODE_INFO_DYN": 0,
	"NODE_INFO_ALL": 1,
}
View Source 
var PeripheralMetric_ReportMethod_name = map[int32]string{
	0: "REPORT_WITH_NODE_METRICS",
	1: "REPORT_WITH_ARHAT_CONNECTIVITY",
	2: "REPORT_WITH_STANDALONE_CLIENT",
}
View Source 
var PeripheralMetric_ReportMethod_value = map[string]int32{
	"REPORT_WITH_NODE_METRICS":       0,
	"REPORT_WITH_ARHAT_CONNECTIVITY": 1,
	"REPORT_WITH_STANDALONE_CLIENT":  2,
}
View Source 
var PeripheralMetric_ValueType_name = map[int32]string{
	0: "METRICS_VALUE_TYPE_UNTYPED",
	1: "METRICS_VALUE_TYPE_COUNTER",
	2: "METRICS_VALUE_TYPE_GAUGE",
}
View Source 
var PeripheralMetric_ValueType_value = map[string]int32{
	"METRICS_VALUE_TYPE_UNTYPED": 0,
	"METRICS_VALUE_TYPE_COUNTER": 1,
	"METRICS_VALUE_TYPE_GAUGE":   2,
}
View Source 
var PeripheralState_name = map[int32]string{
	0: "PERIPHERAL_STATE_UNKNOWN",
	1: "PERIPHERAL_STATE_CREATED",
	2: "PERIPHERAL_STATE_CONNECTED",
	3: "PERIPHERAL_STATE_ERRORED",
	4: "PERIPHERAL_STATE_REMOVED",
}
View Source 
var PeripheralState_value = map[string]int32{
	"PERIPHERAL_STATE_UNKNOWN":   0,
	"PERIPHERAL_STATE_CREATED":   1,
	"PERIPHERAL_STATE_CONNECTED": 2,
	"PERIPHERAL_STATE_ERRORED":   3,
	"PERIPHERAL_STATE_REMOVED":   4,
}
View Source 
var PeripheralType_name = map[int32]string{
	0: "_INVALID_PERIPHERAL_TYPE",
	1: "PERIPHERAL_TYPE_NORMAL",
	2: "PERIPHERAL_TYPE_METRICS_REPORTER",
}
View Source 
var PeripheralType_value = map[string]int32{
	"_INVALID_PERIPHERAL_TYPE":         0,
	"PERIPHERAL_TYPE_NORMAL":           1,
	"PERIPHERAL_TYPE_METRICS_REPORTER": 2,
}
View Source 
var PodState_name = map[int32]string{
	0: "POD_STATE_UNKNOWN",
	1: "POD_STATE_PENDING",
	2: "POD_STATE_RUNNING",
	3: "POD_STATE_SUCCEEDED",
	4: "POD_STATE_FAILED",
}
View Source 
var PodState_value = map[string]int32{
	"POD_STATE_UNKNOWN":   0,
	"POD_STATE_PENDING":   1,
	"POD_STATE_RUNNING":   2,
	"POD_STATE_SUCCEEDED": 3,
	"POD_STATE_FAILED":    4,
}
View Source 
var RejectionReason_name = map[int32]string{
	0: "_INVALID_REJECTION_REASON",
	1: "REJECTION_INVALID_PROTO",
	2: "REJECTION_ALREADY_CONNECTED",
	3: "REJECTION_INITIAL_CHECK_FAILURE",
	4: "REJECTION_INTERNAL_SERVER_ERROR",
}
View Source 
var RejectionReason_value = map[string]int32{
	"_INVALID_REJECTION_REASON":       0,
	"REJECTION_INVALID_PROTO":         1,
	"REJECTION_ALREADY_CONNECTED":     2,
	"REJECTION_INITIAL_CHECK_FAILURE": 3,
	"REJECTION_INTERNAL_SERVER_ERROR": 4,
}
View Source 
var RestartPolicy_name = map[int32]string{
	0: "RESTART_ALWAYS",
	1: "RESTART_ON_FAILURE",
	2: "RESTART_NEVER",
}
View Source 
var RestartPolicy_value = map[string]int32{
	"RESTART_ALWAYS":     0,
	"RESTART_ON_FAILURE": 1,
	"RESTART_NEVER":      2,
}
View Source 
var StateMsg_Kind_name = map[int32]string{
	0: "_INVALID_STATE",
	1: "STATE_ONLINE",
	2: "STATE_OFFLINE",
}
View Source 
var StateMsg_Kind_value = map[string]int32{
	"_INVALID_STATE": 0,
	"STATE_ONLINE":   1,
	"STATE_OFFLINE":  2,
}
View Source 
var StorageState_name = map[int32]string{
	0: "STORAGE_STATE_UNKONW",
	1: "STORAGE_STATE_UNMOUNTED",
	2: "STORAGE_STATE_MOUNTED",
}
View Source 
var StorageState_value = map[string]int32{
	"STORAGE_STATE_UNKONW":    0,
	"STORAGE_STATE_UNMOUNTED": 1,
	"STORAGE_STATE_MOUNTED":   2,
}

Functions

func RegisterEdgeDeviceServer 

func RegisterEdgeDeviceServer(s *grpc.Server, srv EdgeDeviceServer)

Types

type Cmd 

type Cmd struct {
	Kind CmdType `protobuf:"varint,1,opt,name=kind,proto3,enum=aranya.CmdType" json:"kind,omitempty"`
	// session id
	Sid uint64 `protobuf:"varint,2,opt,name=sid,proto3" json:"sid,omitempty"`
	// sequence in the session, to ensure ordered data
	Seq uint64 `protobuf:"varint,3,opt,name=seq,proto3" json:"seq,omitempty"`
	// mark this Cmd is the last piece in the session
	Completed bool `protobuf:"varint,4,opt,name=completed,proto3" json:"completed,omitempty"`
	// body of encoded XxxCmd or raw data bytes
	Body []byte `protobuf:"bytes,11,opt,name=body,proto3" json:"body,omitempty"`
}

func NewCmd 

func NewCmd(kind CmdType, sid, seq uint64, completed bool, payload []byte) *Cmd

NewCmd to create cmd object to be marshaled and sent to agent

func (*Cmd) Descriptor 

func (*Cmd) Descriptor() ([]byte, []int)

func (*Cmd) Equal 

func (this *Cmd) Equal(that interface{}) bool

func (*Cmd) GetBody 

func (m *Cmd) GetBody() []byte

func (*Cmd) GetCompleted 

func (m *Cmd) GetCompleted() bool

func (*Cmd) GetKind 

func (m *Cmd) GetKind() CmdType

func (*Cmd) GetSeq 

func (m *Cmd) GetSeq() uint64

func (*Cmd) GetSid 

func (m *Cmd) GetSid() uint64

func (*Cmd) GoString 

func (this *Cmd) GoString() string

func (*Cmd) Marshal 

func (m *Cmd) Marshal() (dAtA []byte, err error)

func (*Cmd) MarshalTo 

func (m *Cmd) MarshalTo(dAtA []byte) (int, error)

func (*Cmd) MarshalToSizedBuffer 

func (m *Cmd) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Cmd) ProtoMessage 

func (*Cmd) ProtoMessage()

func (*Cmd) Reset 

func (m *Cmd) Reset()

func (*Cmd) Size 

func (m *Cmd) Size() (n int)

func (*Cmd) String 

func (this *Cmd) String() string

func (*Cmd) Unmarshal 

func (m *Cmd) Unmarshal(dAtA []byte) error

func (*Cmd) XXX_DiscardUnknown 

func (m *Cmd) XXX_DiscardUnknown()

func (*Cmd) XXX_Marshal 

func (m *Cmd) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Cmd) XXX_Merge 

func (m *Cmd) XXX_Merge(src proto.Message)

func (*Cmd) XXX_Size 

func (m *Cmd) XXX_Size() int

func (*Cmd) XXX_Unmarshal 

func (m *Cmd) XXX_Unmarshal(b []byte) error

type CmdType 

type CmdType int32
const (
	// 0-4: raw data related cmd
	CMD_DATA_UPSTREAM CmdType = 0
	CMD_SESSION_CLOSE CmdType = 5
	CMD_REJECT        CmdType = 6
	// network operations, protobuf bytes of abbot proto
	CMD_NET CmdType = 10
	// 11-19: node operations
	CMD_NODE_INFO_GET CmdType = 11
	CMD_EXEC          CmdType = 12
	CMD_ATTACH        CmdType = 13
	CMD_LOGS          CmdType = 14
	CMD_TTY_RESIZE    CmdType = 15
	CMD_PORT_FORWARD  CmdType = 16
	// 21-29: metrics operations
	CMD_METRICS_CONFIG  CmdType = 21
	CMD_METRICS_COLLECT CmdType = 22
	// 31-39: credentials operations
	CMD_CRED_ENSURE CmdType = 31
	// 41-49: container image / application bundle operations
	CMD_IMAGE_LIST   CmdType = 41
	CMD_IMAGE_ENSURE CmdType = 42
	CMD_IMAGE_DELETE CmdType = 43
	// 51-59: storage operations (remote csi)
	CMD_STORAGE_LIST   CmdType = 51
	CMD_STORAGE_ENSURE CmdType = 52
	CMD_STORAGE_DELETE CmdType = 53
	// 61-69: pod container provision
	CMD_POD_LIST   CmdType = 61
	CMD_POD_ENSURE CmdType = 62
	CMD_POD_DELETE CmdType = 63
	// 71-79: peripheral operations
	CMD_PERIPHERAL_LIST            CmdType = 71
	CMD_PERIPHERAL_ENSURE          CmdType = 72
	CMD_PERIPHERAL_DELETE          CmdType = 73
	CMD_PERIPHERAL_OPERATE         CmdType = 74
	CMD_PERIPHERAL_COLLECT_METRICS CmdType = 75
)

func (CmdType) EnumDescriptor 

func (CmdType) EnumDescriptor() ([]byte, []int)

func (CmdType) String 

func (x CmdType) String() string

type Connectivity 

type Connectivity struct {
	// method name of the connectivity
	Method string `protobuf:"bytes,1,opt,name=method,proto3" json:"method,omitempty"`
	// target to connect
	Target string `protobuf:"bytes,2,opt,name=target,proto3" json:"target,omitempty"`
	// parameters used when creating this connectivity
	Params map[string]string `` /* 153-byte string literal not displayed */
	Tls    *TLSConfig        `protobuf:"bytes,4,opt,name=tls,proto3" json:"tls,omitempty"`
}

func (*Connectivity) Descriptor 

func (*Connectivity) Descriptor() ([]byte, []int)

func (*Connectivity) Equal 

func (this *Connectivity) Equal(that interface{}) bool

func (*Connectivity) GetMethod 

func (m *Connectivity) GetMethod() string

func (*Connectivity) GetParams 

func (m *Connectivity) GetParams() map[string]string

func (*Connectivity) GetTarget 

func (m *Connectivity) GetTarget() string

func (*Connectivity) GetTls 

func (m *Connectivity) GetTls() *TLSConfig

func (*Connectivity) GoString 

func (this *Connectivity) GoString() string

func (*Connectivity) Marshal 

func (m *Connectivity) Marshal() (dAtA []byte, err error)

func (*Connectivity) MarshalTo 

func (m *Connectivity) MarshalTo(dAtA []byte) (int, error)

func (*Connectivity) MarshalToSizedBuffer 

func (m *Connectivity) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Connectivity) ProtoMessage 

func (*Connectivity) ProtoMessage()

func (*Connectivity) Reset 

func (m *Connectivity) Reset()

func (*Connectivity) Size 

func (m *Connectivity) Size() (n int)

func (*Connectivity) String 

func (this *Connectivity) String() string

func (*Connectivity) Unmarshal 

func (m *Connectivity) Unmarshal(dAtA []byte) error

func (*Connectivity) XXX_DiscardUnknown 

func (m *Connectivity) XXX_DiscardUnknown()

func (*Connectivity) XXX_Marshal 

func (m *Connectivity) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Connectivity) XXX_Merge 

func (m *Connectivity) XXX_Merge(src proto.Message)

func (*Connectivity) XXX_Size 

func (m *Connectivity) XXX_Size() int

func (*Connectivity) XXX_Unmarshal 

func (m *Connectivity) XXX_Unmarshal(b []byte) error

type ContainerAction 

type ContainerAction struct {
	// Types that are valid to be assigned to Action:
	//	*ContainerAction_Exec_
	//	*ContainerAction_Http
	//	*ContainerAction_Socket_
	Action isContainerAction_Action `protobuf_oneof:"action"`
}

func (*ContainerAction) Descriptor 

func (*ContainerAction) Descriptor() ([]byte, []int)

func (*ContainerAction) Equal 

func (this *ContainerAction) Equal(that interface{}) bool

func (*ContainerAction) GetAction 

func (m *ContainerAction) GetAction() isContainerAction_Action

func (*ContainerAction) GetExec 

func (m *ContainerAction) GetExec() *ContainerAction_Exec

func (*ContainerAction) GetHttp 

func (m *ContainerAction) GetHttp() *ContainerAction_HTTP

func (*ContainerAction) GetSocket 

func (m *ContainerAction) GetSocket() *ContainerAction_Socket

func (*ContainerAction) GoString 

func (this *ContainerAction) GoString() string

func (*ContainerAction) Marshal 

func (m *ContainerAction) Marshal() (dAtA []byte, err error)

func (*ContainerAction) MarshalTo 

func (m *ContainerAction) MarshalTo(dAtA []byte) (int, error)

func (*ContainerAction) MarshalToSizedBuffer 

func (m *ContainerAction) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ContainerAction) ProtoMessage 

func (*ContainerAction) ProtoMessage()

func (*ContainerAction) Reset 

func (m *ContainerAction) Reset()

func (*ContainerAction) Size 

func (m *ContainerAction) Size() (n int)

func (*ContainerAction) String 

func (this *ContainerAction) String() string

func (*ContainerAction) Unmarshal 

func (m *ContainerAction) Unmarshal(dAtA []byte) error

func (*ContainerAction) XXX_DiscardUnknown 

func (m *ContainerAction) XXX_DiscardUnknown()

func (*ContainerAction) XXX_Marshal 

func (m *ContainerAction) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ContainerAction) XXX_Merge 

func (m *ContainerAction) XXX_Merge(src proto.Message)

func (*ContainerAction) XXX_OneofWrappers 

func (*ContainerAction) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*ContainerAction) XXX_Size 

func (m *ContainerAction) XXX_Size() int

func (*ContainerAction) XXX_Unmarshal 

func (m *ContainerAction) XXX_Unmarshal(b []byte) error

type ContainerAction_Exec 

type ContainerAction_Exec struct {
	Command []string `protobuf:"bytes,1,rep,name=command,proto3" json:"command,omitempty"`
}

func (*ContainerAction_Exec) Descriptor 

func (*ContainerAction_Exec) Descriptor() ([]byte, []int)

func (*ContainerAction_Exec) Equal 

func (this *ContainerAction_Exec) Equal(that interface{}) bool

func (*ContainerAction_Exec) GetCommand 

func (m *ContainerAction_Exec) GetCommand() []string

func (*ContainerAction_Exec) GoString 

func (this *ContainerAction_Exec) GoString() string

func (*ContainerAction_Exec) Marshal 

func (m *ContainerAction_Exec) Marshal() (dAtA []byte, err error)

func (*ContainerAction_Exec) MarshalTo 

func (m *ContainerAction_Exec) MarshalTo(dAtA []byte) (int, error)

func (*ContainerAction_Exec) MarshalToSizedBuffer 

func (m *ContainerAction_Exec) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ContainerAction_Exec) ProtoMessage 

func (*ContainerAction_Exec) ProtoMessage()

func (*ContainerAction_Exec) Reset 

func (m *ContainerAction_Exec) Reset()

func (*ContainerAction_Exec) Size 

func (m *ContainerAction_Exec) Size() (n int)

func (*ContainerAction_Exec) String 

func (this *ContainerAction_Exec) String() string

func (*ContainerAction_Exec) Unmarshal 

func (m *ContainerAction_Exec) Unmarshal(dAtA []byte) error

func (*ContainerAction_Exec) XXX_DiscardUnknown 

func (m *ContainerAction_Exec) XXX_DiscardUnknown()

func (*ContainerAction_Exec) XXX_Marshal 

func (m *ContainerAction_Exec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ContainerAction_Exec) XXX_Merge 

func (m *ContainerAction_Exec) XXX_Merge(src proto.Message)

func (*ContainerAction_Exec) XXX_Size 

func (m *ContainerAction_Exec) XXX_Size() int

func (*ContainerAction_Exec) XXX_Unmarshal 

func (m *ContainerAction_Exec) XXX_Unmarshal(b []byte) error

type ContainerAction_Exec_ 

type ContainerAction_Exec_ struct {
	Exec *ContainerAction_Exec `protobuf:"bytes,1,opt,name=exec,proto3,oneof" json:"exec,omitempty"`
}

func (*ContainerAction_Exec_) Equal 

func (this *ContainerAction_Exec_) Equal(that interface{}) bool

func (*ContainerAction_Exec_) GoString 

func (this *ContainerAction_Exec_) GoString() string

func (*ContainerAction_Exec_) MarshalTo 

func (m *ContainerAction_Exec_) MarshalTo(dAtA []byte) (int, error)

func (*ContainerAction_Exec_) MarshalToSizedBuffer 

func (m *ContainerAction_Exec_) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ContainerAction_Exec_) Size 

func (m *ContainerAction_Exec_) Size() (n int)

func (*ContainerAction_Exec_) String 

func (this *ContainerAction_Exec_) String() string

type ContainerAction_HTTP 

type ContainerAction_HTTP struct {
	Method  string          `protobuf:"bytes,1,opt,name=method,proto3" json:"method,omitempty"`
	Url     string          `protobuf:"bytes,2,opt,name=url,proto3" json:"url,omitempty"`
	Headers []*KeyValuePair `protobuf:"bytes,3,rep,name=headers,proto3" json:"headers,omitempty"`
}

func (*ContainerAction_HTTP) Descriptor 

func (*ContainerAction_HTTP) Descriptor() ([]byte, []int)

func (*ContainerAction_HTTP) Equal 

func (this *ContainerAction_HTTP) Equal(that interface{}) bool

func (*ContainerAction_HTTP) GetHeaders 

func (m *ContainerAction_HTTP) GetHeaders() []*KeyValuePair

func (*ContainerAction_HTTP) GetMethod 

func (m *ContainerAction_HTTP) GetMethod() string

func (*ContainerAction_HTTP) GetUrl 

func (m *ContainerAction_HTTP) GetUrl() string

func (*ContainerAction_HTTP) GoString 

func (this *ContainerAction_HTTP) GoString() string

func (*ContainerAction_HTTP) Marshal 

func (m *ContainerAction_HTTP) Marshal() (dAtA []byte, err error)

func (*ContainerAction_HTTP) MarshalTo 

func (m *ContainerAction_HTTP) MarshalTo(dAtA []byte) (int, error)

func (*ContainerAction_HTTP) MarshalToSizedBuffer 

func (m *ContainerAction_HTTP) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ContainerAction_HTTP) ProtoMessage 

func (*ContainerAction_HTTP) ProtoMessage()

func (*ContainerAction_HTTP) Reset 

func (m *ContainerAction_HTTP) Reset()

func (*ContainerAction_HTTP) Size 

func (m *ContainerAction_HTTP) Size() (n int)

func (*ContainerAction_HTTP) String 

func (this *ContainerAction_HTTP) String() string

func (*ContainerAction_HTTP) Unmarshal 

func (m *ContainerAction_HTTP) Unmarshal(dAtA []byte) error

func (*ContainerAction_HTTP) XXX_DiscardUnknown 

func (m *ContainerAction_HTTP) XXX_DiscardUnknown()

func (*ContainerAction_HTTP) XXX_Marshal 

func (m *ContainerAction_HTTP) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ContainerAction_HTTP) XXX_Merge 

func (m *ContainerAction_HTTP) XXX_Merge(src proto.Message)

func (*ContainerAction_HTTP) XXX_Size 

func (m *ContainerAction_HTTP) XXX_Size() int

func (*ContainerAction_HTTP) XXX_Unmarshal 

func (m *ContainerAction_HTTP) XXX_Unmarshal(b []byte) error

type ContainerAction_Http 

type ContainerAction_Http struct {
	Http *ContainerAction_HTTP `protobuf:"bytes,2,opt,name=http,proto3,oneof" json:"http,omitempty"`
}

func (*ContainerAction_Http) Equal 

func (this *ContainerAction_Http) Equal(that interface{}) bool

func (*ContainerAction_Http) GoString 

func (this *ContainerAction_Http) GoString() string

func (*ContainerAction_Http) MarshalTo 

func (m *ContainerAction_Http) MarshalTo(dAtA []byte) (int, error)

func (*ContainerAction_Http) MarshalToSizedBuffer 

func (m *ContainerAction_Http) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ContainerAction_Http) Size 

func (m *ContainerAction_Http) Size() (n int)

func (*ContainerAction_Http) String 

func (this *ContainerAction_Http) String() string

type ContainerAction_Socket 

type ContainerAction_Socket struct {
	Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
}

func (*ContainerAction_Socket) Descriptor 

func (*ContainerAction_Socket) Descriptor() ([]byte, []int)

func (*ContainerAction_Socket) Equal 

func (this *ContainerAction_Socket) Equal(that interface{}) bool

func (*ContainerAction_Socket) GetAddress 

func (m *ContainerAction_Socket) GetAddress() string

func (*ContainerAction_Socket) GoString 

func (this *ContainerAction_Socket) GoString() string

func (*ContainerAction_Socket) Marshal 

func (m *ContainerAction_Socket) Marshal() (dAtA []byte, err error)

func (*ContainerAction_Socket) MarshalTo 

func (m *ContainerAction_Socket) MarshalTo(dAtA []byte) (int, error)

func (*ContainerAction_Socket) MarshalToSizedBuffer 

func (m *ContainerAction_Socket) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ContainerAction_Socket) ProtoMessage 

func (*ContainerAction_Socket) ProtoMessage()

func (*ContainerAction_Socket) Reset 

func (m *ContainerAction_Socket) Reset()

func (*ContainerAction_Socket) Size 

func (m *ContainerAction_Socket) Size() (n int)

func (*ContainerAction_Socket) String 

func (this *ContainerAction_Socket) String() string

func (*ContainerAction_Socket) Unmarshal 

func (m *ContainerAction_Socket) Unmarshal(dAtA []byte) error

func (*ContainerAction_Socket) XXX_DiscardUnknown 

func (m *ContainerAction_Socket) XXX_DiscardUnknown()

func (*ContainerAction_Socket) XXX_Marshal 

func (m *ContainerAction_Socket) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ContainerAction_Socket) XXX_Merge 

func (m *ContainerAction_Socket) XXX_Merge(src proto.Message)

func (*ContainerAction_Socket) XXX_Size 

func (m *ContainerAction_Socket) XXX_Size() int

func (*ContainerAction_Socket) XXX_Unmarshal 

func (m *ContainerAction_Socket) XXX_Unmarshal(b []byte) error

type ContainerAction_Socket_ 

type ContainerAction_Socket_ struct {
	Socket *ContainerAction_Socket `protobuf:"bytes,3,opt,name=socket,proto3,oneof" json:"socket,omitempty"`
}

func (*ContainerAction_Socket_) Equal 

func (this *ContainerAction_Socket_) Equal(that interface{}) bool

func (*ContainerAction_Socket_) GoString 

func (this *ContainerAction_Socket_) GoString() string

func (*ContainerAction_Socket_) MarshalTo 

func (m *ContainerAction_Socket_) MarshalTo(dAtA []byte) (int, error)

func (*ContainerAction_Socket_) MarshalToSizedBuffer 

func (m *ContainerAction_Socket_) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ContainerAction_Socket_) Size 

func (m *ContainerAction_Socket_) Size() (n int)

func (*ContainerAction_Socket_) String 

func (this *ContainerAction_Socket_) String() string

type ContainerMountSpec 

type ContainerMountSpec struct {
	MountPath string `protobuf:"bytes,1,opt,name=mount_path,json=mountPath,proto3" json:"mount_path,omitempty"`
	SubPath   string `protobuf:"bytes,2,opt,name=sub_path,json=subPath,proto3" json:"sub_path,omitempty"`
	ReadOnly  bool   `protobuf:"varint,3,opt,name=read_only,json=readOnly,proto3" json:"read_only,omitempty"`
	// device type
	Type     string   `protobuf:"bytes,4,opt,name=type,proto3" json:"type,omitempty"`
	Options  []string `protobuf:"bytes,5,rep,name=options,proto3" json:"options,omitempty"`
	FileMode uint32   `protobuf:"varint,6,opt,name=file_mode,json=fileMode,proto3" json:"file_mode,omitempty"`
	// mount this volume use cluster CSI
	Remote bool `protobuf:"varint,7,opt,name=remote,proto3" json:"remote,omitempty"`
}

func (*ContainerMountSpec) Descriptor 

func (*ContainerMountSpec) Descriptor() ([]byte, []int)

func (*ContainerMountSpec) Ensure 

func (v *ContainerMountSpec) Ensure(dir string, dataMap map[string][]byte) (mountPath string, err error)

func (*ContainerMountSpec) Equal 

func (this *ContainerMountSpec) Equal(that interface{}) bool

func (*ContainerMountSpec) GetFileMode 

func (m *ContainerMountSpec) GetFileMode() uint32

func (*ContainerMountSpec) GetMountPath 

func (m *ContainerMountSpec) GetMountPath() string

func (*ContainerMountSpec) GetOptions 

func (m *ContainerMountSpec) GetOptions() []string

func (*ContainerMountSpec) GetReadOnly 

func (m *ContainerMountSpec) GetReadOnly() bool

func (*ContainerMountSpec) GetRemote 

func (m *ContainerMountSpec) GetRemote() bool

func (*ContainerMountSpec) GetSubPath 

func (m *ContainerMountSpec) GetSubPath() string

func (*ContainerMountSpec) GetType 

func (m *ContainerMountSpec) GetType() string

func (*ContainerMountSpec) GoString 

func (this *ContainerMountSpec) GoString() string

func (*ContainerMountSpec) Marshal 

func (m *ContainerMountSpec) Marshal() (dAtA []byte, err error)

func (*ContainerMountSpec) MarshalTo 

func (m *ContainerMountSpec) MarshalTo(dAtA []byte) (int, error)

func (*ContainerMountSpec) MarshalToSizedBuffer 

func (m *ContainerMountSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ContainerMountSpec) ProtoMessage 

func (*ContainerMountSpec) ProtoMessage()

func (*ContainerMountSpec) Reset 

func (m *ContainerMountSpec) Reset()

func (*ContainerMountSpec) Size 

func (m *ContainerMountSpec) Size() (n int)

func (*ContainerMountSpec) String 

func (this *ContainerMountSpec) String() string

func (*ContainerMountSpec) Unmarshal 

func (m *ContainerMountSpec) Unmarshal(dAtA []byte) error

func (*ContainerMountSpec) XXX_DiscardUnknown 

func (m *ContainerMountSpec) XXX_DiscardUnknown()

func (*ContainerMountSpec) XXX_Marshal 

func (m *ContainerMountSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ContainerMountSpec) XXX_Merge 

func (m *ContainerMountSpec) XXX_Merge(src proto.Message)

func (*ContainerMountSpec) XXX_Size 

func (m *ContainerMountSpec) XXX_Size() int

func (*ContainerMountSpec) XXX_Unmarshal 

func (m *ContainerMountSpec) XXX_Unmarshal(b []byte) error

type ContainerProbeSpec 

type ContainerProbeSpec struct {
	InitialDelay     int64            `protobuf:"varint,1,opt,name=initial_delay,json=initialDelay,proto3" json:"initial_delay,omitempty"`
	ProbeTimeout     int64            `protobuf:"varint,2,opt,name=probe_timeout,json=probeTimeout,proto3" json:"probe_timeout,omitempty"`
	ProbeInterval    int64            `protobuf:"varint,3,opt,name=probe_interval,json=probeInterval,proto3" json:"probe_interval,omitempty"`
	SuccessThreshold int32            `protobuf:"varint,4,opt,name=success_threshold,json=successThreshold,proto3" json:"success_threshold,omitempty"`
	FailureThreshold int32            `protobuf:"varint,5,opt,name=failure_threshold,json=failureThreshold,proto3" json:"failure_threshold,omitempty"`
	Method           *ContainerAction `protobuf:"bytes,6,opt,name=method,proto3" json:"method,omitempty"`
}

func (*ContainerProbeSpec) Descriptor 

func (*ContainerProbeSpec) Descriptor() ([]byte, []int)

func (*ContainerProbeSpec) Equal 

func (this *ContainerProbeSpec) Equal(that interface{}) bool

func (*ContainerProbeSpec) GetFailureThreshold 

func (m *ContainerProbeSpec) GetFailureThreshold() int32

func (*ContainerProbeSpec) GetInitialDelay 

func (m *ContainerProbeSpec) GetInitialDelay() int64

func (*ContainerProbeSpec) GetMethod 

func (m *ContainerProbeSpec) GetMethod() *ContainerAction

func (*ContainerProbeSpec) GetProbeInterval 

func (m *ContainerProbeSpec) GetProbeInterval() int64

func (*ContainerProbeSpec) GetProbeTimeout 

func (m *ContainerProbeSpec) GetProbeTimeout() int64

func (*ContainerProbeSpec) GetSuccessThreshold 

func (m *ContainerProbeSpec) GetSuccessThreshold() int32

func (*ContainerProbeSpec) GoString 

func (this *ContainerProbeSpec) GoString() string

func (*ContainerProbeSpec) Marshal 

func (m *ContainerProbeSpec) Marshal() (dAtA []byte, err error)

func (*ContainerProbeSpec) MarshalTo 

func (m *ContainerProbeSpec) MarshalTo(dAtA []byte) (int, error)

func (*ContainerProbeSpec) MarshalToSizedBuffer 

func (m *ContainerProbeSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ContainerProbeSpec) ProtoMessage 

func (*ContainerProbeSpec) ProtoMessage()

func (*ContainerProbeSpec) Reset 

func (m *ContainerProbeSpec) Reset()

func (*ContainerProbeSpec) Size 

func (m *ContainerProbeSpec) Size() (n int)

func (*ContainerProbeSpec) String 

func (this *ContainerProbeSpec) String() string

func (*ContainerProbeSpec) Unmarshal 

func (m *ContainerProbeSpec) Unmarshal(dAtA []byte) error

func (*ContainerProbeSpec) XXX_DiscardUnknown 

func (m *ContainerProbeSpec) XXX_DiscardUnknown()

func (*ContainerProbeSpec) XXX_Marshal 

func (m *ContainerProbeSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ContainerProbeSpec) XXX_Merge 

func (m *ContainerProbeSpec) XXX_Merge(src proto.Message)

func (*ContainerProbeSpec) XXX_Size 

func (m *ContainerProbeSpec) XXX_Size() int

func (*ContainerProbeSpec) XXX_Unmarshal 

func (m *ContainerProbeSpec) XXX_Unmarshal(b []byte) error

type ContainerSecuritySpec 

type ContainerSecuritySpec struct {
	Privileged         bool                                `protobuf:"varint,1,opt,name=privileged,proto3" json:"privileged,omitempty"`
	AllowNewPrivileges bool                                `protobuf:"varint,2,opt,name=allow_new_privileges,json=allowNewPrivileges,proto3" json:"allow_new_privileges,omitempty"`
	NonRoot            bool                                `protobuf:"varint,3,opt,name=non_root,json=nonRoot,proto3" json:"non_root,omitempty"`
	ReadOnlyRootfs     bool                                `protobuf:"varint,4,opt,name=read_only_rootfs,json=readOnlyRootfs,proto3" json:"read_only_rootfs,omitempty"`
	User               int64                               `protobuf:"varint,5,opt,name=user,proto3" json:"user,omitempty"`
	Group              int64                               `protobuf:"varint,6,opt,name=group,proto3" json:"group,omitempty"`
	CapsAdd            []string                            `protobuf:"bytes,7,rep,name=caps_add,json=capsAdd,proto3" json:"caps_add,omitempty"`
	CapsDrop           []string                            `protobuf:"bytes,8,rep,name=caps_drop,json=capsDrop,proto3" json:"caps_drop,omitempty"`
	ProcMountKind      ContainerSecuritySpec_ProcMountKind `` /* 151-byte string literal not displayed */
	SelinuxOptions     *SELinuxOptions                     `protobuf:"bytes,10,opt,name=selinux_options,json=selinuxOptions,proto3" json:"selinux_options,omitempty"`
}

func (*ContainerSecuritySpec) Descriptor 

func (*ContainerSecuritySpec) Descriptor() ([]byte, []int)

func (*ContainerSecuritySpec) Equal 

func (this *ContainerSecuritySpec) Equal(that interface{}) bool

func (*ContainerSecuritySpec) GetAllowNewPrivileges 

func (m *ContainerSecuritySpec) GetAllowNewPrivileges() bool

func (*ContainerSecuritySpec) GetCapsAdd 

func (m *ContainerSecuritySpec) GetCapsAdd() []string

func (*ContainerSecuritySpec) GetCapsDrop 

func (m *ContainerSecuritySpec) GetCapsDrop() []string

func (*ContainerSecuritySpec) GetGroup 

func (m *ContainerSecuritySpec) GetGroup() int64

func (*ContainerSecuritySpec) GetNonRoot 

func (m *ContainerSecuritySpec) GetNonRoot() bool

func (*ContainerSecuritySpec) GetPrivileged 

func (m *ContainerSecuritySpec) GetPrivileged() bool

func (*ContainerSecuritySpec) GetProcMountKind 

func (m *ContainerSecuritySpec) GetProcMountKind() ContainerSecuritySpec_ProcMountKind

func (*ContainerSecuritySpec) GetReadOnlyRootfs 

func (m *ContainerSecuritySpec) GetReadOnlyRootfs() bool

func (*ContainerSecuritySpec) GetSelinuxOptions 

func (m *ContainerSecuritySpec) GetSelinuxOptions() *SELinuxOptions

func (*ContainerSecuritySpec) GetUser 

func (m *ContainerSecuritySpec) GetUser() int64

func (*ContainerSecuritySpec) GoString 

func (this *ContainerSecuritySpec) GoString() string

func (*ContainerSecuritySpec) Marshal 

func (m *ContainerSecuritySpec) Marshal() (dAtA []byte, err error)

func (*ContainerSecuritySpec) MarshalTo 

func (m *ContainerSecuritySpec) MarshalTo(dAtA []byte) (int, error)

func (*ContainerSecuritySpec) MarshalToSizedBuffer 

func (m *ContainerSecuritySpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ContainerSecuritySpec) ProtoMessage 

func (*ContainerSecuritySpec) ProtoMessage()

func (*ContainerSecuritySpec) Reset 

func (m *ContainerSecuritySpec) Reset()

func (*ContainerSecuritySpec) Size 

func (m *ContainerSecuritySpec) Size() (n int)

func (*ContainerSecuritySpec) String 

func (this *ContainerSecuritySpec) String() string

func (*ContainerSecuritySpec) Unmarshal 

func (m *ContainerSecuritySpec) Unmarshal(dAtA []byte) error

func (*ContainerSecuritySpec) XXX_DiscardUnknown 

func (m *ContainerSecuritySpec) XXX_DiscardUnknown()

func (*ContainerSecuritySpec) XXX_Marshal 

func (m *ContainerSecuritySpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ContainerSecuritySpec) XXX_Merge 

func (m *ContainerSecuritySpec) XXX_Merge(src proto.Message)

func (*ContainerSecuritySpec) XXX_Size 

func (m *ContainerSecuritySpec) XXX_Size() int

func (*ContainerSecuritySpec) XXX_Unmarshal 

func (m *ContainerSecuritySpec) XXX_Unmarshal(b []byte) error

type ContainerSecuritySpec_ProcMountKind 

type ContainerSecuritySpec_ProcMountKind int32
const (
	PROC_MOUNT_DEFAULT  ContainerSecuritySpec_ProcMountKind = 0
	PROC_MOUNT_UNMASKED ContainerSecuritySpec_ProcMountKind = 1
)

func (ContainerSecuritySpec_ProcMountKind) EnumDescriptor 

func (ContainerSecuritySpec_ProcMountKind) EnumDescriptor() ([]byte, []int)

func (ContainerSecuritySpec_ProcMountKind) String 

func (x ContainerSecuritySpec_ProcMountKind) String() string

type ContainerSpec 

type ContainerSpec struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// container image name to pull
	Image      string `protobuf:"bytes,2,opt,name=image,proto3" json:"image,omitempty"`
	WorkingDir string `protobuf:"bytes,3,opt,name=working_dir,json=workingDir,proto3" json:"working_dir,omitempty"`
	Stdin      bool   `protobuf:"varint,4,opt,name=stdin,proto3" json:"stdin,omitempty"`
	StdinOnce  bool   `protobuf:"varint,5,opt,name=stdin_once,json=stdinOnce,proto3" json:"stdin_once,omitempty"`
	Tty        bool   `protobuf:"varint,6,opt,name=tty,proto3" json:"tty,omitempty"`
	// Command (ENTRYPOINT in Dockerfile)
	Command []string `protobuf:"bytes,7,rep,name=command,proto3" json:"command,omitempty"`
	// Args (CMD in Dockerfile)
	Args []string `protobuf:"bytes,8,rep,name=args,proto3" json:"args,omitempty"`
	// Contaienr environment variables
	//
	// key: env key
	// value: env value
	Envs map[string]string `` /* 149-byte string literal not displayed */
	// Container voulme or device mounts
	//
	// key: volume or device name
	// value: mount options
	Mounts         map[string]*ContainerMountSpec `` /* 154-byte string literal not displayed */
	ReadinessCheck *ContainerProbeSpec            `protobuf:"bytes,11,opt,name=readiness_check,json=readinessCheck,proto3" json:"readiness_check,omitempty"`
	LivenessCheck  *ContainerProbeSpec            `protobuf:"bytes,12,opt,name=liveness_check,json=livenessCheck,proto3" json:"liveness_check,omitempty"`
	//
	// resolved security opts in pod
	//
	Security *ContainerSecuritySpec `protobuf:"bytes,13,opt,name=security,proto3" json:"security,omitempty"`
	//
	// Container hooks
	//
	HookPostStart *ContainerAction `protobuf:"bytes,14,opt,name=hook_post_start,json=hookPostStart,proto3" json:"hook_post_start,omitempty"`
}

func (*ContainerSpec) Descriptor 

func (*ContainerSpec) Descriptor() ([]byte, []int)

func (*ContainerSpec) Equal 

func (this *ContainerSpec) Equal(that interface{}) bool

func (*ContainerSpec) GetArgs 

func (m *ContainerSpec) GetArgs() []string

func (*ContainerSpec) GetCommand 

func (m *ContainerSpec) GetCommand() []string

func (*ContainerSpec) GetEnvs 

func (m *ContainerSpec) GetEnvs() map[string]string

func (*ContainerSpec) GetHookPostStart 

func (m *ContainerSpec) GetHookPostStart() *ContainerAction

func (*ContainerSpec) GetImage 

func (m *ContainerSpec) GetImage() string

func (*ContainerSpec) GetLivenessCheck 

func (m *ContainerSpec) GetLivenessCheck() *ContainerProbeSpec

func (*ContainerSpec) GetMounts 

func (m *ContainerSpec) GetMounts() map[string]*ContainerMountSpec

func (*ContainerSpec) GetName 

func (m *ContainerSpec) GetName() string

func (*ContainerSpec) GetReadinessCheck 

func (m *ContainerSpec) GetReadinessCheck() *ContainerProbeSpec

func (*ContainerSpec) GetSecurity 

func (m *ContainerSpec) GetSecurity() *ContainerSecuritySpec

func (*ContainerSpec) GetStdin 

func (m *ContainerSpec) GetStdin() bool

func (*ContainerSpec) GetStdinOnce 

func (m *ContainerSpec) GetStdinOnce() bool

func (*ContainerSpec) GetTty 

func (m *ContainerSpec) GetTty() bool

func (*ContainerSpec) GetWorkingDir 

func (m *ContainerSpec) GetWorkingDir() string

func (*ContainerSpec) GoString 

func (this *ContainerSpec) GoString() string

func (*ContainerSpec) Marshal 

func (m *ContainerSpec) Marshal() (dAtA []byte, err error)

func (*ContainerSpec) MarshalTo 

func (m *ContainerSpec) MarshalTo(dAtA []byte) (int, error)

func (*ContainerSpec) MarshalToSizedBuffer 

func (m *ContainerSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ContainerSpec) ProtoMessage 

func (*ContainerSpec) ProtoMessage()

func (*ContainerSpec) Reset 

func (m *ContainerSpec) Reset()

func (*ContainerSpec) Size 

func (m *ContainerSpec) Size() (n int)

func (*ContainerSpec) String 

func (this *ContainerSpec) String() string

func (*ContainerSpec) Unmarshal 

func (m *ContainerSpec) Unmarshal(dAtA []byte) error

func (*ContainerSpec) XXX_DiscardUnknown 

func (m *ContainerSpec) XXX_DiscardUnknown()

func (*ContainerSpec) XXX_Marshal 

func (m *ContainerSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ContainerSpec) XXX_Merge 

func (m *ContainerSpec) XXX_Merge(src proto.Message)

func (*ContainerSpec) XXX_Size 

func (m *ContainerSpec) XXX_Size() int

func (*ContainerSpec) XXX_Unmarshal 

func (m *ContainerSpec) XXX_Unmarshal(b []byte) error

type ContainerStatus 

type ContainerStatus struct {
	ContainerId string `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	ImageId     string `protobuf:"bytes,2,opt,name=image_id,json=imageId,proto3" json:"image_id,omitempty"`
	// time values in rfc3339nano format
	CreatedAt    string `protobuf:"bytes,4,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	StartedAt    string `protobuf:"bytes,5,opt,name=started_at,json=startedAt,proto3" json:"started_at,omitempty"`
	FinishedAt   string `protobuf:"bytes,6,opt,name=finished_at,json=finishedAt,proto3" json:"finished_at,omitempty"`
	ExitCode     int32  `protobuf:"varint,7,opt,name=exit_code,json=exitCode,proto3" json:"exit_code,omitempty"`
	RestartCount int32  `protobuf:"varint,8,opt,name=restart_count,json=restartCount,proto3" json:"restart_count,omitempty"`
	Reason       string `protobuf:"bytes,11,opt,name=reason,proto3" json:"reason,omitempty"`
	Message      string `protobuf:"bytes,12,opt,name=message,proto3" json:"message,omitempty"`
}

func (*ContainerStatus) Descriptor 

func (*ContainerStatus) Descriptor() ([]byte, []int)

func (*ContainerStatus) Equal 

func (this *ContainerStatus) Equal(that interface{}) bool

func (*ContainerStatus) GetContainerId 

func (m *ContainerStatus) GetContainerId() string

func (*ContainerStatus) GetCreatedAt 

func (m *ContainerStatus) GetCreatedAt() string

func (*ContainerStatus) GetExitCode 

func (m *ContainerStatus) GetExitCode() int32

func (*ContainerStatus) GetFinishedAt 

func (m *ContainerStatus) GetFinishedAt() string

func (*ContainerStatus) GetImageId 

func (m *ContainerStatus) GetImageId() string

func (*ContainerStatus) GetMessage 

func (m *ContainerStatus) GetMessage() string

func (*ContainerStatus) GetReason 

func (m *ContainerStatus) GetReason() string

func (*ContainerStatus) GetRestartCount 

func (m *ContainerStatus) GetRestartCount() int32

func (*ContainerStatus) GetStartedAt 

func (m *ContainerStatus) GetStartedAt() string

func (*ContainerStatus) GetState 

func (s *ContainerStatus) GetState() PodState

func (*ContainerStatus) GetTimeCreatedAt 

func (s *ContainerStatus) GetTimeCreatedAt() time.Time

func (*ContainerStatus) GetTimeFinishedAt 

func (s *ContainerStatus) GetTimeFinishedAt() time.Time

func (*ContainerStatus) GetTimeStartedAt 

func (s *ContainerStatus) GetTimeStartedAt() time.Time

func (*ContainerStatus) GoString 

func (this *ContainerStatus) GoString() string

func (*ContainerStatus) Marshal 

func (m *ContainerStatus) Marshal() (dAtA []byte, err error)

func (*ContainerStatus) MarshalTo 

func (m *ContainerStatus) MarshalTo(dAtA []byte) (int, error)

func (*ContainerStatus) MarshalToSizedBuffer 

func (m *ContainerStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ContainerStatus) ProtoMessage 

func (*ContainerStatus) ProtoMessage()

func (*ContainerStatus) Reset 

func (m *ContainerStatus) Reset()

func (*ContainerStatus) Size 

func (m *ContainerStatus) Size() (n int)

func (*ContainerStatus) String 

func (this *ContainerStatus) String() string

func (*ContainerStatus) Unmarshal 

func (m *ContainerStatus) Unmarshal(dAtA []byte) error

func (*ContainerStatus) XXX_DiscardUnknown 

func (m *ContainerStatus) XXX_DiscardUnknown()

func (*ContainerStatus) XXX_Marshal 

func (m *ContainerStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ContainerStatus) XXX_Merge 

func (m *ContainerStatus) XXX_Merge(src proto.Message)

func (*ContainerStatus) XXX_Size 

func (m *ContainerStatus) XXX_Size() int

func (*ContainerStatus) XXX_Unmarshal 

func (m *ContainerStatus) XXX_Unmarshal(b []byte) error

type CredentialDeleteCmd 

type CredentialDeleteCmd struct {
}

func (*CredentialDeleteCmd) Descriptor 

func (*CredentialDeleteCmd) Descriptor() ([]byte, []int)

func (*CredentialDeleteCmd) Equal 

func (this *CredentialDeleteCmd) Equal(that interface{}) bool

func (*CredentialDeleteCmd) GoString 

func (this *CredentialDeleteCmd) GoString() string

func (*CredentialDeleteCmd) Marshal 

func (m *CredentialDeleteCmd) Marshal() (dAtA []byte, err error)

func (*CredentialDeleteCmd) MarshalTo 

func (m *CredentialDeleteCmd) MarshalTo(dAtA []byte) (int, error)

func (*CredentialDeleteCmd) MarshalToSizedBuffer 

func (m *CredentialDeleteCmd) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CredentialDeleteCmd) ProtoMessage 

func (*CredentialDeleteCmd) ProtoMessage()

func (*CredentialDeleteCmd) Reset 

func (m *CredentialDeleteCmd) Reset()

func (*CredentialDeleteCmd) Size 

func (m *CredentialDeleteCmd) Size() (n int)

func (*CredentialDeleteCmd) String 

func (this *CredentialDeleteCmd) String() string

func (*CredentialDeleteCmd) Unmarshal 

func (m *CredentialDeleteCmd) Unmarshal(dAtA []byte) error

func (*CredentialDeleteCmd) XXX_DiscardUnknown 

func (m *CredentialDeleteCmd) XXX_DiscardUnknown()

func (*CredentialDeleteCmd) XXX_Marshal 

func (m *CredentialDeleteCmd) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CredentialDeleteCmd) XXX_Merge 

func (m *CredentialDeleteCmd) XXX_Merge(src proto.Message)

func (*CredentialDeleteCmd) XXX_Size 

func (m *CredentialDeleteCmd) XXX_Size() int

func (*CredentialDeleteCmd) XXX_Unmarshal 

func (m *CredentialDeleteCmd) XXX_Unmarshal(b []byte) error

type CredentialEnsureCmd 

type CredentialEnsureCmd struct {
	SshPrivateKey []byte `protobuf:"bytes,1,opt,name=ssh_private_key,json=sshPrivateKey,proto3" json:"ssh_private_key,omitempty"`
}

func NewCredentialEnsureCmd 

func NewCredentialEnsureCmd(sshPrivateKey []byte) *CredentialEnsureCmd

func (*CredentialEnsureCmd) Descriptor 

func (*CredentialEnsureCmd) Descriptor() ([]byte, []int)

func (*CredentialEnsureCmd) Equal 

func (this *CredentialEnsureCmd) Equal(that interface{}) bool

func (*CredentialEnsureCmd) GetSshPrivateKey 

func (m *CredentialEnsureCmd) GetSshPrivateKey() []byte

func (*CredentialEnsureCmd) GoString 

func (this *CredentialEnsureCmd) GoString() string

func (*CredentialEnsureCmd) Marshal 

func (m *CredentialEnsureCmd) Marshal() (dAtA []byte, err error)

func (*CredentialEnsureCmd) MarshalTo 

func (m *CredentialEnsureCmd) MarshalTo(dAtA []byte) (int, error)

func (*CredentialEnsureCmd) MarshalToSizedBuffer 

func (m *CredentialEnsureCmd) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CredentialEnsureCmd) ProtoMessage 

func (*CredentialEnsureCmd) ProtoMessage()

func (*CredentialEnsureCmd) Reset 

func (m *CredentialEnsureCmd) Reset()

func (*CredentialEnsureCmd) Size 

func (m *CredentialEnsureCmd) Size() (n int)

func (*CredentialEnsureCmd) String 

func (this *CredentialEnsureCmd) String() string

func (*CredentialEnsureCmd) Unmarshal 

func (m *CredentialEnsureCmd) Unmarshal(dAtA []byte) error

func (*CredentialEnsureCmd) XXX_DiscardUnknown 

func (m *CredentialEnsureCmd) XXX_DiscardUnknown()

func (*CredentialEnsureCmd) XXX_Marshal 

func (m *CredentialEnsureCmd) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CredentialEnsureCmd) XXX_Merge 

func (m *CredentialEnsureCmd) XXX_Merge(src proto.Message)

func (*CredentialEnsureCmd) XXX_Size 

func (m *CredentialEnsureCmd) XXX_Size() int

func (*CredentialEnsureCmd) XXX_Unmarshal 

func (m *CredentialEnsureCmd) XXX_Unmarshal(b []byte) error

type CredentialListCmd 

type CredentialListCmd struct {
}

func (*CredentialListCmd) Descriptor 

func (*CredentialListCmd) Descriptor() ([]byte, []int)

func (*CredentialListCmd) Equal 

func (this *CredentialListCmd) Equal(that interface{}) bool

func (*CredentialListCmd) GoString 

func (this *CredentialListCmd) GoString() string

func (*CredentialListCmd) Marshal 

func (m *CredentialListCmd) Marshal() (dAtA []byte, err error)

func (*CredentialListCmd) MarshalTo 

func (m *CredentialListCmd) MarshalTo(dAtA []byte) (int, error)

func (*CredentialListCmd) MarshalToSizedBuffer 

func (m *CredentialListCmd) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CredentialListCmd) ProtoMessage 

func (*CredentialListCmd) ProtoMessage()

func (*CredentialListCmd) Reset 

func (m *CredentialListCmd) Reset()

func (*CredentialListCmd) Size 

func (m *CredentialListCmd) Size() (n int)

func (*CredentialListCmd) String 

func (this *CredentialListCmd) String() string

func (*CredentialListCmd) Unmarshal 

func (m *CredentialListCmd) Unmarshal(dAtA []byte) error

func (*CredentialListCmd) XXX_DiscardUnknown 

func (m *CredentialListCmd) XXX_DiscardUnknown()

func (*CredentialListCmd) XXX_Marshal 

func (m *CredentialListCmd) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CredentialListCmd) XXX_Merge 

func (m *CredentialListCmd) XXX_Merge(src proto.Message)

func (*CredentialListCmd) XXX_Size 

func (m *CredentialListCmd) XXX_Size() int

func (*CredentialListCmd) XXX_Unmarshal 

func (m *CredentialListCmd) XXX_Unmarshal(b []byte) error

type CredentialStatusMsg 

type CredentialStatusMsg struct {
	SshPrivateKeySha256Hex string `` /* 133-byte string literal not displayed */
}

func NewCredentialStatusMsg 

func NewCredentialStatusMsg(sshPrivateKeySha256Hex string) *CredentialStatusMsg

func (*CredentialStatusMsg) Descriptor 

func (*CredentialStatusMsg) Descriptor() ([]byte, []int)

func (*CredentialStatusMsg) Equal 

func (this *CredentialStatusMsg) Equal(that interface{}) bool

func (*CredentialStatusMsg) GetSshPrivateKeySha256Hex 

func (m *CredentialStatusMsg) GetSshPrivateKeySha256Hex() string

func (*CredentialStatusMsg) GoString 

func (this *CredentialStatusMsg) GoString() string

func (*CredentialStatusMsg) Marshal 

func (m *CredentialStatusMsg) Marshal() (dAtA []byte, err error)

func (*CredentialStatusMsg) MarshalTo 

func (m *CredentialStatusMsg) MarshalTo(dAtA []byte) (int, error)

func (*CredentialStatusMsg) MarshalToSizedBuffer 

func (m *CredentialStatusMsg) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CredentialStatusMsg) ProtoMessage 

func (*CredentialStatusMsg) ProtoMessage()

func (*CredentialStatusMsg) Reset 

func (m *CredentialStatusMsg) Reset()

func (*CredentialStatusMsg) Size 

func (m *CredentialStatusMsg) Size() (n int)

func (*CredentialStatusMsg) String 

func (this *CredentialStatusMsg) String() string

func (*CredentialStatusMsg) Unmarshal 

func (m *CredentialStatusMsg) Unmarshal(dAtA []byte) error

func (*CredentialStatusMsg) XXX_DiscardUnknown 

func (m *CredentialStatusMsg) XXX_DiscardUnknown()

func (*CredentialStatusMsg) XXX_Marshal 

func (m *CredentialStatusMsg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CredentialStatusMsg) XXX_Merge 

func (m *CredentialStatusMsg) XXX_Merge(src proto.Message)

func (*CredentialStatusMsg) XXX_Size 

func (m *CredentialStatusMsg) XXX_Size() int

func (*CredentialStatusMsg) XXX_Unmarshal 

func (m *CredentialStatusMsg) XXX_Unmarshal(b []byte) error

type EdgeDeviceClient 

type EdgeDeviceClient interface {
	Sync(ctx context.Context, opts ...grpc.CallOption) (EdgeDevice_SyncClient, error)
}

EdgeDeviceClient is the client API for EdgeDevice service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewEdgeDeviceClient 

func NewEdgeDeviceClient(cc *grpc.ClientConn) EdgeDeviceClient

type EdgeDeviceServer 

type EdgeDeviceServer interface {
	Sync(EdgeDevice_SyncServer) error
}

EdgeDeviceServer is the server API for EdgeDevice service.

type EdgeDevice_SyncClient 

type EdgeDevice_SyncClient interface {
	Send(*Msg) error
	Recv() (*Cmd, error)
	grpc.ClientStream
}

type EdgeDevice_SyncServer 

type EdgeDevice_SyncServer interface {
	Send(*Cmd) error
	Recv() (*Msg, error)
	grpc.ServerStream
}

type Empty 

type Empty struct {
}

func (*Empty) Descriptor 

func (*Empty) Descriptor() ([]byte, []int)

func (*Empty) Equal 

func (this *Empty) Equal(that interface{}) bool

func (*Empty) GoString 

func (this *Empty) GoString() string

func (*Empty) Marshal 

func (m *Empty) Marshal() (dAtA []byte, err error)

func (*Empty) MarshalTo 

func (m *Empty) MarshalTo(dAtA []byte) (int, error)

func (*Empty) MarshalToSizedBuffer 

func (m *Empty) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Empty) ProtoMessage 

func (*Empty) ProtoMessage()

func (*Empty) Reset 

func (m *Empty) Reset()

func (*Empty) Size 

func (m *Empty) Size() (n int)

func (*Empty) String 

func (this *Empty) String() string

func (*Empty) Unmarshal 

func (m *Empty) Unmarshal(dAtA []byte) error

func (*Empty) XXX_DiscardUnknown 

func (m *Empty) XXX_DiscardUnknown()

func (*Empty) XXX_Marshal 

func (m *Empty) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Empty) XXX_Merge 

func (m *Empty) XXX_Merge(src proto.Message)

func (*Empty) XXX_Size 

func (m *Empty) XXX_Size() int

func (*Empty) XXX_Unmarshal 

func (m *Empty) XXX_Unmarshal(b []byte) error

type ErrorMsg 

type ErrorMsg struct {
	Kind ErrorMsg_Kind `protobuf:"varint,1,opt,name=kind,proto3,enum=aranya.ErrorMsg_Kind" json:"kind,omitempty"`
	// Human readable error description
	Description string `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	// error code may be used for:
	//  - exit code of command execution
	//  - ...TBD
	Code int64 `protobuf:"varint,3,opt,name=code,proto3" json:"code,omitempty"`
}

Error infomation

func NewCommonErrorMsg 

func NewCommonErrorMsg(format string, args ...interface{}) *ErrorMsg

func NewCommonErrorMsgWithCode 

func NewCommonErrorMsgWithCode(code int64, format string, args ...interface{}) *ErrorMsg

func NewErrorMsg 

func NewErrorMsg(kind ErrorMsg_Kind, format string, args ...interface{}) *ErrorMsg

func NewTimeoutErrorMsg 

func NewTimeoutErrorMsg(sid uint64) *ErrorMsg

func (*ErrorMsg) Descriptor 

func (*ErrorMsg) Descriptor() ([]byte, []int)

func (*ErrorMsg) Equal 

func (this *ErrorMsg) Equal(that interface{}) bool

func (*ErrorMsg) Error 

func (m *ErrorMsg) Error() string

func (*ErrorMsg) GetCode 

func (m *ErrorMsg) GetCode() int64

func (*ErrorMsg) GetDescription 

func (m *ErrorMsg) GetDescription() string

func (*ErrorMsg) GetKind 

func (m *ErrorMsg) GetKind() ErrorMsg_Kind

func (*ErrorMsg) GoString 

func (this *ErrorMsg) GoString() string

func (*ErrorMsg) IsAlreadyExists 

func (m *ErrorMsg) IsAlreadyExists() bool

func (*ErrorMsg) IsCommon 

func (m *ErrorMsg) IsCommon() bool

func (*ErrorMsg) IsNotFound 

func (m *ErrorMsg) IsNotFound() bool

func (*ErrorMsg) IsNotSupported 

func (m *ErrorMsg) IsNotSupported() bool

func (*ErrorMsg) Marshal 

func (m *ErrorMsg) Marshal() (dAtA []byte, err error)

func (*ErrorMsg) MarshalTo 

func (m *ErrorMsg) MarshalTo(dAtA []byte) (int, error)

func (*ErrorMsg) MarshalToSizedBuffer 

func (m *ErrorMsg) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ErrorMsg) ProtoMessage 

func (*ErrorMsg) ProtoMessage()

func (*ErrorMsg) Reset 

func (m *ErrorMsg) Reset()

func (*ErrorMsg) Size 

func (m *ErrorMsg) Size() (n int)

func (*ErrorMsg) String 

func (this *ErrorMsg) String() string

func (*ErrorMsg) Unmarshal 

func (m *ErrorMsg) Unmarshal(dAtA []byte) error

func (*ErrorMsg) XXX_DiscardUnknown 

func (m *ErrorMsg) XXX_DiscardUnknown()

func (*ErrorMsg) XXX_Marshal 

func (m *ErrorMsg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ErrorMsg) XXX_Merge 

func (m *ErrorMsg) XXX_Merge(src proto.Message)

func (*ErrorMsg) XXX_Size 

func (m *ErrorMsg) XXX_Size() int

func (*ErrorMsg) XXX_Unmarshal 

func (m *ErrorMsg) XXX_Unmarshal(b []byte) error

type ErrorMsg_Kind 

type ErrorMsg_Kind int32
const (
	// ERR_COMMON means Error happened, but we don't know what to do,
	// report as failure and retry later.
	ERR_COMMON ErrorMsg_Kind = 0
	// ERR_NOT_FOUND means something not found but may be expected by
	// the scheduler, aranya should schedule according task or ignore.
	ERR_NOT_FOUND ErrorMsg_Kind = 1
	// ERR_ALREADY_EXISTS means something expected by the scheduler already
	// exists in agent, agent only report this error when it's sure the
	// existing object is the same with the one expected by the scheduler,
	// otherwise it should report ERR_NOT_FOUND.
	ERR_ALREADY_EXISTS ErrorMsg_Kind = 2
	// ERR_NOT_SUPPORTED means Cmd not supported by the agent,
	// aranya should ignore this error and cancel all future
	// job.
	ERR_NOT_SUPPORTED ErrorMsg_Kind = 3
	// ERR_TIMEOUT only happens in connectivity server,
	// right after the session is timed out
	ERR_TIMEOUT ErrorMsg_Kind = 4
)

func (ErrorMsg_Kind) EnumDescriptor 

func (ErrorMsg_Kind) EnumDescriptor() ([]byte, []int)

func (ErrorMsg_Kind) String 

func (x ErrorMsg_Kind) String() string

type ExecOrAttachCmd 

type ExecOrAttachCmd struct {
	PodUid    string `protobuf:"bytes,1,opt,name=pod_uid,json=podUid,proto3" json:"pod_uid,omitempty"`
	Container string `protobuf:"bytes,2,opt,name=container,proto3" json:"container,omitempty"`
	Stdin     bool   `protobuf:"varint,3,opt,name=stdin,proto3" json:"stdin,omitempty"`
	Stdout    bool   `protobuf:"varint,4,opt,name=stdout,proto3" json:"stdout,omitempty"`
	Stderr    bool   `protobuf:"varint,5,opt,name=stderr,proto3" json:"stderr,omitempty"`
	Tty       bool   `protobuf:"varint,6,opt,name=tty,proto3" json:"tty,omitempty"`
	// command is empty when used for container attach
	Command []string `protobuf:"bytes,7,rep,name=command,proto3" json:"command,omitempty"`
	// environment variables when used with virtual host container image
	// values are resolved by aranya
	Envs map[string]string `` /* 149-byte string literal not displayed */
}

Exec/Attach Cmd

func NewAttachCmd 

func NewAttachCmd(podUID, container string, stdin, stdout, stderr, tty bool) *ExecOrAttachCmd

func NewExecCmd 

func NewExecCmd(
	podUID, container string,
	command []string,
	stdin, stdout, stderr, tty bool,
	env map[string]string,
) *ExecOrAttachCmd

func (*ExecOrAttachCmd) Descriptor 

func (*ExecOrAttachCmd) Descriptor() ([]byte, []int)

func (*ExecOrAttachCmd) Equal 

func (this *ExecOrAttachCmd) Equal(that interface{}) bool

func (*ExecOrAttachCmd) GetCommand 

func (m *ExecOrAttachCmd) GetCommand() []string

func (*ExecOrAttachCmd) GetContainer 

func (m *ExecOrAttachCmd) GetContainer() string

func (*ExecOrAttachCmd) GetEnvs 

func (m *ExecOrAttachCmd) GetEnvs() map[string]string

func (*ExecOrAttachCmd) GetPodUid 

func (m *ExecOrAttachCmd) GetPodUid() string

func (*ExecOrAttachCmd) GetStderr 

func (m *ExecOrAttachCmd) GetStderr() bool

func (*ExecOrAttachCmd) GetStdin 

func (m *ExecOrAttachCmd) GetStdin() bool

func (*ExecOrAttachCmd) GetStdout 

func (m *ExecOrAttachCmd) GetStdout() bool

func (*ExecOrAttachCmd) GetTty 

func (m *ExecOrAttachCmd) GetTty() bool

func (*ExecOrAttachCmd) GoString 

func (this *ExecOrAttachCmd) GoString() string

func (*ExecOrAttachCmd) Marshal 

func (m *ExecOrAttachCmd) Marshal() (dAtA []byte, err error)

func (*ExecOrAttachCmd) MarshalTo 

func (m *ExecOrAttachCmd) MarshalTo(dAtA []byte) (int, error)

func (*ExecOrAttachCmd) MarshalToSizedBuffer 

func (m *ExecOrAttachCmd) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ExecOrAttachCmd) ProtoMessage 

func (*ExecOrAttachCmd) ProtoMessage()

func (*ExecOrAttachCmd) Reset 

func (m *ExecOrAttachCmd) Reset()

func (*ExecOrAttachCmd) Size 

func (m *ExecOrAttachCmd) Size() (n int)

func (*ExecOrAttachCmd) String 

func (this *ExecOrAttachCmd) String() string

func (*ExecOrAttachCmd) Unmarshal 

func (m *ExecOrAttachCmd) Unmarshal(dAtA []byte) error

func (*ExecOrAttachCmd) XXX_DiscardUnknown 

func (m *ExecOrAttachCmd) XXX_DiscardUnknown()

func (*ExecOrAttachCmd) XXX_Marshal 

func (m *ExecOrAttachCmd) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExecOrAttachCmd) XXX_Merge 

func (m *ExecOrAttachCmd) XXX_Merge(src proto.Message)

func (*ExecOrAttachCmd) XXX_Size 

func (m *ExecOrAttachCmd) XXX_Size() int

func (*ExecOrAttachCmd) XXX_Unmarshal 

func (m *ExecOrAttachCmd) XXX_Unmarshal(b []byte) error

type ImageAuthConfig 

type ImageAuthConfig struct {
	Username      string `protobuf:"bytes,1,opt,name=username,proto3" json:"username,omitempty"`
	Password      string `protobuf:"bytes,2,opt,name=password,proto3" json:"password,omitempty"`
	Auth          string `protobuf:"bytes,3,opt,name=auth,proto3" json:"auth,omitempty"`
	ServerAddress string `protobuf:"bytes,4,opt,name=server_address,json=serverAddress,proto3" json:"server_address,omitempty"`
	// IdentityToken is used to authenticate the user and get
	// an access token for the registry.
	IdentityToken string `protobuf:"bytes,5,opt,name=identity_token,json=identityToken,proto3" json:"identity_token,omitempty"`
	// RegistryToken is a bearer token to be sent to a registry
	RegistryToken string `protobuf:"bytes,6,opt,name=registry_token,json=registryToken,proto3" json:"registry_token,omitempty"`
	Email         string `protobuf:"bytes,7,opt,name=email,proto3" json:"email,omitempty"`
}

func (*ImageAuthConfig) Descriptor 

func (*ImageAuthConfig) Descriptor() ([]byte, []int)

func (*ImageAuthConfig) Equal 

func (this *ImageAuthConfig) Equal(that interface{}) bool

func (*ImageAuthConfig) GetAuth 

func (m *ImageAuthConfig) GetAuth() string

func (*ImageAuthConfig) GetEmail 

func (m *ImageAuthConfig) GetEmail() string

func (*ImageAuthConfig) GetIdentityToken 

func (m *ImageAuthConfig) GetIdentityToken() string

func (*ImageAuthConfig) GetPassword 

func (m *ImageAuthConfig) GetPassword() string

func (*ImageAuthConfig) GetRegistryToken 

func (m *ImageAuthConfig) GetRegistryToken() string

func (*ImageAuthConfig) GetServerAddress 

func (m *ImageAuthConfig) GetServerAddress() string

func (*ImageAuthConfig) GetUsername 

func (m *ImageAuthConfig) GetUsername() string

func (*ImageAuthConfig) GoString 

func (this *ImageAuthConfig) GoString() string

func (*ImageAuthConfig) Marshal 

func (m *ImageAuthConfig) Marshal() (dAtA []byte, err error)

func (*ImageAuthConfig) MarshalTo 

func (m *ImageAuthConfig) MarshalTo(dAtA []byte) (int, error)

func (*ImageAuthConfig) MarshalToSizedBuffer 

func (m *ImageAuthConfig) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ImageAuthConfig) ProtoMessage 

func (*ImageAuthConfig) ProtoMessage()

func (*ImageAuthConfig) Reset 

func (m *ImageAuthConfig) Reset()

func (*ImageAuthConfig) Size 

func (m *ImageAuthConfig) Size() (n int)

func (*ImageAuthConfig) String 

func (this *ImageAuthConfig) String() string

func (*ImageAuthConfig) Unmarshal 

func (m *ImageAuthConfig) Unmarshal(dAtA []byte) error

func (*ImageAuthConfig) XXX_DiscardUnknown 

func (m *ImageAuthConfig) XXX_DiscardUnknown()

func (*ImageAuthConfig) XXX_Marshal 

func (m *ImageAuthConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ImageAuthConfig) XXX_Merge 

func (m *ImageAuthConfig) XXX_Merge(src proto.Message)

func (*ImageAuthConfig) XXX_Size 

func (m *ImageAuthConfig) XXX_Size() int

func (*ImageAuthConfig) XXX_Unmarshal 

func (m *ImageAuthConfig) XXX_Unmarshal(b []byte) error

type ImageDeleteCmd 

type ImageDeleteCmd struct {
	Refs []string `protobuf:"bytes,1,rep,name=refs,proto3" json:"refs,omitempty"`
}

func NewImageDeleteCmd 

func NewImageDeleteCmd(refs ...string) *ImageDeleteCmd

func (*ImageDeleteCmd) Descriptor 

func (*ImageDeleteCmd) Descriptor() ([]byte, []int)

func (*ImageDeleteCmd) Equal 

func (this *ImageDeleteCmd) Equal(that interface{}) bool

func (*ImageDeleteCmd) GetRefs 

func (m *ImageDeleteCmd) GetRefs() []string

func (*ImageDeleteCmd) GoString 

func (this *ImageDeleteCmd) GoString() string

func (*ImageDeleteCmd) Marshal 

func (m *ImageDeleteCmd) Marshal() (dAtA []byte, err error)

func (*ImageDeleteCmd) MarshalTo 

func (m *ImageDeleteCmd) MarshalTo(dAtA []byte) (int, error)

func (*ImageDeleteCmd) MarshalToSizedBuffer 

func (m *ImageDeleteCmd) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ImageDeleteCmd) ProtoMessage 

func (*ImageDeleteCmd) ProtoMessage()

func (*ImageDeleteCmd) Reset 

func (m *ImageDeleteCmd) Reset()

func (*ImageDeleteCmd) Size 

func (m *ImageDeleteCmd) Size() (n int)

func (*ImageDeleteCmd) String 

func (this *ImageDeleteCmd) String() string

func (*ImageDeleteCmd) Unmarshal 

func (m *ImageDeleteCmd) Unmarshal(dAtA []byte) error

func (*ImageDeleteCmd) XXX_DiscardUnknown 

func (m *ImageDeleteCmd) XXX_DiscardUnknown()

func (*ImageDeleteCmd) XXX_Marshal 

func (m *ImageDeleteCmd) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ImageDeleteCmd) XXX_Merge 

func (m *ImageDeleteCmd) XXX_Merge(src proto.Message)

func (*ImageDeleteCmd) XXX_Size 

func (m *ImageDeleteCmd) XXX_Size() int

func (*ImageDeleteCmd) XXX_Unmarshal 

func (m *ImageDeleteCmd) XXX_Unmarshal(b []byte) error

type ImageEnsureCmd 

type ImageEnsureCmd struct {
	// key: image ref (name)
	// value: pull config
	Images map[string]*ImagePullSpec `` /* 153-byte string literal not displayed */
}

func (*ImageEnsureCmd) Descriptor 

func (*ImageEnsureCmd) Descriptor() ([]byte, []int)

func (*ImageEnsureCmd) Equal 

func (this *ImageEnsureCmd) Equal(that interface{}) bool

func (*ImageEnsureCmd) GetImages 

func (m *ImageEnsureCmd) GetImages() map[string]*ImagePullSpec

func (*ImageEnsureCmd) GoString 

func (this *ImageEnsureCmd) GoString() string

func (*ImageEnsureCmd) Marshal 

func (m *ImageEnsureCmd) Marshal() (dAtA []byte, err error)

func (*ImageEnsureCmd) MarshalTo 

func (m *ImageEnsureCmd) MarshalTo(dAtA []byte) (int, error)

func (*ImageEnsureCmd) MarshalToSizedBuffer 

func (m *ImageEnsureCmd) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ImageEnsureCmd) ProtoMessage 

func (*ImageEnsureCmd) ProtoMessage()

func (*ImageEnsureCmd) Reset 

func (m *ImageEnsureCmd) Reset()

func (*ImageEnsureCmd) Size 

func (m *ImageEnsureCmd) Size() (n int)

func (*ImageEnsureCmd) String 

func (this *ImageEnsureCmd) String() string

func (*ImageEnsureCmd) Unmarshal 

func (m *ImageEnsureCmd) Unmarshal(dAtA []byte) error

func (*ImageEnsureCmd) XXX_DiscardUnknown 

func (m *ImageEnsureCmd) XXX_DiscardUnknown()

func (*ImageEnsureCmd) XXX_Marshal 

func (m *ImageEnsureCmd) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ImageEnsureCmd) XXX_Merge 

func (m *ImageEnsureCmd) XXX_Merge(src proto.Message)

func (*ImageEnsureCmd) XXX_Size 

func (m *ImageEnsureCmd) XXX_Size() int

func (*ImageEnsureCmd) XXX_Unmarshal 

func (m *ImageEnsureCmd) XXX_Unmarshal(b []byte) error

type ImageListCmd 

type ImageListCmd struct {
	Refs []string `protobuf:"bytes,1,rep,name=refs,proto3" json:"refs,omitempty"`
}

func NewImageListCmd 

func NewImageListCmd(refs ...string) *ImageListCmd

func (*ImageListCmd) Descriptor 

func (*ImageListCmd) Descriptor() ([]byte, []int)

func (*ImageListCmd) Equal 

func (this *ImageListCmd) Equal(that interface{}) bool

func (*ImageListCmd) GetRefs 

func (m *ImageListCmd) GetRefs() []string

func (*ImageListCmd) GoString 

func (this *ImageListCmd) GoString() string

func (*ImageListCmd) Marshal 

func (m *ImageListCmd) Marshal() (dAtA []byte, err error)

func (*ImageListCmd) MarshalTo 

func (m *ImageListCmd) MarshalTo(dAtA []byte) (int, error)

func (*ImageListCmd) MarshalToSizedBuffer 

func (m *ImageListCmd) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ImageListCmd) ProtoMessage 

func (*ImageListCmd) ProtoMessage()

func (*ImageListCmd) Reset 

func (m *ImageListCmd) Reset()

func (*ImageListCmd) Size 

func (m *ImageListCmd) Size() (n int)

func (*ImageListCmd) String 

func (this *ImageListCmd) String() string

func (*ImageListCmd) Unmarshal 

func (m *ImageListCmd) Unmarshal(dAtA []byte) error

func (*ImageListCmd) XXX_DiscardUnknown 

func (m *ImageListCmd) XXX_DiscardUnknown()

func (*ImageListCmd) XXX_Marshal 

func (m *ImageListCmd) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ImageListCmd) XXX_Merge 

func (m *ImageListCmd) XXX_Merge(src proto.Message)

func (*ImageListCmd) XXX_Size 

func (m *ImageListCmd) XXX_Size() int

func (*ImageListCmd) XXX_Unmarshal 

func (m *ImageListCmd) XXX_Unmarshal(b []byte) error

type ImagePullPolicy 

type ImagePullPolicy int32
const (
	IMAGE_PULL_ALWAYS         ImagePullPolicy = 0
	IMAGE_PULL_IF_NOT_PRESENT ImagePullPolicy = 1
	IMAGE_PULL_NEVER          ImagePullPolicy = 2
)

func (ImagePullPolicy) EnumDescriptor 

func (ImagePullPolicy) EnumDescriptor() ([]byte, []int)

func (ImagePullPolicy) String 

func (x ImagePullPolicy) String() string

type ImagePullSpec 

type ImagePullSpec struct {
	// image pull secrets
	AuthConfig *ImageAuthConfig `protobuf:"bytes,1,opt,name=auth_config,json=authConfig,proto3" json:"auth_config,omitempty"`
	// pull policy
	PullPolicy ImagePullPolicy `protobuf:"varint,2,opt,name=pull_policy,json=pullPolicy,proto3,enum=aranya.ImagePullPolicy" json:"pull_policy,omitempty"`
}

func (*ImagePullSpec) Descriptor 

func (*ImagePullSpec) Descriptor() ([]byte, []int)

func (*ImagePullSpec) Equal 

func (this *ImagePullSpec) Equal(that interface{}) bool

func (*ImagePullSpec) GetAuthConfig 

func (m *ImagePullSpec) GetAuthConfig() *ImageAuthConfig

func (*ImagePullSpec) GetPullPolicy 

func (m *ImagePullSpec) GetPullPolicy() ImagePullPolicy

func (*ImagePullSpec) GoString 

func (this *ImagePullSpec) GoString() string

func (*ImagePullSpec) Marshal 

func (m *ImagePullSpec) Marshal() (dAtA []byte, err error)

func (*ImagePullSpec) MarshalTo 

func (m *ImagePullSpec) MarshalTo(dAtA []byte) (int, error)

func (*ImagePullSpec) MarshalToSizedBuffer 

func (m *ImagePullSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ImagePullSpec) ProtoMessage 

func (*ImagePullSpec) ProtoMessage()

func (*ImagePullSpec) Reset 

func (m *ImagePullSpec) Reset()

func (*ImagePullSpec) Size 

func (m *ImagePullSpec) Size() (n int)

func (*ImagePullSpec) String 

func (this *ImagePullSpec) String() string

func (*ImagePullSpec) Unmarshal 

func (m *ImagePullSpec) Unmarshal(dAtA []byte) error

func (*ImagePullSpec) XXX_DiscardUnknown 

func (m *ImagePullSpec) XXX_DiscardUnknown()

func (*ImagePullSpec) XXX_Marshal 

func (m *ImagePullSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ImagePullSpec) XXX_Merge 

func (m *ImagePullSpec) XXX_Merge(src proto.Message)

func (*ImagePullSpec) XXX_Size 

func (m *ImagePullSpec) XXX_Size() int

func (*ImagePullSpec) XXX_Unmarshal 

func (m *ImagePullSpec) XXX_Unmarshal(b []byte) error

type ImageStatusListMsg 

type ImageStatusListMsg struct {
	Images []*ImageStatusMsg `protobuf:"bytes,1,rep,name=images,proto3" json:"images,omitempty"`
}

func (*ImageStatusListMsg) Descriptor 

func (*ImageStatusListMsg) Descriptor() ([]byte, []int)

func (*ImageStatusListMsg) Equal 

func (this *ImageStatusListMsg) Equal(that interface{}) bool

func (*ImageStatusListMsg) GetImages 

func (m *ImageStatusListMsg) GetImages() []*ImageStatusMsg

func (*ImageStatusListMsg) GoString 

func (this *ImageStatusListMsg) GoString() string

func (*ImageStatusListMsg) Marshal 

func (m *ImageStatusListMsg) Marshal() (dAtA []byte, err error)

func (*ImageStatusListMsg) MarshalTo 

func (m *ImageStatusListMsg) MarshalTo(dAtA []byte) (int, error)

func (*ImageStatusListMsg) MarshalToSizedBuffer 

func (m *ImageStatusListMsg) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ImageStatusListMsg) ProtoMessage 

func (*ImageStatusListMsg) ProtoMessage()

func (*ImageStatusListMsg) Reset 

func (m *ImageStatusListMsg) Reset()

func (*ImageStatusListMsg) Size 

func (m *ImageStatusListMsg) Size() (n int)

func (*ImageStatusListMsg) String 

func (this *ImageStatusListMsg) String() string

func (*ImageStatusListMsg) Unmarshal 

func (m *ImageStatusListMsg) Unmarshal(dAtA []byte) error

func (*ImageStatusListMsg) XXX_DiscardUnknown 

func (m *ImageStatusListMsg) XXX_DiscardUnknown()

func (*ImageStatusListMsg) XXX_Marshal 

func (m *ImageStatusListMsg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ImageStatusListMsg) XXX_Merge 

func (m *ImageStatusListMsg) XXX_Merge(src proto.Message)

func (*ImageStatusListMsg) XXX_Size 

func (m *ImageStatusListMsg) XXX_Size() int

func (*ImageStatusListMsg) XXX_Unmarshal 

func (m *ImageStatusListMsg) XXX_Unmarshal(b []byte) error

type ImageStatusMsg 

type ImageStatusMsg struct {
	Sha256 string `protobuf:"bytes,1,opt,name=sha256,proto3" json:"sha256,omitempty"`
	// size of the image in bytes
	Size_ uint64   `protobuf:"varint,2,opt,name=size,proto3" json:"size,omitempty"`
	Refs  []string `protobuf:"bytes,3,rep,name=refs,proto3" json:"refs,omitempty"`
}

func (*ImageStatusMsg) Descriptor 

func (*ImageStatusMsg) Descriptor() ([]byte, []int)

func (*ImageStatusMsg) Equal 

func (this *ImageStatusMsg) Equal(that interface{}) bool

func (*ImageStatusMsg) GetRefs 

func (m *ImageStatusMsg) GetRefs() []string

func (*ImageStatusMsg) GetSha256 

func (m *ImageStatusMsg) GetSha256() string

func (*ImageStatusMsg) GetSize_ 

func (m *ImageStatusMsg) GetSize_() uint64

func (*ImageStatusMsg) GoString 

func (this *ImageStatusMsg) GoString() string

func (*ImageStatusMsg) Marshal 

func (m *ImageStatusMsg) Marshal() (dAtA []byte, err error)

func (*ImageStatusMsg) MarshalTo 

func (m *ImageStatusMsg) MarshalTo(dAtA []byte) (int, error)

func (*ImageStatusMsg) MarshalToSizedBuffer 

func (m *ImageStatusMsg) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ImageStatusMsg) ProtoMessage 

func (*ImageStatusMsg) ProtoMessage()

func (*ImageStatusMsg) Reset 

func (m *ImageStatusMsg) Reset()

func (*ImageStatusMsg) Size 

func (m *ImageStatusMsg) Size() (n int)

func (*ImageStatusMsg) String 

func (this *ImageStatusMsg) String() string

func (*ImageStatusMsg) Unmarshal 

func (m *ImageStatusMsg) Unmarshal(dAtA []byte) error

func (*ImageStatusMsg) XXX_DiscardUnknown 

func (m *ImageStatusMsg) XXX_DiscardUnknown()

func (*ImageStatusMsg) XXX_Marshal 

func (m *ImageStatusMsg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ImageStatusMsg) XXX_Merge 

func (m *ImageStatusMsg) XXX_Merge(src proto.Message)

func (*ImageStatusMsg) XXX_Size 

func (m *ImageStatusMsg) XXX_Size() int

func (*ImageStatusMsg) XXX_Unmarshal 

func (m *ImageStatusMsg) XXX_Unmarshal(b []byte) error

type KeyValuePair 

type KeyValuePair struct {
	Key   string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
}

func (*KeyValuePair) Descriptor 

func (*KeyValuePair) Descriptor() ([]byte, []int)

func (*KeyValuePair) Equal 

func (this *KeyValuePair) Equal(that interface{}) bool

func (*KeyValuePair) GetKey 

func (m *KeyValuePair) GetKey() string

func (*KeyValuePair) GetValue 

func (m *KeyValuePair) GetValue() string

func (*KeyValuePair) GoString 

func (this *KeyValuePair) GoString() string

func (*KeyValuePair) Marshal 

func (m *KeyValuePair) Marshal() (dAtA []byte, err error)

func (*KeyValuePair) MarshalTo 

func (m *KeyValuePair) MarshalTo(dAtA []byte) (int, error)

func (*KeyValuePair) MarshalToSizedBuffer 

func (m *KeyValuePair) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*KeyValuePair) ProtoMessage 

func (*KeyValuePair) ProtoMessage()

func (*KeyValuePair) Reset 

func (m *KeyValuePair) Reset()

func (*KeyValuePair) Size 

func (m *KeyValuePair) Size() (n int)

func (*KeyValuePair) String 

func (this *KeyValuePair) String() string

func (*KeyValuePair) Unmarshal 

func (m *KeyValuePair) Unmarshal(dAtA []byte) error

func (*KeyValuePair) XXX_DiscardUnknown 

func (m *KeyValuePair) XXX_DiscardUnknown()

func (*KeyValuePair) XXX_Marshal 

func (m *KeyValuePair) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*KeyValuePair) XXX_Merge 

func (m *KeyValuePair) XXX_Merge(src proto.Message)

func (*KeyValuePair) XXX_Size 

func (m *KeyValuePair) XXX_Size() int

func (*KeyValuePair) XXX_Unmarshal 

func (m *KeyValuePair) XXX_Unmarshal(b []byte) error

type LogsCmd 

type LogsCmd struct {
	PodUid     string `protobuf:"bytes,1,opt,name=pod_uid,json=podUid,proto3" json:"pod_uid,omitempty"`
	Container  string `protobuf:"bytes,2,opt,name=container,proto3" json:"container,omitempty"`
	Follow     bool   `protobuf:"varint,3,opt,name=follow,proto3" json:"follow,omitempty"`
	Timestamp  bool   `protobuf:"varint,4,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Since      string `protobuf:"bytes,5,opt,name=since,proto3" json:"since,omitempty"`
	TailLines  int64  `protobuf:"varint,6,opt,name=tail_lines,json=tailLines,proto3" json:"tail_lines,omitempty"`
	BytesLimit int64  `protobuf:"varint,7,opt,name=bytes_limit,json=bytesLimit,proto3" json:"bytes_limit,omitempty"`
	Previous   bool   `protobuf:"varint,8,opt,name=previous,proto3" json:"previous,omitempty"`
	// host log path
	Path string `protobuf:"bytes,9,opt,name=path,proto3" json:"path,omitempty"`
}

func NewHostLogCmd 

func NewHostLogCmd(path string) *LogsCmd

func NewLogsCmd 

func NewLogsCmd(
	podUID, container string,
	follow, timestamp, previous bool,
	since time.Time, tailLines, bytesLimit int64,
) *LogsCmd

func (*LogsCmd) Descriptor 

func (*LogsCmd) Descriptor() ([]byte, []int)

func (*LogsCmd) Equal 

func (this *LogsCmd) Equal(that interface{}) bool

func (*LogsCmd) GetBytesLimit 

func (m *LogsCmd) GetBytesLimit() int64

func (*LogsCmd) GetContainer 

func (m *LogsCmd) GetContainer() string

func (*LogsCmd) GetFollow 

func (m *LogsCmd) GetFollow() bool

func (*LogsCmd) GetPath 

func (m *LogsCmd) GetPath() string

func (*LogsCmd) GetPodUid 

func (m *LogsCmd) GetPodUid() string

func (*LogsCmd) GetPrevious 

func (m *LogsCmd) GetPrevious() bool

func (*LogsCmd) GetSince 

func (m *LogsCmd) GetSince() string

func (*LogsCmd) GetTailLines 

func (m *LogsCmd) GetTailLines() int64

func (*LogsCmd) GetTimestamp 

func (m *LogsCmd) GetTimestamp() bool

func (*LogsCmd) GoString 

func (this *LogsCmd) GoString() string

func (*LogsCmd) Marshal 

func (m *LogsCmd) Marshal() (dAtA []byte, err error)

func (*LogsCmd) MarshalTo 

func (m *LogsCmd) MarshalTo(dAtA []byte) (int, error)

func (*LogsCmd) MarshalToSizedBuffer 

func (m *LogsCmd) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*LogsCmd) ProtoMessage 

func (*LogsCmd) ProtoMessage()

func (*LogsCmd) Reset 

func (m *LogsCmd) Reset()

func (*LogsCmd) Size 

func (m *LogsCmd) Size() (n int)

func (*LogsCmd) String 

func (this *LogsCmd) String() string

func (*LogsCmd) Unmarshal 

func (m *LogsCmd) Unmarshal(dAtA []byte) error

func (*LogsCmd) XXX_DiscardUnknown 

func (m *LogsCmd) XXX_DiscardUnknown()

func (*LogsCmd) XXX_Marshal 

func (m *LogsCmd) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LogsCmd) XXX_Merge 

func (m *LogsCmd) XXX_Merge(src proto.Message)

func (*LogsCmd) XXX_Size 

func (m *LogsCmd) XXX_Size() int

func (*LogsCmd) XXX_Unmarshal 

func (m *LogsCmd) XXX_Unmarshal(b []byte) error

type MetricsCollectCmd 

type MetricsCollectCmd struct {
	Target MetricsTarget `protobuf:"varint,1,opt,name=target,proto3,enum=aranya.MetricsTarget" json:"target,omitempty"`
}

func NewMetricsCollectCmd 

func NewMetricsCollectCmd(t MetricsTarget) *MetricsCollectCmd

func (*MetricsCollectCmd) Descriptor 

func (*MetricsCollectCmd) Descriptor() ([]byte, []int)

func (*MetricsCollectCmd) Equal 

func (this *MetricsCollectCmd) Equal(that interface{}) bool

func (*MetricsCollectCmd) GetTarget 

func (m *MetricsCollectCmd) GetTarget() MetricsTarget

func (*MetricsCollectCmd) GoString 

func (this *MetricsCollectCmd) GoString() string

func (*MetricsCollectCmd) Marshal 

func (m *MetricsCollectCmd) Marshal() (dAtA []byte, err error)

func (*MetricsCollectCmd) MarshalTo 

func (m *MetricsCollectCmd) MarshalTo(dAtA []byte) (int, error)

func (*MetricsCollectCmd) MarshalToSizedBuffer 

func (m *MetricsCollectCmd) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MetricsCollectCmd) ProtoMessage 

func (*MetricsCollectCmd) ProtoMessage()

func (*MetricsCollectCmd) Reset 

func (m *MetricsCollectCmd) Reset()

func (*MetricsCollectCmd) Size 

func (m *MetricsCollectCmd) Size() (n int)

func (*MetricsCollectCmd) String 

func (this *MetricsCollectCmd) String() string

func (*MetricsCollectCmd) Unmarshal 

func (m *MetricsCollectCmd) Unmarshal(dAtA []byte) error

func (*MetricsCollectCmd) XXX_DiscardUnknown 

func (m *MetricsCollectCmd) XXX_DiscardUnknown()

func (*MetricsCollectCmd) XXX_Marshal 

func (m *MetricsCollectCmd) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MetricsCollectCmd) XXX_Merge 

func (m *MetricsCollectCmd) XXX_Merge(src proto.Message)

func (*MetricsCollectCmd) XXX_Size 

func (m *MetricsCollectCmd) XXX_Size() int

func (*MetricsCollectCmd) XXX_Unmarshal 

func (m *MetricsCollectCmd) XXX_Unmarshal(b []byte) error

type MetricsConfigCmd 

type MetricsConfigCmd struct {
	Target    MetricsTarget `protobuf:"varint,1,opt,name=target,proto3,enum=aranya.MetricsTarget" json:"target,omitempty"`
	Collect   []string      `protobuf:"bytes,2,rep,name=collect,proto3" json:"collect,omitempty"`
	ExtraArgs []string      `protobuf:"bytes,3,rep,name=extra_args,json=extraArgs,proto3" json:"extra_args,omitempty"`
}

func NewMetricsConfigCmd 

func NewMetricsConfigCmd(t MetricsTarget, collect, extraArgs []string) *MetricsConfigCmd

func (*MetricsConfigCmd) Descriptor 

func (*MetricsConfigCmd) Descriptor() ([]byte, []int)

func (*MetricsConfigCmd) Equal 

func (this *MetricsConfigCmd) Equal(that interface{}) bool

func (*MetricsConfigCmd) GetCollect 

func (m *MetricsConfigCmd) GetCollect() []string

func (*MetricsConfigCmd) GetExtraArgs 

func (m *MetricsConfigCmd) GetExtraArgs() []string

func (*MetricsConfigCmd) GetTarget 

func (m *MetricsConfigCmd) GetTarget() MetricsTarget

func (*MetricsConfigCmd) GoString 

func (this *MetricsConfigCmd) GoString() string

func (*MetricsConfigCmd) Marshal 

func (m *MetricsConfigCmd) Marshal() (dAtA []byte, err error)

func (*MetricsConfigCmd) MarshalTo 

func (m *MetricsConfigCmd) MarshalTo(dAtA []byte) (int, error)

func (*MetricsConfigCmd) MarshalToSizedBuffer 

func (m *MetricsConfigCmd) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MetricsConfigCmd) ProtoMessage 

func (*MetricsConfigCmd) ProtoMessage()

func (*MetricsConfigCmd) Reset 

func (m *MetricsConfigCmd) Reset()

func (*MetricsConfigCmd) Size 

func (m *MetricsConfigCmd) Size() (n int)

func (*MetricsConfigCmd) String 

func (this *MetricsConfigCmd) String() string

func (*MetricsConfigCmd) Unmarshal 

func (m *MetricsConfigCmd) Unmarshal(dAtA []byte) error

func (*MetricsConfigCmd) XXX_DiscardUnknown 

func (m *MetricsConfigCmd) XXX_DiscardUnknown()

func (*MetricsConfigCmd) XXX_Marshal 

func (m *MetricsConfigCmd) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MetricsConfigCmd) XXX_Merge 

func (m *MetricsConfigCmd) XXX_Merge(src proto.Message)

func (*MetricsConfigCmd) XXX_Size 

func (m *MetricsConfigCmd) XXX_Size() int

func (*MetricsConfigCmd) XXX_Unmarshal 

func (m *MetricsConfigCmd) XXX_Unmarshal(b []byte) error

type MetricsTarget 

type MetricsTarget int32
const (
	METRICS_TARGET_NODE      MetricsTarget = 0
	METRICS_TARGET_CONTAINER MetricsTarget = 1
)

func (MetricsTarget) EnumDescriptor 

func (MetricsTarget) EnumDescriptor() ([]byte, []int)

func (MetricsTarget) String 

func (x MetricsTarget) String() string

type Msg 

type Msg struct {
	Kind MsgType `protobuf:"varint,1,opt,name=kind,proto3,enum=aranya.MsgType" json:"kind,omitempty"`
	// session id
	Sid uint64 `protobuf:"varint,2,opt,name=sid,proto3" json:"sid,omitempty"`
	// sequence in the session, to ensure ordered data
	Seq uint64 `protobuf:"varint,3,opt,name=seq,proto3" json:"seq,omitempty"`
	// mark this Msg is the last piece in the session
	Completed bool `protobuf:"varint,4,opt,name=completed,proto3" json:"completed,omitempty"`
	// body of encoded XxxMsg or raw data bytes
	Body []byte `protobuf:"bytes,11,opt,name=body,proto3" json:"body,omitempty"`
}

func NewMsg 

func NewMsg(kind MsgType, sid, seq uint64, completed bool, payload []byte) *Msg

func (*Msg) Descriptor 

func (*Msg) Descriptor() ([]byte, []int)

func (*Msg) Equal 

func (this *Msg) Equal(that interface{}) bool

func (*Msg) GetBody 

func (m *Msg) GetBody() []byte

func (*Msg) GetCompleted 

func (m *Msg) GetCompleted() bool

func (*Msg) GetCredentialStatus 

func (m *Msg) GetCredentialStatus() *CredentialStatusMsg

func (*Msg) GetData 

func (m *Msg) GetData() []byte

func (*Msg) GetError 

func (m *Msg) GetError() *ErrorMsg

func (*Msg) GetImageList 

func (m *Msg) GetImageList() *ImageStatusListMsg

func (*Msg) GetKind 

func (m *Msg) GetKind() MsgType

func (*Msg) GetNodeStatus 

func (m *Msg) GetNodeStatus() *NodeStatusMsg

func (*Msg) GetPeripheralOperationResult 

func (m *Msg) GetPeripheralOperationResult() *PeripheralOperationResultMsg

func (*Msg) GetPeripheralStatus 

func (m *Msg) GetPeripheralStatus() *PeripheralStatusMsg

func (*Msg) GetPeripheralStatusList 

func (m *Msg) GetPeripheralStatusList() *PeripheralStatusListMsg

func (*Msg) GetPodStatus 

func (m *Msg) GetPodStatus() *PodStatusMsg

func (*Msg) GetPodStatusList 

func (m *Msg) GetPodStatusList() *PodStatusListMsg

func (*Msg) GetSeq 

func (m *Msg) GetSeq() uint64

func (*Msg) GetSid 

func (m *Msg) GetSid() uint64

func (*Msg) GetState 

func (m *Msg) GetState() *StateMsg

func (*Msg) GetStorageStatus 

func (m *Msg) GetStorageStatus() *StorageStatusMsg

func (*Msg) GetStorageStatusList 

func (m *Msg) GetStorageStatusList() *StorageStatusListMsg

func (*Msg) GoString 

func (this *Msg) GoString() string

func (*Msg) Marshal 

func (m *Msg) Marshal() (dAtA []byte, err error)

func (*Msg) MarshalTo 

func (m *Msg) MarshalTo(dAtA []byte) (int, error)

func (*Msg) MarshalToSizedBuffer 

func (m *Msg) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Msg) ProtoMessage 

func (*Msg) ProtoMessage()

func (*Msg) Reset 

func (m *Msg) Reset()

func (*Msg) Size 

func (m *Msg) Size() (n int)

func (*Msg) String 

func (this *Msg) String() string

func (*Msg) Unmarshal 

func (m *Msg) Unmarshal(dAtA []byte) error

func (*Msg) XXX_DiscardUnknown 

func (m *Msg) XXX_DiscardUnknown()

func (*Msg) XXX_Marshal 

func (m *Msg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Msg) XXX_Merge 

func (m *Msg) XXX_Merge(src proto.Message)

func (*Msg) XXX_Size 

func (m *Msg) XXX_Size() int

func (*Msg) XXX_Unmarshal 

func (m *Msg) XXX_Unmarshal(b []byte) error

type MsgType 

type MsgType int32
const (
	MSG_DATA         MsgType = 0
	MSG_DATA_DEFAULT MsgType = 0
	MSG_DATA_STDOUT  MsgType = 0
	MSG_DATA_METRICS MsgType = 0
	MSG_DATA_STDERR  MsgType = 1
	MSG_DONE         MsgType = 5
	MSG_STATE        MsgType = 6
	MSG_ERROR        MsgType = 7
	// network msgs, protobuf bytes of abbot proto
	MSG_NET MsgType = 10
	// 11-19: node msgs
	MSG_NODE_STATUS MsgType = 11
	// 31-39: credential msgs
	MSG_CRED_STATUS MsgType = 31
	// 41-49: image msgs
	MSG_IMAGE_STATUS      MsgType = 41
	MSG_IMAGE_STATUS_LIST MsgType = 42
	// 51-59: storage msgs
	MSG_STORAGE_STATUS      MsgType = 51
	MSG_STORAGE_STATUS_LIST MsgType = 52
	// 61-69: pod msgs
	MSG_POD_STATUS      MsgType = 61
	MSG_POD_STATUS_LIST MsgType = 62
	// 71-79: peripheral msgs
	MSG_PERIPHERAL_STATUS           MsgType = 71
	MSG_PERIPHERAL_STATUS_LIST      MsgType = 72
	MSG_PERIPHERAL_OPERATION_RESULT MsgType = 73
)

func (MsgType) EnumDescriptor 

func (MsgType) EnumDescriptor() ([]byte, []int)

func (MsgType) String 

func (x MsgType) String() string

type NamedData 

type NamedData struct {
	DataMap map[string][]byte `` /* 170-byte string literal not displayed */
}

func (*NamedData) Descriptor 

func (*NamedData) Descriptor() ([]byte, []int)

func (*NamedData) Equal 

func (this *NamedData) Equal(that interface{}) bool

func (*NamedData) GetDataMap 

func (m *NamedData) GetDataMap() map[string][]byte

func (*NamedData) GoString 

func (this *NamedData) GoString() string

func (*NamedData) Marshal 

func (m *NamedData) Marshal() (dAtA []byte, err error)

func (*NamedData) MarshalTo 

func (m *NamedData) MarshalTo(dAtA []byte) (int, error)

func (*NamedData) MarshalToSizedBuffer 

func (m *NamedData) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*NamedData) ProtoMessage 

func (*NamedData) ProtoMessage()

func (*NamedData) Reset 

func (m *NamedData) Reset()

func (*NamedData) Size 

func (m *NamedData) Size() (n int)

func (*NamedData) String 

func (this *NamedData) String() string

func (*NamedData) Unmarshal 

func (m *NamedData) Unmarshal(dAtA []byte) error

func (*NamedData) XXX_DiscardUnknown 

func (m *NamedData) XXX_DiscardUnknown()

func (*NamedData) XXX_Marshal 

func (m *NamedData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NamedData) XXX_Merge 

func (m *NamedData) XXX_Merge(src proto.Message)

func (*NamedData) XXX_Size 

func (m *NamedData) XXX_Size() int

func (*NamedData) XXX_Unmarshal 

func (m *NamedData) XXX_Unmarshal(b []byte) error

type NetworkCmd 

type NetworkCmd struct {
	// protobuf bytes of abbot proto
	AbbotRequestBytes []byte `protobuf:"bytes,1,opt,name=abbot_request_bytes,json=abbotRequestBytes,proto3" json:"abbot_request_bytes,omitempty"`
}

func (*NetworkCmd) Descriptor 

func (*NetworkCmd) Descriptor() ([]byte, []int)

func (*NetworkCmd) Equal 

func (this *NetworkCmd) Equal(that interface{}) bool

func (*NetworkCmd) GetAbbotRequestBytes 

func (m *NetworkCmd) GetAbbotRequestBytes() []byte

func (*NetworkCmd) GoString 

func (this *NetworkCmd) GoString() string

func (*NetworkCmd) Marshal 

func (m *NetworkCmd) Marshal() (dAtA []byte, err error)

func (*NetworkCmd) MarshalTo 

func (m *NetworkCmd) MarshalTo(dAtA []byte) (int, error)

func (*NetworkCmd) MarshalToSizedBuffer 

func (m *NetworkCmd) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*NetworkCmd) ProtoMessage 

func (*NetworkCmd) ProtoMessage()

func (*NetworkCmd) Reset 

func (m *NetworkCmd) Reset()

func (*NetworkCmd) Size 

func (m *NetworkCmd) Size() (n int)

func (*NetworkCmd) String 

func (this *NetworkCmd) String() string

func (*NetworkCmd) Unmarshal 

func (m *NetworkCmd) Unmarshal(dAtA []byte) error

func (*NetworkCmd) XXX_DiscardUnknown 

func (m *NetworkCmd) XXX_DiscardUnknown()

func (*NetworkCmd) XXX_Marshal 

func (m *NetworkCmd) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NetworkCmd) XXX_Merge 

func (m *NetworkCmd) XXX_Merge(src proto.Message)

func (*NetworkCmd) XXX_Size 

func (m *NetworkCmd) XXX_Size() int

func (*NetworkCmd) XXX_Unmarshal 

func (m *NetworkCmd) XXX_Unmarshal(b []byte) error

type NetworkMsg 

type NetworkMsg struct {
	// protobuf bytes of abbot proto
	AbbotResponseBytes []byte `protobuf:"bytes,1,opt,name=abbot_response_bytes,json=abbotResponseBytes,proto3" json:"abbot_response_bytes,omitempty"`
}

func (*NetworkMsg) Descriptor 

func (*NetworkMsg) Descriptor() ([]byte, []int)

func (*NetworkMsg) Equal 

func (this *NetworkMsg) Equal(that interface{}) bool

func (*NetworkMsg) GetAbbotResponseBytes 

func (m *NetworkMsg) GetAbbotResponseBytes() []byte

func (*NetworkMsg) GoString 

func (this *NetworkMsg) GoString() string

func (*NetworkMsg) Marshal 

func (m *NetworkMsg) Marshal() (dAtA []byte, err error)

func (*NetworkMsg) MarshalTo 

func (m *NetworkMsg) MarshalTo(dAtA []byte) (int, error)

func (*NetworkMsg) MarshalToSizedBuffer 

func (m *NetworkMsg) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*NetworkMsg) ProtoMessage 

func (*NetworkMsg) ProtoMessage()

func (*NetworkMsg) Reset 

func (m *NetworkMsg) Reset()

func (*NetworkMsg) Size 

func (m *NetworkMsg) Size() (n int)

func (*NetworkMsg) String 

func (this *NetworkMsg) String() string

func (*NetworkMsg) Unmarshal 

func (m *NetworkMsg) Unmarshal(dAtA []byte) error

func (*NetworkMsg) XXX_DiscardUnknown 

func (m *NetworkMsg) XXX_DiscardUnknown()

func (*NetworkMsg) XXX_Marshal 

func (m *NetworkMsg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NetworkMsg) XXX_Merge 

func (m *NetworkMsg) XXX_Merge(src proto.Message)

func (*NetworkMsg) XXX_Size 

func (m *NetworkMsg) XXX_Size() int

func (*NetworkMsg) XXX_Unmarshal 

func (m *NetworkMsg) XXX_Unmarshal(b []byte) error

type NodeCondition 

type NodeCondition int32
const (
	NODE_CONDITION_UNKNOWN   NodeCondition = 0
	NODE_CONDITION_HEALTHY   NodeCondition = 1
	NODE_CONDITION_UNHEALTHY NodeCondition = 2
)

func (NodeCondition) EnumDescriptor 

func (NodeCondition) EnumDescriptor() ([]byte, []int)

func (NodeCondition) String 

func (x NodeCondition) String() string

type NodeConditions 

type NodeConditions struct {
	Ready   NodeCondition `protobuf:"varint,1,opt,name=ready,proto3,enum=aranya.NodeCondition" json:"ready,omitempty"`
	Memory  NodeCondition `protobuf:"varint,2,opt,name=memory,proto3,enum=aranya.NodeCondition" json:"memory,omitempty"`
	Disk    NodeCondition `protobuf:"varint,3,opt,name=disk,proto3,enum=aranya.NodeCondition" json:"disk,omitempty"`
	Pid     NodeCondition `protobuf:"varint,4,opt,name=pid,proto3,enum=aranya.NodeCondition" json:"pid,omitempty"`
	Network NodeCondition `protobuf:"varint,5,opt,name=network,proto3,enum=aranya.NodeCondition" json:"network,omitempty"`
	Pod     NodeCondition `protobuf:"varint,6,opt,name=pod,proto3,enum=aranya.NodeCondition" json:"pod,omitempty"`
}

func (*NodeConditions) Descriptor 

func (*NodeConditions) Descriptor() ([]byte, []int)

func (*NodeConditions) Equal 

func (this *NodeConditions) Equal(that interface{}) bool

func (*NodeConditions) GetDisk 

func (m *NodeConditions) GetDisk() NodeCondition

func (*NodeConditions) GetMemory 

func (m *NodeConditions) GetMemory() NodeCondition

func (*NodeConditions) GetNetwork 

func (m *NodeConditions) GetNetwork() NodeCondition

func (*NodeConditions) GetPid 

func (m *NodeConditions) GetPid() NodeCondition

func (*NodeConditions) GetPod 

func (m *NodeConditions) GetPod() NodeCondition

func (*NodeConditions) GetReady 

func (m *NodeConditions) GetReady() NodeCondition

func (*NodeConditions) GoString 

func (this *NodeConditions) GoString() string

func (*NodeConditions) Marshal 

func (m *NodeConditions) Marshal() (dAtA []byte, err error)

func (*NodeConditions) MarshalTo 

func (m *NodeConditions) MarshalTo(dAtA []byte) (int, error)

func (*NodeConditions) MarshalToSizedBuffer 

func (m *NodeConditions) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*NodeConditions) ProtoMessage 

func (*NodeConditions) ProtoMessage()

func (*NodeConditions) Reset 

func (m *NodeConditions) Reset()

func (*NodeConditions) Size 

func (m *NodeConditions) Size() (n int)

func (*NodeConditions) String 

func (this *NodeConditions) String() string

func (*NodeConditions) Unmarshal 

func (m *NodeConditions) Unmarshal(dAtA []byte) error

func (*NodeConditions) XXX_DiscardUnknown 

func (m *NodeConditions) XXX_DiscardUnknown()

func (*NodeConditions) XXX_Marshal 

func (m *NodeConditions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NodeConditions) XXX_Merge 

func (m *NodeConditions) XXX_Merge(src proto.Message)

func (*NodeConditions) XXX_Size 

func (m *NodeConditions) XXX_Size() int

func (*NodeConditions) XXX_Unmarshal 

func (m *NodeConditions) XXX_Unmarshal(b []byte) error

type NodeContainerRuntimeInfo 

type NodeContainerRuntimeInfo struct {
	Name    string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
}

func (*NodeContainerRuntimeInfo) Descriptor 

func (*NodeContainerRuntimeInfo) Descriptor() ([]byte, []int)

func (*NodeContainerRuntimeInfo) Equal 

func (this *NodeContainerRuntimeInfo) Equal(that interface{}) bool

func (*NodeContainerRuntimeInfo) GetName 

func (m *NodeContainerRuntimeInfo) GetName() string

func (*NodeContainerRuntimeInfo) GetVersion 

func (m *NodeContainerRuntimeInfo) GetVersion() string

func (*NodeContainerRuntimeInfo) GoString 

func (this *NodeContainerRuntimeInfo) GoString() string

func (*NodeContainerRuntimeInfo) Marshal 

func (m *NodeContainerRuntimeInfo) Marshal() (dAtA []byte, err error)

func (*NodeContainerRuntimeInfo) MarshalTo 

func (m *NodeContainerRuntimeInfo) MarshalTo(dAtA []byte) (int, error)

func (*NodeContainerRuntimeInfo) MarshalToSizedBuffer 

func (m *NodeContainerRuntimeInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*NodeContainerRuntimeInfo) ProtoMessage 

func (*NodeContainerRuntimeInfo) ProtoMessage()

func (*NodeContainerRuntimeInfo) Reset 

func (m *NodeContainerRuntimeInfo) Reset()

func (*NodeContainerRuntimeInfo) Size 

func (m *NodeContainerRuntimeInfo) Size() (n int)

func (*NodeContainerRuntimeInfo) String 

func (this *NodeContainerRuntimeInfo) String() string

func (*NodeContainerRuntimeInfo) Unmarshal 

func (m *NodeContainerRuntimeInfo) Unmarshal(dAtA []byte) error

func (*NodeContainerRuntimeInfo) XXX_DiscardUnknown 

func (m *NodeContainerRuntimeInfo) XXX_DiscardUnknown()

func (*NodeContainerRuntimeInfo) XXX_Marshal 

func (m *NodeContainerRuntimeInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NodeContainerRuntimeInfo) XXX_Merge 

func (m *NodeContainerRuntimeInfo) XXX_Merge(src proto.Message)

func (*NodeContainerRuntimeInfo) XXX_Size 

func (m *NodeContainerRuntimeInfo) XXX_Size() int

func (*NodeContainerRuntimeInfo) XXX_Unmarshal 

func (m *NodeContainerRuntimeInfo) XXX_Unmarshal(b []byte) error

type NodeExtInfo 

type NodeExtInfo struct {
	// value is always transmitted in string format
	Value string `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// type of the value
	ValueType NodeExtInfo_ValueType `protobuf:"varint,2,opt,name=value_type,json=valueType,proto3,enum=aranya.NodeExtInfo_ValueType" json:"value_type,omitempty"`
	// operator
	Operator  NodeExtInfo_Operator `protobuf:"varint,3,opt,name=operator,proto3,enum=aranya.NodeExtInfo_Operator" json:"operator,omitempty"`
	Target    NodeExtInfo_Target   `protobuf:"varint,4,opt,name=target,proto3,enum=aranya.NodeExtInfo_Target" json:"target,omitempty"`
	TargetKey string               `protobuf:"bytes,5,opt,name=target_key,json=targetKey,proto3" json:"target_key,omitempty"`
}

set extra node information

func (*NodeExtInfo) Descriptor 

func (*NodeExtInfo) Descriptor() ([]byte, []int)

func (*NodeExtInfo) Equal 

func (this *NodeExtInfo) Equal(that interface{}) bool

func (*NodeExtInfo) GetOperator 

func (m *NodeExtInfo) GetOperator() NodeExtInfo_Operator

func (*NodeExtInfo) GetTarget 

func (m *NodeExtInfo) GetTarget() NodeExtInfo_Target

func (*NodeExtInfo) GetTargetKey 

func (m *NodeExtInfo) GetTargetKey() string

func (*NodeExtInfo) GetValue 

func (m *NodeExtInfo) GetValue() string

func (*NodeExtInfo) GetValueType 

func (m *NodeExtInfo) GetValueType() NodeExtInfo_ValueType

func (*NodeExtInfo) GoString 

func (this *NodeExtInfo) GoString() string

func (*NodeExtInfo) Marshal 

func (m *NodeExtInfo) Marshal() (dAtA []byte, err error)

func (*NodeExtInfo) MarshalTo 

func (m *NodeExtInfo) MarshalTo(dAtA []byte) (int, error)

func (*NodeExtInfo) MarshalToSizedBuffer 

func (m *NodeExtInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*NodeExtInfo) ProtoMessage 

func (*NodeExtInfo) ProtoMessage()

func (*NodeExtInfo) Reset 

func (m *NodeExtInfo) Reset()

func (*NodeExtInfo) Size 

func (m *NodeExtInfo) Size() (n int)

func (*NodeExtInfo) String 

func (this *NodeExtInfo) String() string

func (*NodeExtInfo) Unmarshal 

func (m *NodeExtInfo) Unmarshal(dAtA []byte) error

func (*NodeExtInfo) XXX_DiscardUnknown 

func (m *NodeExtInfo) XXX_DiscardUnknown()

func (*NodeExtInfo) XXX_Marshal 

func (m *NodeExtInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NodeExtInfo) XXX_Merge 

func (m *NodeExtInfo) XXX_Merge(src proto.Message)

func (*NodeExtInfo) XXX_Size 

func (m *NodeExtInfo) XXX_Size() int

func (*NodeExtInfo) XXX_Unmarshal 

func (m *NodeExtInfo) XXX_Unmarshal(b []byte) error

type NodeExtInfo_Operator 

type NodeExtInfo_Operator int32
const (
	// no matter what previous value is, set to new value
	NODE_EXT_INFO_OPERATOR_SET NodeExtInfo_Operator = 0
	// only valid for {integer, float}
	NODE_EXT_INFO_OPERATOR_ADD NodeExtInfo_Operator = 1
	// only valid for {integer, float}
	NODE_EXT_INFO_OPERATOR_MINUS NodeExtInfo_Operator = 2
)

func (NodeExtInfo_Operator) EnumDescriptor 

func (NodeExtInfo_Operator) EnumDescriptor() ([]byte, []int)

func (NodeExtInfo_Operator) String 

func (x NodeExtInfo_Operator) String() string

type NodeExtInfo_Target 

type NodeExtInfo_Target int32
const (
	NODE_EXT_INFO_TARGET_ANNOTATION NodeExtInfo_Target = 0
	NODE_EXT_INFO_TARGET_LABEL      NodeExtInfo_Target = 1
)

func (NodeExtInfo_Target) EnumDescriptor 

func (NodeExtInfo_Target) EnumDescriptor() ([]byte, []int)

func (NodeExtInfo_Target) String 

func (x NodeExtInfo_Target) String() string

type NodeExtInfo_ValueType 

type NodeExtInfo_ValueType int32
const (
	NODE_EXT_INFO_TYPE_STRING  NodeExtInfo_ValueType = 0
	NODE_EXT_INFO_TYPE_INTEGER NodeExtInfo_ValueType = 1
	NODE_EXT_INFO_TYPE_FLOAT   NodeExtInfo_ValueType = 2
)

func (NodeExtInfo_ValueType) EnumDescriptor 

func (NodeExtInfo_ValueType) EnumDescriptor() ([]byte, []int)

func (NodeExtInfo_ValueType) String 

func (x NodeExtInfo_ValueType) String() string

type NodeInfoGetCmd 

type NodeInfoGetCmd struct {
	Kind NodeInfoGetCmd_Kind `protobuf:"varint,1,opt,name=kind,proto3,enum=aranya.NodeInfoGetCmd_Kind" json:"kind,omitempty"`
}

func NewNodeCmd 

func NewNodeCmd(k NodeInfoGetCmd_Kind) *NodeInfoGetCmd

func (*NodeInfoGetCmd) Descriptor 

func (*NodeInfoGetCmd) Descriptor() ([]byte, []int)

func (*NodeInfoGetCmd) Equal 

func (this *NodeInfoGetCmd) Equal(that interface{}) bool

func (*NodeInfoGetCmd) GetKind 

func (m *NodeInfoGetCmd) GetKind() NodeInfoGetCmd_Kind

func (*NodeInfoGetCmd) GoString 

func (this *NodeInfoGetCmd) GoString() string

func (*NodeInfoGetCmd) Marshal 

func (m *NodeInfoGetCmd) Marshal() (dAtA []byte, err error)

func (*NodeInfoGetCmd) MarshalTo 

func (m *NodeInfoGetCmd) MarshalTo(dAtA []byte) (int, error)

func (*NodeInfoGetCmd) MarshalToSizedBuffer 

func (m *NodeInfoGetCmd) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*NodeInfoGetCmd) ProtoMessage 

func (*NodeInfoGetCmd) ProtoMessage()

func (*NodeInfoGetCmd) Reset 

func (m *NodeInfoGetCmd) Reset()

func (*NodeInfoGetCmd) Size 

func (m *NodeInfoGetCmd) Size() (n int)

func (*NodeInfoGetCmd) String 

func (this *NodeInfoGetCmd) String() string

func (*NodeInfoGetCmd) Unmarshal 

func (m *NodeInfoGetCmd) Unmarshal(dAtA []byte) error

func (*NodeInfoGetCmd) XXX_DiscardUnknown 

func (m *NodeInfoGetCmd) XXX_DiscardUnknown()

func (*NodeInfoGetCmd) XXX_Marshal 

func (m *NodeInfoGetCmd) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NodeInfoGetCmd) XXX_Merge 

func (m *NodeInfoGetCmd) XXX_Merge(src proto.Message)

func (*NodeInfoGetCmd) XXX_Size 

func (m *NodeInfoGetCmd) XXX_Size() int

func (*NodeInfoGetCmd) XXX_Unmarshal 

func (m *NodeInfoGetCmd) XXX_Unmarshal(b []byte) error

type NodeInfoGetCmd_Kind 

type NodeInfoGetCmd_Kind int32
const (
	NODE_INFO_DYN NodeInfoGetCmd_Kind = 0
	NODE_INFO_ALL NodeInfoGetCmd_Kind = 1
)

func (NodeInfoGetCmd_Kind) EnumDescriptor 

func (NodeInfoGetCmd_Kind) EnumDescriptor() ([]byte, []int)

func (NodeInfoGetCmd_Kind) String 

func (x NodeInfoGetCmd_Kind) String() string

type NodeResources 

type NodeResources struct {
	CpuCount     uint64 `protobuf:"varint,1,opt,name=cpu_count,json=cpuCount,proto3" json:"cpu_count,omitempty"`
	MemoryBytes  uint64 `protobuf:"varint,2,opt,name=memory_bytes,json=memoryBytes,proto3" json:"memory_bytes,omitempty"`
	StorageBytes uint64 `protobuf:"varint,3,opt,name=storage_bytes,json=storageBytes,proto3" json:"storage_bytes,omitempty"`
}

func (*NodeResources) Descriptor 

func (*NodeResources) Descriptor() ([]byte, []int)

func (*NodeResources) Equal 

func (this *NodeResources) Equal(that interface{}) bool

func (*NodeResources) GetCpuCount 

func (m *NodeResources) GetCpuCount() uint64

func (*NodeResources) GetMemoryBytes 

func (m *NodeResources) GetMemoryBytes() uint64

func (*NodeResources) GetStorageBytes 

func (m *NodeResources) GetStorageBytes() uint64

func (*NodeResources) GoString 

func (this *NodeResources) GoString() string

func (*NodeResources) Marshal 

func (m *NodeResources) Marshal() (dAtA []byte, err error)

func (*NodeResources) MarshalTo 

func (m *NodeResources) MarshalTo(dAtA []byte) (int, error)

func (*NodeResources) MarshalToSizedBuffer 

func (m *NodeResources) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*NodeResources) ProtoMessage 

func (*NodeResources) ProtoMessage()

func (*NodeResources) Reset 

func (m *NodeResources) Reset()

func (*NodeResources) Size 

func (m *NodeResources) Size() (n int)

func (*NodeResources) String 

func (this *NodeResources) String() string

func (*NodeResources) Unmarshal 

func (m *NodeResources) Unmarshal(dAtA []byte) error

func (*NodeResources) XXX_DiscardUnknown 

func (m *NodeResources) XXX_DiscardUnknown()

func (*NodeResources) XXX_Marshal 

func (m *NodeResources) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NodeResources) XXX_Merge 

func (m *NodeResources) XXX_Merge(src proto.Message)

func (*NodeResources) XXX_Size 

func (m *NodeResources) XXX_Size() int

func (*NodeResources) XXX_Unmarshal 

func (m *NodeResources) XXX_Unmarshal(b []byte) error

type NodeStatusMsg 

type NodeStatusMsg struct {
	SystemInfo *NodeSystemInfo `protobuf:"bytes,1,opt,name=system_info,json=systemInfo,proto3" json:"system_info,omitempty"`
	Capacity   *NodeResources  `protobuf:"bytes,2,opt,name=capacity,proto3" json:"capacity,omitempty"`
	Conditions *NodeConditions `protobuf:"bytes,3,opt,name=conditions,proto3" json:"conditions,omitempty"`
	ExtInfo    []*NodeExtInfo  `protobuf:"bytes,4,rep,name=ext_info,json=extInfo,proto3" json:"ext_info,omitempty"`
}

func NewNodeStatusMsg 

func NewNodeStatusMsg(
	systemInfo *NodeSystemInfo,
	capacity *NodeResources,
	conditions *NodeConditions,
	extInfo []*NodeExtInfo,
) *NodeStatusMsg

func (*NodeStatusMsg) Descriptor 

func (*NodeStatusMsg) Descriptor() ([]byte, []int)

func (*NodeStatusMsg) Equal 

func (this *NodeStatusMsg) Equal(that interface{}) bool

func (*NodeStatusMsg) GetCapacity 

func (m *NodeStatusMsg) GetCapacity() *NodeResources

func (*NodeStatusMsg) GetConditions 

func (m *NodeStatusMsg) GetConditions() *NodeConditions

func (*NodeStatusMsg) GetExtInfo 

func (m *NodeStatusMsg) GetExtInfo() []*NodeExtInfo

func (*NodeStatusMsg) GetSystemInfo 

func (m *NodeStatusMsg) GetSystemInfo() *NodeSystemInfo

func (*NodeStatusMsg) GoString 

func (this *NodeStatusMsg) GoString() string

func (*NodeStatusMsg) Marshal 

func (m *NodeStatusMsg) Marshal() (dAtA []byte, err error)

func (*NodeStatusMsg) MarshalTo 

func (m *NodeStatusMsg) MarshalTo(dAtA []byte) (int, error)

func (*NodeStatusMsg) MarshalToSizedBuffer 

func (m *NodeStatusMsg) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*NodeStatusMsg) ProtoMessage 

func (*NodeStatusMsg) ProtoMessage()

func (*NodeStatusMsg) Reset 

func (m *NodeStatusMsg) Reset()

func (*NodeStatusMsg) Size 

func (m *NodeStatusMsg) Size() (n int)

func (*NodeStatusMsg) String 

func (this *NodeStatusMsg) String() string

func (*NodeStatusMsg) Unmarshal 

func (m *NodeStatusMsg) Unmarshal(dAtA []byte) error

func (*NodeStatusMsg) XXX_DiscardUnknown 

func (m *NodeStatusMsg) XXX_DiscardUnknown()

func (*NodeStatusMsg) XXX_Marshal 

func (m *NodeStatusMsg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NodeStatusMsg) XXX_Merge 

func (m *NodeStatusMsg) XXX_Merge(src proto.Message)

func (*NodeStatusMsg) XXX_Size 

func (m *NodeStatusMsg) XXX_Size() int

func (*NodeStatusMsg) XXX_Unmarshal 

func (m *NodeStatusMsg) XXX_Unmarshal(b []byte) error

type NodeSystemInfo 

type NodeSystemInfo struct {
	Os            string                    `protobuf:"bytes,1,opt,name=os,proto3" json:"os,omitempty"`
	OsImage       string                    `protobuf:"bytes,2,opt,name=os_image,json=osImage,proto3" json:"os_image,omitempty"`
	Arch          string                    `protobuf:"bytes,3,opt,name=arch,proto3" json:"arch,omitempty"`
	KernelVersion string                    `protobuf:"bytes,4,opt,name=kernel_version,json=kernelVersion,proto3" json:"kernel_version,omitempty"`
	BootId        string                    `protobuf:"bytes,5,opt,name=boot_id,json=bootId,proto3" json:"boot_id,omitempty"`
	MachineId     string                    `protobuf:"bytes,6,opt,name=machine_id,json=machineId,proto3" json:"machine_id,omitempty"`
	SystemUuid    string                    `protobuf:"bytes,7,opt,name=system_uuid,json=systemUuid,proto3" json:"system_uuid,omitempty"`
	RuntimeInfo   *NodeContainerRuntimeInfo `protobuf:"bytes,11,opt,name=runtime_info,json=runtimeInfo,proto3" json:"runtime_info,omitempty"`
}

func (*NodeSystemInfo) Descriptor 

func (*NodeSystemInfo) Descriptor() ([]byte, []int)

func (*NodeSystemInfo) Equal 

func (this *NodeSystemInfo) Equal(that interface{}) bool

func (*NodeSystemInfo) GetArch 

func (m *NodeSystemInfo) GetArch() string

func (*NodeSystemInfo) GetBootId 

func (m *NodeSystemInfo) GetBootId() string

func (*NodeSystemInfo) GetKernelVersion 

func (m *NodeSystemInfo) GetKernelVersion() string

func (*NodeSystemInfo) GetMachineId 

func (m *NodeSystemInfo) GetMachineId() string

func (*NodeSystemInfo) GetOs 

func (m *NodeSystemInfo) GetOs() string

func (*NodeSystemInfo) GetOsImage 

func (m *NodeSystemInfo) GetOsImage() string

func (*NodeSystemInfo) GetRuntimeInfo 

func (m *NodeSystemInfo) GetRuntimeInfo() *NodeContainerRuntimeInfo

func (*NodeSystemInfo) GetSystemUuid 

func (m *NodeSystemInfo) GetSystemUuid() string

func (*NodeSystemInfo) GoString 

func (this *NodeSystemInfo) GoString() string

func (*NodeSystemInfo) Marshal 

func (m *NodeSystemInfo) Marshal() (dAtA []byte, err error)

func (*NodeSystemInfo) MarshalTo 

func (m *NodeSystemInfo) MarshalTo(dAtA []byte) (int, error)

func (*NodeSystemInfo) MarshalToSizedBuffer 

func (m *NodeSystemInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*NodeSystemInfo) ProtoMessage 

func (*NodeSystemInfo) ProtoMessage()

func (*NodeSystemInfo) Reset 

func (m *NodeSystemInfo) Reset()

func (*NodeSystemInfo) Size 

func (m *NodeSystemInfo) Size() (n int)

func (*NodeSystemInfo) String 

func (this *NodeSystemInfo) String() string

func (*NodeSystemInfo) Unmarshal 

func (m *NodeSystemInfo) Unmarshal(dAtA []byte) error

func (*NodeSystemInfo) XXX_DiscardUnknown 

func (m *NodeSystemInfo) XXX_DiscardUnknown()

func (*NodeSystemInfo) XXX_Marshal 

func (m *NodeSystemInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NodeSystemInfo) XXX_Merge 

func (m *NodeSystemInfo) XXX_Merge(src proto.Message)

func (*NodeSystemInfo) XXX_Size 

func (m *NodeSystemInfo) XXX_Size() int

func (*NodeSystemInfo) XXX_Unmarshal 

func (m *NodeSystemInfo) XXX_Unmarshal(b []byte) error

type PeripheralDeleteCmd 

type PeripheralDeleteCmd struct {
	// delete normal peripherals or metrics reporters
	PeripheralNames []string `protobuf:"bytes,1,rep,name=peripheral_names,json=peripheralNames,proto3" json:"peripheral_names,omitempty"`
}

func NewPeripheralDeleteCmd 

func NewPeripheralDeleteCmd(names ...string) *PeripheralDeleteCmd

func (*PeripheralDeleteCmd) Descriptor 

func (*PeripheralDeleteCmd) Descriptor() ([]byte, []int)

func (*PeripheralDeleteCmd) Equal 

func (this *PeripheralDeleteCmd) Equal(that interface{}) bool

func (*PeripheralDeleteCmd) GetPeripheralNames 

func (m *PeripheralDeleteCmd) GetPeripheralNames() []string

func (*PeripheralDeleteCmd) GoString 

func (this *PeripheralDeleteCmd) GoString() string

func (*PeripheralDeleteCmd) Marshal 

func (m *PeripheralDeleteCmd) Marshal() (dAtA []byte, err error)

func (*PeripheralDeleteCmd) MarshalTo 

func (m *PeripheralDeleteCmd) MarshalTo(dAtA []byte) (int, error)

func (*PeripheralDeleteCmd) MarshalToSizedBuffer 

func (m *PeripheralDeleteCmd) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PeripheralDeleteCmd) ProtoMessage 

func (*PeripheralDeleteCmd) ProtoMessage()

func (*PeripheralDeleteCmd) Reset 

func (m *PeripheralDeleteCmd) Reset()

func (*PeripheralDeleteCmd) Size 

func (m *PeripheralDeleteCmd) Size() (n int)

func (*PeripheralDeleteCmd) String 

func (this *PeripheralDeleteCmd) String() string

func (*PeripheralDeleteCmd) Unmarshal 

func (m *PeripheralDeleteCmd) Unmarshal(dAtA []byte) error

func (*PeripheralDeleteCmd) XXX_DiscardUnknown 

func (m *PeripheralDeleteCmd) XXX_DiscardUnknown()

func (*PeripheralDeleteCmd) XXX_Marshal 

func (m *PeripheralDeleteCmd) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PeripheralDeleteCmd) XXX_Merge 

func (m *PeripheralDeleteCmd) XXX_Merge(src proto.Message)

func (*PeripheralDeleteCmd) XXX_Size 

func (m *PeripheralDeleteCmd) XXX_Size() int

func (*PeripheralDeleteCmd) XXX_Unmarshal 

func (m *PeripheralDeleteCmd) XXX_Unmarshal(b []byte) error

type PeripheralEnsureCmd 

type PeripheralEnsureCmd struct {
	Kind PeripheralType `protobuf:"varint,1,opt,name=kind,proto3,enum=aranya.PeripheralType" json:"kind,omitempty"`
	// (required) User defined peripheral name
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// (required) Connector defines how to connect to the peripheral, operations operate
	// upon this connector
	Connector *Connectivity `protobuf:"bytes,3,opt,name=connector,proto3" json:"connector,omitempty"`
	// (optional) User defined peripheral operations
	Operations []*PeripheralOperation `protobuf:"bytes,4,rep,name=operations,proto3" json:"operations,omitempty"`
	// (optional) User defined peripheral metrics
	Metrics []*PeripheralMetric `protobuf:"bytes,5,rep,name=metrics,proto3" json:"metrics,omitempty"`
}

func NewPeripheralEnsureCmd 

func NewPeripheralEnsureCmd(
	kind PeripheralType,
	name string,
	connector *Connectivity,
	operations []*PeripheralOperation,
	metrics []*PeripheralMetric,
) *PeripheralEnsureCmd

func (*PeripheralEnsureCmd) Descriptor 

func (*PeripheralEnsureCmd) Descriptor() ([]byte, []int)

func (*PeripheralEnsureCmd) Equal 

func (this *PeripheralEnsureCmd) Equal(that interface{}) bool

func (*PeripheralEnsureCmd) GetConnector 

func (m *PeripheralEnsureCmd) GetConnector() *Connectivity

func (*PeripheralEnsureCmd) GetKind 

func (m *PeripheralEnsureCmd) GetKind() PeripheralType

func (*PeripheralEnsureCmd) GetMetrics 

func (m *PeripheralEnsureCmd) GetMetrics() []*PeripheralMetric

func (*PeripheralEnsureCmd) GetName 

func (m *PeripheralEnsureCmd) GetName() string

func (*PeripheralEnsureCmd) GetOperations 

func (m *PeripheralEnsureCmd) GetOperations() []*PeripheralOperation

func (*PeripheralEnsureCmd) GoString 

func (this *PeripheralEnsureCmd) GoString() string

func (*PeripheralEnsureCmd) Marshal 

func (m *PeripheralEnsureCmd) Marshal() (dAtA []byte, err error)

func (*PeripheralEnsureCmd) MarshalTo 

func (m *PeripheralEnsureCmd) MarshalTo(dAtA []byte) (int, error)

func (*PeripheralEnsureCmd) MarshalToSizedBuffer 

func (m *PeripheralEnsureCmd) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PeripheralEnsureCmd) ProtoMessage 

func (*PeripheralEnsureCmd) ProtoMessage()

func (*PeripheralEnsureCmd) Reset 

func (m *PeripheralEnsureCmd) Reset()

func (*PeripheralEnsureCmd) Size 

func (m *PeripheralEnsureCmd) Size() (n int)

func (*PeripheralEnsureCmd) String 

func (this *PeripheralEnsureCmd) String() string

func (*PeripheralEnsureCmd) Unmarshal 

func (m *PeripheralEnsureCmd) Unmarshal(dAtA []byte) error

func (*PeripheralEnsureCmd) XXX_DiscardUnknown 

func (m *PeripheralEnsureCmd) XXX_DiscardUnknown()

func (*PeripheralEnsureCmd) XXX_Marshal 

func (m *PeripheralEnsureCmd) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PeripheralEnsureCmd) XXX_Merge 

func (m *PeripheralEnsureCmd) XXX_Merge(src proto.Message)

func (*PeripheralEnsureCmd) XXX_Size 

func (m *PeripheralEnsureCmd) XXX_Size() int

func (*PeripheralEnsureCmd) XXX_Unmarshal 

func (m *PeripheralEnsureCmd) XXX_Unmarshal(b []byte) error

type PeripheralListCmd 

type PeripheralListCmd struct {
	PeripheralNames []string `protobuf:"bytes,1,rep,name=peripheral_names,json=peripheralNames,proto3" json:"peripheral_names,omitempty"`
}

func NewPeripheralListCmd 

func NewPeripheralListCmd(names ...string) *PeripheralListCmd

func (*PeripheralListCmd) Descriptor 

func (*PeripheralListCmd) Descriptor() ([]byte, []int)

func (*PeripheralListCmd) Equal 

func (this *PeripheralListCmd) Equal(that interface{}) bool

func (*PeripheralListCmd) GetPeripheralNames 

func (m *PeripheralListCmd) GetPeripheralNames() []string

func (*PeripheralListCmd) GoString 

func (this *PeripheralListCmd) GoString() string

func (*PeripheralListCmd) Marshal 

func (m *PeripheralListCmd) Marshal() (dAtA []byte, err error)

func (*PeripheralListCmd) MarshalTo 

func (m *PeripheralListCmd) MarshalTo(dAtA []byte) (int, error)

func (*PeripheralListCmd) MarshalToSizedBuffer 

func (m *PeripheralListCmd) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PeripheralListCmd) ProtoMessage 

func (*PeripheralListCmd) ProtoMessage()

func (*PeripheralListCmd) Reset 

func (m *PeripheralListCmd) Reset()

func (*PeripheralListCmd) Size 

func (m *PeripheralListCmd) Size() (n int)

func (*PeripheralListCmd) String 

func (this *PeripheralListCmd) String() string

func (*PeripheralListCmd) Unmarshal 

func (m *PeripheralListCmd) Unmarshal(dAtA []byte) error

func (*PeripheralListCmd) XXX_DiscardUnknown 

func (m *PeripheralListCmd) XXX_DiscardUnknown()

func (*PeripheralListCmd) XXX_Marshal 

func (m *PeripheralListCmd) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PeripheralListCmd) XXX_Merge 

func (m *PeripheralListCmd) XXX_Merge(src proto.Message)

func (*PeripheralListCmd) XXX_Size 

func (m *PeripheralListCmd) XXX_Size() int

func (*PeripheralListCmd) XXX_Unmarshal 

func (m *PeripheralListCmd) XXX_Unmarshal(b []byte) error

type PeripheralMetric 

type PeripheralMetric struct {
	// Name of this metric
	Name         string                        `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	ReportMethod PeripheralMetric_ReportMethod `` /* 140-byte string literal not displayed */
	ValueType    PeripheralMetric_ValueType    `` /* 128-byte string literal not displayed */
	// (required) params for peripheral connector to retrieve metrics
	PeripheralParams map[string]string `` /* 197-byte string literal not displayed */
	// Hex encoded hash of the metrics reporter
	ReporterName string `protobuf:"bytes,5,opt,name=reporter_name,json=reporterName,proto3" json:"reporter_name,omitempty"`
	// (optional) params for metrics_reporter to upload metrics
	ReporterParams map[string]string `` /* 191-byte string literal not displayed */
}

func (*PeripheralMetric) Descriptor 

func (*PeripheralMetric) Descriptor() ([]byte, []int)

func (*PeripheralMetric) Equal 

func (this *PeripheralMetric) Equal(that interface{}) bool

func (*PeripheralMetric) GetName 

func (m *PeripheralMetric) GetName() string

func (*PeripheralMetric) GetPeripheralParams 

func (m *PeripheralMetric) GetPeripheralParams() map[string]string

func (*PeripheralMetric) GetReportMethod 

func (m *PeripheralMetric) GetReportMethod() PeripheralMetric_ReportMethod

func (*PeripheralMetric) GetReporterName 

func (m *PeripheralMetric) GetReporterName() string

func (*PeripheralMetric) GetReporterParams 

func (m *PeripheralMetric) GetReporterParams() map[string]string

func (*PeripheralMetric) GetValueType 

func (m *PeripheralMetric) GetValueType() PeripheralMetric_ValueType

func (*PeripheralMetric) GoString 

func (this *PeripheralMetric) GoString() string

func (*PeripheralMetric) Marshal 

func (m *PeripheralMetric) Marshal() (dAtA []byte, err error)

func (*PeripheralMetric) MarshalTo 

func (m *PeripheralMetric) MarshalTo(dAtA []byte) (int, error)

func (*PeripheralMetric) MarshalToSizedBuffer 

func (m *PeripheralMetric) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PeripheralMetric) ProtoMessage 

func (*PeripheralMetric) ProtoMessage()

func (*PeripheralMetric) Reset 

func (m *PeripheralMetric) Reset()

func (*PeripheralMetric) Size 

func (m *PeripheralMetric) Size() (n int)

func (*PeripheralMetric) String 

func (this *PeripheralMetric) String() string

func (*PeripheralMetric) Unmarshal 

func (m *PeripheralMetric) Unmarshal(dAtA []byte) error

func (*PeripheralMetric) XXX_DiscardUnknown 

func (m *PeripheralMetric) XXX_DiscardUnknown()

func (*PeripheralMetric) XXX_Marshal 

func (m *PeripheralMetric) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PeripheralMetric) XXX_Merge 

func (m *PeripheralMetric) XXX_Merge(src proto.Message)

func (*PeripheralMetric) XXX_Size 

func (m *PeripheralMetric) XXX_Size() int

func (*PeripheralMetric) XXX_Unmarshal 

func (m *PeripheralMetric) XXX_Unmarshal(b []byte) error

type PeripheralMetric_ReportMethod 

type PeripheralMetric_ReportMethod int32
const (
	// Report peripheral metrics when collecting node metrics
	REPORT_WITH_NODE_METRICS PeripheralMetric_ReportMethod = 0
	// Report peripheral metrics along with arhat client
	REPORT_WITH_ARHAT_CONNECTIVITY PeripheralMetric_ReportMethod = 1
	// Create a standalone client for metrics uploading
	REPORT_WITH_STANDALONE_CLIENT PeripheralMetric_ReportMethod = 2
)

func (PeripheralMetric_ReportMethod) EnumDescriptor 

func (PeripheralMetric_ReportMethod) EnumDescriptor() ([]byte, []int)

func (PeripheralMetric_ReportMethod) String 

func (x PeripheralMetric_ReportMethod) String() string

type PeripheralMetric_ValueType 

type PeripheralMetric_ValueType int32
const (
	METRICS_VALUE_TYPE_UNTYPED PeripheralMetric_ValueType = 0
	METRICS_VALUE_TYPE_COUNTER PeripheralMetric_ValueType = 1
	METRICS_VALUE_TYPE_GAUGE   PeripheralMetric_ValueType = 2
)

func (PeripheralMetric_ValueType) EnumDescriptor 

func (PeripheralMetric_ValueType) EnumDescriptor() ([]byte, []int)

func (PeripheralMetric_ValueType) String 

func (x PeripheralMetric_ValueType) String() string

type PeripheralMetricsCollectCmd 

type PeripheralMetricsCollectCmd struct {
	PeripheralNames []string `protobuf:"bytes,2,rep,name=peripheral_names,json=peripheralNames,proto3" json:"peripheral_names,omitempty"`
}

func NewPeripheralMetricsCollectCmd 

func NewPeripheralMetricsCollectCmd(names ...string) *PeripheralMetricsCollectCmd

func (*PeripheralMetricsCollectCmd) Descriptor 

func (*PeripheralMetricsCollectCmd) Descriptor() ([]byte, []int)

func (*PeripheralMetricsCollectCmd) Equal 

func (this *PeripheralMetricsCollectCmd) Equal(that interface{}) bool

func (*PeripheralMetricsCollectCmd) GetPeripheralNames 

func (m *PeripheralMetricsCollectCmd) GetPeripheralNames() []string

func (*PeripheralMetricsCollectCmd) GoString 

func (this *PeripheralMetricsCollectCmd) GoString() string

func (*PeripheralMetricsCollectCmd) Marshal 

func (m *PeripheralMetricsCollectCmd) Marshal() (dAtA []byte, err error)

func (*PeripheralMetricsCollectCmd) MarshalTo 

func (m *PeripheralMetricsCollectCmd) MarshalTo(dAtA []byte) (int, error)

func (*PeripheralMetricsCollectCmd) MarshalToSizedBuffer 

func (m *PeripheralMetricsCollectCmd) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PeripheralMetricsCollectCmd) ProtoMessage 

func (*PeripheralMetricsCollectCmd) ProtoMessage()

func (*PeripheralMetricsCollectCmd) Reset 

func (m *PeripheralMetricsCollectCmd) Reset()

func (*PeripheralMetricsCollectCmd) Size 

func (m *PeripheralMetricsCollectCmd) Size() (n int)

func (*PeripheralMetricsCollectCmd) String 

func (this *PeripheralMetricsCollectCmd) String() string

func (*PeripheralMetricsCollectCmd) Unmarshal 

func (m *PeripheralMetricsCollectCmd) Unmarshal(dAtA []byte) error

func (*PeripheralMetricsCollectCmd) XXX_DiscardUnknown 

func (m *PeripheralMetricsCollectCmd) XXX_DiscardUnknown()

func (*PeripheralMetricsCollectCmd) XXX_Marshal 

func (m *PeripheralMetricsCollectCmd) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PeripheralMetricsCollectCmd) XXX_Merge 

func (m *PeripheralMetricsCollectCmd) XXX_Merge(src proto.Message)

func (*PeripheralMetricsCollectCmd) XXX_Size 

func (m *PeripheralMetricsCollectCmd) XXX_Size() int

func (*PeripheralMetricsCollectCmd) XXX_Unmarshal 

func (m *PeripheralMetricsCollectCmd) XXX_Unmarshal(b []byte) error

type PeripheralOperateCmd 

type PeripheralOperateCmd struct {
	// (required) peripheral id of a normal peripheral
	PeripheralName string `protobuf:"bytes,1,opt,name=peripheral_name,json=peripheralName,proto3" json:"peripheral_name,omitempty"`
	// (required) identifier of this operation
	OperationId string `protobuf:"bytes,2,opt,name=operation_id,json=operationId,proto3" json:"operation_id,omitempty"`
	// (optional) extra data for this operation
	Data []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
}

func NewPeripheralOperateCmd 

func NewPeripheralOperateCmd(peripheralName, operationID string, data []byte) *PeripheralOperateCmd

func (*PeripheralOperateCmd) Descriptor 

func (*PeripheralOperateCmd) Descriptor() ([]byte, []int)

func (*PeripheralOperateCmd) Equal 

func (this *PeripheralOperateCmd) Equal(that interface{}) bool

func (*PeripheralOperateCmd) GetData 

func (m *PeripheralOperateCmd) GetData() []byte

func (*PeripheralOperateCmd) GetOperationId 

func (m *PeripheralOperateCmd) GetOperationId() string

func (*PeripheralOperateCmd) GetPeripheralName 

func (m *PeripheralOperateCmd) GetPeripheralName() string

func (*PeripheralOperateCmd) GoString 

func (this *PeripheralOperateCmd) GoString() string

func (*PeripheralOperateCmd) Marshal 

func (m *PeripheralOperateCmd) Marshal() (dAtA []byte, err error)

func (*PeripheralOperateCmd) MarshalTo 

func (m *PeripheralOperateCmd) MarshalTo(dAtA []byte) (int, error)

func (*PeripheralOperateCmd) MarshalToSizedBuffer 

func (m *PeripheralOperateCmd) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PeripheralOperateCmd) ProtoMessage 

func (*PeripheralOperateCmd) ProtoMessage()

func (*PeripheralOperateCmd) Reset 

func (m *PeripheralOperateCmd) Reset()

func (*PeripheralOperateCmd) Size 

func (m *PeripheralOperateCmd) Size() (n int)

func (*PeripheralOperateCmd) String 

func (this *PeripheralOperateCmd) String() string

func (*PeripheralOperateCmd) Unmarshal 

func (m *PeripheralOperateCmd) Unmarshal(dAtA []byte) error

func (*PeripheralOperateCmd) XXX_DiscardUnknown 

func (m *PeripheralOperateCmd) XXX_DiscardUnknown()

func (*PeripheralOperateCmd) XXX_Marshal 

func (m *PeripheralOperateCmd) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PeripheralOperateCmd) XXX_Merge 

func (m *PeripheralOperateCmd) XXX_Merge(src proto.Message)

func (*PeripheralOperateCmd) XXX_Size 

func (m *PeripheralOperateCmd) XXX_Size() int

func (*PeripheralOperateCmd) XXX_Unmarshal 

func (m *PeripheralOperateCmd) XXX_Unmarshal(b []byte) error

type PeripheralOperation 

type PeripheralOperation struct {
	// (required) identifier of this operation
	OperationId string `protobuf:"bytes,1,opt,name=operation_id,json=operationId,proto3" json:"operation_id,omitempty"`
	// (optional) params usd for peripheral connectivity when executing this
	// operation
	Params map[string]string `` /* 153-byte string literal not displayed */
}

func (*PeripheralOperation) Descriptor 

func (*PeripheralOperation) Descriptor() ([]byte, []int)

func (*PeripheralOperation) Equal 

func (this *PeripheralOperation) Equal(that interface{}) bool

func (*PeripheralOperation) GetOperationId 

func (m *PeripheralOperation) GetOperationId() string

func (*PeripheralOperation) GetParams 

func (m *PeripheralOperation) GetParams() map[string]string

func (*PeripheralOperation) GoString 

func (this *PeripheralOperation) GoString() string

func (*PeripheralOperation) Marshal 

func (m *PeripheralOperation) Marshal() (dAtA []byte, err error)

func (*PeripheralOperation) MarshalTo 

func (m *PeripheralOperation) MarshalTo(dAtA []byte) (int, error)

func (*PeripheralOperation) MarshalToSizedBuffer 

func (m *PeripheralOperation) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PeripheralOperation) ProtoMessage 

func (*PeripheralOperation) ProtoMessage()

func (*PeripheralOperation) Reset 

func (m *PeripheralOperation) Reset()

func (*PeripheralOperation) Size 

func (m *PeripheralOperation) Size() (n int)

func (*PeripheralOperation) String 

func (this *PeripheralOperation) String() string

func (*PeripheralOperation) Unmarshal 

func (m *PeripheralOperation) Unmarshal(dAtA []byte) error

func (*PeripheralOperation) XXX_DiscardUnknown 

func (m *PeripheralOperation) XXX_DiscardUnknown()

func (*PeripheralOperation) XXX_Marshal 

func (m *PeripheralOperation) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PeripheralOperation) XXX_Merge 

func (m *PeripheralOperation) XXX_Merge(src proto.Message)

func (*PeripheralOperation) XXX_Size 

func (m *PeripheralOperation) XXX_Size() int

func (*PeripheralOperation) XXX_Unmarshal 

func (m *PeripheralOperation) XXX_Unmarshal(b []byte) error

type PeripheralOperationResultMsg 

type PeripheralOperationResultMsg struct {
	Data [][]byte `protobuf:"bytes,1,rep,name=data,proto3" json:"data,omitempty"`
}

func NewPeripheralOperationResultMsg 

func NewPeripheralOperationResultMsg(result [][]byte) *PeripheralOperationResultMsg

func (*PeripheralOperationResultMsg) Descriptor 

func (*PeripheralOperationResultMsg) Descriptor() ([]byte, []int)

func (*PeripheralOperationResultMsg) Equal 

func (this *PeripheralOperationResultMsg) Equal(that interface{}) bool

func (*PeripheralOperationResultMsg) GetData 

func (m *PeripheralOperationResultMsg) GetData() [][]byte

func (*PeripheralOperationResultMsg) GoString 

func (this *PeripheralOperationResultMsg) GoString() string

func (*PeripheralOperationResultMsg) Marshal 

func (m *PeripheralOperationResultMsg) Marshal() (dAtA []byte, err error)

func (*PeripheralOperationResultMsg) MarshalTo 

func (m *PeripheralOperationResultMsg) MarshalTo(dAtA []byte) (int, error)

func (*PeripheralOperationResultMsg) MarshalToSizedBuffer 

func (m *PeripheralOperationResultMsg) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PeripheralOperationResultMsg) ProtoMessage 

func (*PeripheralOperationResultMsg) ProtoMessage()

func (*PeripheralOperationResultMsg) Reset 

func (m *PeripheralOperationResultMsg) Reset()

func (*PeripheralOperationResultMsg) Size 

func (m *PeripheralOperationResultMsg) Size() (n int)

func (*PeripheralOperationResultMsg) String 

func (this *PeripheralOperationResultMsg) String() string

func (*PeripheralOperationResultMsg) Unmarshal 

func (m *PeripheralOperationResultMsg) Unmarshal(dAtA []byte) error

func (*PeripheralOperationResultMsg) XXX_DiscardUnknown 

func (m *PeripheralOperationResultMsg) XXX_DiscardUnknown()

func (*PeripheralOperationResultMsg) XXX_Marshal 

func (m *PeripheralOperationResultMsg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PeripheralOperationResultMsg) XXX_Merge 

func (m *PeripheralOperationResultMsg) XXX_Merge(src proto.Message)

func (*PeripheralOperationResultMsg) XXX_Size 

func (m *PeripheralOperationResultMsg) XXX_Size() int

func (*PeripheralOperationResultMsg) XXX_Unmarshal 

func (m *PeripheralOperationResultMsg) XXX_Unmarshal(b []byte) error

type PeripheralState 

type PeripheralState int32
const (
	PERIPHERAL_STATE_UNKNOWN   PeripheralState = 0
	PERIPHERAL_STATE_CREATED   PeripheralState = 1
	PERIPHERAL_STATE_CONNECTED PeripheralState = 2
	PERIPHERAL_STATE_ERRORED   PeripheralState = 3
	PERIPHERAL_STATE_REMOVED   PeripheralState = 4
)

func (PeripheralState) EnumDescriptor 

func (PeripheralState) EnumDescriptor() ([]byte, []int)

func (PeripheralState) String 

func (x PeripheralState) String() string

type PeripheralStatusListMsg 

type PeripheralStatusListMsg struct {
	Peripherals []*PeripheralStatusMsg `protobuf:"bytes,1,rep,name=peripherals,proto3" json:"peripherals,omitempty"`
}

func NewPeripheralStatusListMsg 

func NewPeripheralStatusListMsg(peripherals []*PeripheralStatusMsg) *PeripheralStatusListMsg

func (*PeripheralStatusListMsg) Descriptor 

func (*PeripheralStatusListMsg) Descriptor() ([]byte, []int)

func (*PeripheralStatusListMsg) Equal 

func (this *PeripheralStatusListMsg) Equal(that interface{}) bool

func (*PeripheralStatusListMsg) GetPeripherals 

func (m *PeripheralStatusListMsg) GetPeripherals() []*PeripheralStatusMsg

func (*PeripheralStatusListMsg) GoString 

func (this *PeripheralStatusListMsg) GoString() string

func (*PeripheralStatusListMsg) Marshal 

func (m *PeripheralStatusListMsg) Marshal() (dAtA []byte, err error)

func (*PeripheralStatusListMsg) MarshalTo 

func (m *PeripheralStatusListMsg) MarshalTo(dAtA []byte) (int, error)

func (*PeripheralStatusListMsg) MarshalToSizedBuffer 

func (m *PeripheralStatusListMsg) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PeripheralStatusListMsg) ProtoMessage 

func (*PeripheralStatusListMsg) ProtoMessage()

func (*PeripheralStatusListMsg) Reset 

func (m *PeripheralStatusListMsg) Reset()

func (*PeripheralStatusListMsg) Size 

func (m *PeripheralStatusListMsg) Size() (n int)

func (*PeripheralStatusListMsg) String 

func (this *PeripheralStatusListMsg) String() string

func (*PeripheralStatusListMsg) Unmarshal 

func (m *PeripheralStatusListMsg) Unmarshal(dAtA []byte) error

func (*PeripheralStatusListMsg) XXX_DiscardUnknown 

func (m *PeripheralStatusListMsg) XXX_DiscardUnknown()

func (*PeripheralStatusListMsg) XXX_Marshal 

func (m *PeripheralStatusListMsg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PeripheralStatusListMsg) XXX_Merge 

func (m *PeripheralStatusListMsg) XXX_Merge(src proto.Message)

func (*PeripheralStatusListMsg) XXX_Size 

func (m *PeripheralStatusListMsg) XXX_Size() int

func (*PeripheralStatusListMsg) XXX_Unmarshal 

func (m *PeripheralStatusListMsg) XXX_Unmarshal(b []byte) error

type PeripheralStatusMsg 

type PeripheralStatusMsg struct {
	Kind  PeripheralType  `protobuf:"varint,1,opt,name=kind,proto3,enum=aranya.PeripheralType" json:"kind,omitempty"`
	Name  string          `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	State PeripheralState `protobuf:"varint,3,opt,name=state,proto3,enum=aranya.PeripheralState" json:"state,omitempty"`
	// Human readable description for this state
	Message string `protobuf:"bytes,4,opt,name=message,proto3" json:"message,omitempty"`
}

func NewPeripheralStatusMsg 

func NewPeripheralStatusMsg(
	kind PeripheralType,
	name string,
	state PeripheralState,
	msg string,
) *PeripheralStatusMsg

func (*PeripheralStatusMsg) Descriptor 

func (*PeripheralStatusMsg) Descriptor() ([]byte, []int)

func (*PeripheralStatusMsg) Equal 

func (this *PeripheralStatusMsg) Equal(that interface{}) bool

func (*PeripheralStatusMsg) GetKind 

func (m *PeripheralStatusMsg) GetKind() PeripheralType

func (*PeripheralStatusMsg) GetMessage 

func (m *PeripheralStatusMsg) GetMessage() string

func (*PeripheralStatusMsg) GetName 

func (m *PeripheralStatusMsg) GetName() string

func (*PeripheralStatusMsg) GetState 

func (m *PeripheralStatusMsg) GetState() PeripheralState

func (*PeripheralStatusMsg) GoString 

func (this *PeripheralStatusMsg) GoString() string

func (*PeripheralStatusMsg) Marshal 

func (m *PeripheralStatusMsg) Marshal() (dAtA []byte, err error)

func (*PeripheralStatusMsg) MarshalTo 

func (m *PeripheralStatusMsg) MarshalTo(dAtA []byte) (int, error)

func (*PeripheralStatusMsg) MarshalToSizedBuffer 

func (m *PeripheralStatusMsg) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PeripheralStatusMsg) ProtoMessage 

func (*PeripheralStatusMsg) ProtoMessage()

func (*PeripheralStatusMsg) Reset 

func (m *PeripheralStatusMsg) Reset()

func (*PeripheralStatusMsg) Size 

func (m *PeripheralStatusMsg) Size() (n int)

func (*PeripheralStatusMsg) String 

func (this *PeripheralStatusMsg) String() string

func (*PeripheralStatusMsg) Unmarshal 

func (m *PeripheralStatusMsg) Unmarshal(dAtA []byte) error

func (*PeripheralStatusMsg) XXX_DiscardUnknown 

func (m *PeripheralStatusMsg) XXX_DiscardUnknown()

func (*PeripheralStatusMsg) XXX_Marshal 

func (m *PeripheralStatusMsg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PeripheralStatusMsg) XXX_Merge 

func (m *PeripheralStatusMsg) XXX_Merge(src proto.Message)

func (*PeripheralStatusMsg) XXX_Size 

func (m *PeripheralStatusMsg) XXX_Size() int

func (*PeripheralStatusMsg) XXX_Unmarshal 

func (m *PeripheralStatusMsg) XXX_Unmarshal(b []byte) error

type PeripheralType 

type PeripheralType int32
const (

	// a normal peripheral for physical operations (e.g. sensor, cam)
	PERIPHERAL_TYPE_NORMAL PeripheralType = 1
	// a reporter peripheral is used to report metrics
	PERIPHERAL_TYPE_METRICS_REPORTER PeripheralType = 2
)

func (PeripheralType) EnumDescriptor 

func (PeripheralType) EnumDescriptor() ([]byte, []int)

func (PeripheralType) String 

func (x PeripheralType) String() string

type PodDeleteCmd 

type PodDeleteCmd struct {
	// pod to perform delete operation
	PodUid string `protobuf:"bytes,1,opt,name=pod_uid,json=podUid,proto3" json:"pod_uid,omitempty"`
	// containers to delete, if not specified, delete this pod
	Containers []string `protobuf:"bytes,2,rep,name=containers,proto3" json:"containers,omitempty"`
	// pod deletion grace time
	GraceTime int64 `protobuf:"varint,10,opt,name=grace_time,json=graceTime,proto3" json:"grace_time,omitempty"`
	// key: container name
	// value:
	HookPreStop map[string]*ContainerAction `` /* 185-byte string literal not displayed */
}

func NewPodContainerDeleteCmd 

func NewPodContainerDeleteCmd(podUID string, containers []string) *PodDeleteCmd

func NewPodDeleteCmd 

func NewPodDeleteCmd(podUID string, graceTime time.Duration, preStopHooks map[string]*ContainerAction) *PodDeleteCmd

func (*PodDeleteCmd) Descriptor 

func (*PodDeleteCmd) Descriptor() ([]byte, []int)

func (*PodDeleteCmd) Equal 

func (this *PodDeleteCmd) Equal(that interface{}) bool

func (*PodDeleteCmd) GetContainers 

func (m *PodDeleteCmd) GetContainers() []string

func (*PodDeleteCmd) GetGraceTime 

func (m *PodDeleteCmd) GetGraceTime() int64

func (*PodDeleteCmd) GetHookPreStop 

func (m *PodDeleteCmd) GetHookPreStop() map[string]*ContainerAction

func (*PodDeleteCmd) GetPodUid 

func (m *PodDeleteCmd) GetPodUid() string

func (*PodDeleteCmd) GoString 

func (this *PodDeleteCmd) GoString() string

func (*PodDeleteCmd) Marshal 

func (m *PodDeleteCmd) Marshal() (dAtA []byte, err error)

func (*PodDeleteCmd) MarshalTo 

func (m *PodDeleteCmd) MarshalTo(dAtA []byte) (int, error)

func (*PodDeleteCmd) MarshalToSizedBuffer 

func (m *PodDeleteCmd) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PodDeleteCmd) ProtoMessage 

func (*PodDeleteCmd) ProtoMessage()

func (*PodDeleteCmd) Reset 

func (m *PodDeleteCmd) Reset()

func (*PodDeleteCmd) Size 

func (m *PodDeleteCmd) Size() (n int)

func (*PodDeleteCmd) String 

func (this *PodDeleteCmd) String() string

func (*PodDeleteCmd) Unmarshal 

func (m *PodDeleteCmd) Unmarshal(dAtA []byte) error

func (*PodDeleteCmd) XXX_DiscardUnknown 

func (m *PodDeleteCmd) XXX_DiscardUnknown()

func (*PodDeleteCmd) XXX_Marshal 

func (m *PodDeleteCmd) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PodDeleteCmd) XXX_Merge 

func (m *PodDeleteCmd) XXX_Merge(src proto.Message)

func (*PodDeleteCmd) XXX_Size 

func (m *PodDeleteCmd) XXX_Size() int

func (*PodDeleteCmd) XXX_Unmarshal 

func (m *PodDeleteCmd) XXX_Unmarshal(b []byte) error

type PodEnsureCmd 

type PodEnsureCmd struct {
	// kubernetes metadata
	PodUid        string        `protobuf:"bytes,1,opt,name=pod_uid,json=podUid,proto3" json:"pod_uid,omitempty"`
	Namespace     string        `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Name          string        `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	RestartPolicy RestartPolicy `` /* 127-byte string literal not displayed */
	//
	// Relationships to host namespaces
	//
	HostIpc     bool `protobuf:"varint,5,opt,name=host_ipc,json=hostIpc,proto3" json:"host_ipc,omitempty"`
	HostNetwork bool `protobuf:"varint,6,opt,name=host_network,json=hostNetwork,proto3" json:"host_network,omitempty"`
	HostPid     bool `protobuf:"varint,7,opt,name=host_pid,json=hostPid,proto3" json:"host_pid,omitempty"`
	// share pid namespace between containers in the same pod
	SharePid bool `protobuf:"varint,8,opt,name=share_pid,json=sharePid,proto3" json:"share_pid,omitempty"`
	// wait unitl all containers defined in this cmd exited with no error
	Wait bool `protobuf:"varint,9,opt,name=wait,proto3" json:"wait,omitempty"`
	// custom hostname to override pod name as hostname
	Hostname   string            `protobuf:"bytes,10,opt,name=hostname,proto3" json:"hostname,omitempty"`
	Containers []*ContainerSpec  `protobuf:"bytes,11,rep,name=containers,proto3" json:"containers,omitempty"`
	Network    *PodNetworkSpec   `protobuf:"bytes,12,opt,name=network,proto3" json:"network,omitempty"`
	Volumes    *PodVolumeSpec    `protobuf:"bytes,13,opt,name=volumes,proto3" json:"volumes,omitempty"`
	Security   *PodSecuritySpec  `protobuf:"bytes,14,opt,name=security,proto3" json:"security,omitempty"`
	Labels     map[string]string `` /* 154-byte string literal not displayed */
}

func (*PodEnsureCmd) Descriptor 

func (*PodEnsureCmd) Descriptor() ([]byte, []int)

func (*PodEnsureCmd) Equal 

func (this *PodEnsureCmd) Equal(that interface{}) bool

func (*PodEnsureCmd) GetContainers 

func (m *PodEnsureCmd) GetContainers() []*ContainerSpec

func (*PodEnsureCmd) GetHostIpc 

func (m *PodEnsureCmd) GetHostIpc() bool

func (*PodEnsureCmd) GetHostNetwork 

func (m *PodEnsureCmd) GetHostNetwork() bool

func (*PodEnsureCmd) GetHostPid 

func (m *PodEnsureCmd) GetHostPid() bool

func (*PodEnsureCmd) GetHostname 

func (m *PodEnsureCmd) GetHostname() string

func (*PodEnsureCmd) GetLabels 

func (m *PodEnsureCmd) GetLabels() map[string]string

func (*PodEnsureCmd) GetName 

func (m *PodEnsureCmd) GetName() string

func (*PodEnsureCmd) GetNamespace 

func (m *PodEnsureCmd) GetNamespace() string

func (*PodEnsureCmd) GetNetwork 

func (m *PodEnsureCmd) GetNetwork() *PodNetworkSpec

func (*PodEnsureCmd) GetPodUid 

func (m *PodEnsureCmd) GetPodUid() string

func (*PodEnsureCmd) GetRestartPolicy 

func (m *PodEnsureCmd) GetRestartPolicy() RestartPolicy

func (*PodEnsureCmd) GetSecurity 

func (m *PodEnsureCmd) GetSecurity() *PodSecuritySpec

func (*PodEnsureCmd) GetSharePid 

func (m *PodEnsureCmd) GetSharePid() bool

func (*PodEnsureCmd) GetVolumes 

func (m *PodEnsureCmd) GetVolumes() *PodVolumeSpec

func (*PodEnsureCmd) GetWait 

func (m *PodEnsureCmd) GetWait() bool

func (*PodEnsureCmd) GoString 

func (this *PodEnsureCmd) GoString() string

func (*PodEnsureCmd) Marshal 

func (m *PodEnsureCmd) Marshal() (dAtA []byte, err error)

func (*PodEnsureCmd) MarshalTo 

func (m *PodEnsureCmd) MarshalTo(dAtA []byte) (int, error)

func (*PodEnsureCmd) MarshalToSizedBuffer 

func (m *PodEnsureCmd) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PodEnsureCmd) ProtoMessage 

func (*PodEnsureCmd) ProtoMessage()

func (*PodEnsureCmd) Reset 

func (m *PodEnsureCmd) Reset()

func (*PodEnsureCmd) Size 

func (m *PodEnsureCmd) Size() (n int)

func (*PodEnsureCmd) String 

func (this *PodEnsureCmd) String() string

func (*PodEnsureCmd) Unmarshal 

func (m *PodEnsureCmd) Unmarshal(dAtA []byte) error

func (*PodEnsureCmd) XXX_DiscardUnknown 

func (m *PodEnsureCmd) XXX_DiscardUnknown()

func (*PodEnsureCmd) XXX_Marshal 

func (m *PodEnsureCmd) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PodEnsureCmd) XXX_Merge 

func (m *PodEnsureCmd) XXX_Merge(src proto.Message)

func (*PodEnsureCmd) XXX_Size 

func (m *PodEnsureCmd) XXX_Size() int

func (*PodEnsureCmd) XXX_Unmarshal 

func (m *PodEnsureCmd) XXX_Unmarshal(b []byte) error

type PodListCmd 

type PodListCmd struct {
	// show all pods available
	All bool `protobuf:"varint,1,opt,name=all,proto3" json:"all,omitempty"`
	// pod names filter
	Names []string `protobuf:"bytes,2,rep,name=names,proto3" json:"names,omitempty"`
}

func NewPodListCmd 

func NewPodListCmd(all bool, names ...string) *PodListCmd

func (*PodListCmd) Descriptor 

func (*PodListCmd) Descriptor() ([]byte, []int)

func (*PodListCmd) Equal 

func (this *PodListCmd) Equal(that interface{}) bool

func (*PodListCmd) GetAll 

func (m *PodListCmd) GetAll() bool

func (*PodListCmd) GetNames 

func (m *PodListCmd) GetNames() []string

func (*PodListCmd) GoString 

func (this *PodListCmd) GoString() string

func (*PodListCmd) Marshal 

func (m *PodListCmd) Marshal() (dAtA []byte, err error)

func (*PodListCmd) MarshalTo 

func (m *PodListCmd) MarshalTo(dAtA []byte) (int, error)

func (*PodListCmd) MarshalToSizedBuffer 

func (m *PodListCmd) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PodListCmd) ProtoMessage 

func (*PodListCmd) ProtoMessage()

func (*PodListCmd) Reset 

func (m *PodListCmd) Reset()

func (*PodListCmd) Size 

func (m *PodListCmd) Size() (n int)

func (*PodListCmd) String 

func (this *PodListCmd) String() string

func (*PodListCmd) Unmarshal 

func (m *PodListCmd) Unmarshal(dAtA []byte) error

func (*PodListCmd) XXX_DiscardUnknown 

func (m *PodListCmd) XXX_DiscardUnknown()

func (*PodListCmd) XXX_Marshal 

func (m *PodListCmd) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PodListCmd) XXX_Merge 

func (m *PodListCmd) XXX_Merge(src proto.Message)

func (*PodListCmd) XXX_Size 

func (m *PodListCmd) XXX_Size() int

func (*PodListCmd) XXX_Unmarshal 

func (m *PodListCmd) XXX_Unmarshal(b []byte) error

type PodNetworkSpec 

type PodNetworkSpec struct {
	Nameservers []string `protobuf:"bytes,1,rep,name=nameservers,proto3" json:"nameservers,omitempty"`
	DnsSearches []string `protobuf:"bytes,2,rep,name=dns_searches,json=dnsSearches,proto3" json:"dns_searches,omitempty"`
	DnsOptions  []string `protobuf:"bytes,3,rep,name=dns_options,json=dnsOptions,proto3" json:"dns_options,omitempty"`
	// key: ip
	// value: space separated domain names (e.g. `example.com example.org`)
	Hosts map[string]string `` /* 151-byte string literal not displayed */
	// protobuf bytes of abbot proto
	AbbotRequestBytes []byte `protobuf:"bytes,11,opt,name=abbot_request_bytes,json=abbotRequestBytes,proto3" json:"abbot_request_bytes,omitempty"`
}

func (*PodNetworkSpec) Descriptor 

func (*PodNetworkSpec) Descriptor() ([]byte, []int)

func (*PodNetworkSpec) Equal 

func (this *PodNetworkSpec) Equal(that interface{}) bool

func (*PodNetworkSpec) GetAbbotRequestBytes 

func (m *PodNetworkSpec) GetAbbotRequestBytes() []byte

func (*PodNetworkSpec) GetDnsOptions 

func (m *PodNetworkSpec) GetDnsOptions() []string

func (*PodNetworkSpec) GetDnsSearches 

func (m *PodNetworkSpec) GetDnsSearches() []string

func (*PodNetworkSpec) GetHosts 

func (m *PodNetworkSpec) GetHosts() map[string]string

func (*PodNetworkSpec) GetNameservers 

func (m *PodNetworkSpec) GetNameservers() []string

func (*PodNetworkSpec) GoString 

func (this *PodNetworkSpec) GoString() string

func (*PodNetworkSpec) Marshal 

func (m *PodNetworkSpec) Marshal() (dAtA []byte, err error)

func (*PodNetworkSpec) MarshalTo 

func (m *PodNetworkSpec) MarshalTo(dAtA []byte) (int, error)

func (*PodNetworkSpec) MarshalToSizedBuffer 

func (m *PodNetworkSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PodNetworkSpec) ProtoMessage 

func (*PodNetworkSpec) ProtoMessage()

func (*PodNetworkSpec) Reset 

func (m *PodNetworkSpec) Reset()

func (*PodNetworkSpec) Size 

func (m *PodNetworkSpec) Size() (n int)

func (*PodNetworkSpec) String 

func (this *PodNetworkSpec) String() string

func (*PodNetworkSpec) Unmarshal 

func (m *PodNetworkSpec) Unmarshal(dAtA []byte) error

func (*PodNetworkSpec) XXX_DiscardUnknown 

func (m *PodNetworkSpec) XXX_DiscardUnknown()

func (*PodNetworkSpec) XXX_Marshal 

func (m *PodNetworkSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PodNetworkSpec) XXX_Merge 

func (m *PodNetworkSpec) XXX_Merge(src proto.Message)

func (*PodNetworkSpec) XXX_Size 

func (m *PodNetworkSpec) XXX_Size() int

func (*PodNetworkSpec) XXX_Unmarshal 

func (m *PodNetworkSpec) XXX_Unmarshal(b []byte) error

type PodSecuritySpec 

type PodSecuritySpec struct {
	// key:
	// value:
	Sysctls map[string]string `` /* 156-byte string literal not displayed */
}

func (*PodSecuritySpec) Descriptor 

func (*PodSecuritySpec) Descriptor() ([]byte, []int)

func (*PodSecuritySpec) Equal 

func (this *PodSecuritySpec) Equal(that interface{}) bool

func (*PodSecuritySpec) GetSysctls 

func (m *PodSecuritySpec) GetSysctls() map[string]string

func (*PodSecuritySpec) GoString 

func (this *PodSecuritySpec) GoString() string

func (*PodSecuritySpec) Marshal 

func (m *PodSecuritySpec) Marshal() (dAtA []byte, err error)

func (*PodSecuritySpec) MarshalTo 

func (m *PodSecuritySpec) MarshalTo(dAtA []byte) (int, error)

func (*PodSecuritySpec) MarshalToSizedBuffer 

func (m *PodSecuritySpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PodSecuritySpec) ProtoMessage 

func (*PodSecuritySpec) ProtoMessage()

func (*PodSecuritySpec) Reset 

func (m *PodSecuritySpec) Reset()

func (*PodSecuritySpec) Size 

func (m *PodSecuritySpec) Size() (n int)

func (*PodSecuritySpec) String 

func (this *PodSecuritySpec) String() string

func (*PodSecuritySpec) Unmarshal 

func (m *PodSecuritySpec) Unmarshal(dAtA []byte) error

func (*PodSecuritySpec) XXX_DiscardUnknown 

func (m *PodSecuritySpec) XXX_DiscardUnknown()

func (*PodSecuritySpec) XXX_Marshal 

func (m *PodSecuritySpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PodSecuritySpec) XXX_Merge 

func (m *PodSecuritySpec) XXX_Merge(src proto.Message)

func (*PodSecuritySpec) XXX_Size 

func (m *PodSecuritySpec) XXX_Size() int

func (*PodSecuritySpec) XXX_Unmarshal 

func (m *PodSecuritySpec) XXX_Unmarshal(b []byte) error

type PodState 

type PodState int32
const (
	POD_STATE_UNKNOWN   PodState = 0
	POD_STATE_PENDING   PodState = 1
	POD_STATE_RUNNING   PodState = 2
	POD_STATE_SUCCEEDED PodState = 3
	POD_STATE_FAILED    PodState = 4
)

func (PodState) EnumDescriptor 

func (PodState) EnumDescriptor() ([]byte, []int)

func (PodState) String 

func (x PodState) String() string

type PodStatusListMsg 

type PodStatusListMsg struct {
	Pods []*PodStatusMsg `protobuf:"bytes,1,rep,name=pods,proto3" json:"pods,omitempty"`
}

func NewPodStatusListMsg 

func NewPodStatusListMsg(pods []*PodStatusMsg) *PodStatusListMsg

func (*PodStatusListMsg) Descriptor 

func (*PodStatusListMsg) Descriptor() ([]byte, []int)

func (*PodStatusListMsg) Equal 

func (this *PodStatusListMsg) Equal(that interface{}) bool

func (*PodStatusListMsg) GetPods 

func (m *PodStatusListMsg) GetPods() []*PodStatusMsg

func (*PodStatusListMsg) GoString 

func (this *PodStatusListMsg) GoString() string

func (*PodStatusListMsg) Marshal 

func (m *PodStatusListMsg) Marshal() (dAtA []byte, err error)

func (*PodStatusListMsg) MarshalTo 

func (m *PodStatusListMsg) MarshalTo(dAtA []byte) (int, error)

func (*PodStatusListMsg) MarshalToSizedBuffer 

func (m *PodStatusListMsg) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PodStatusListMsg) ProtoMessage 

func (*PodStatusListMsg) ProtoMessage()

func (*PodStatusListMsg) Reset 

func (m *PodStatusListMsg) Reset()

func (*PodStatusListMsg) Size 

func (m *PodStatusListMsg) Size() (n int)

func (*PodStatusListMsg) String 

func (this *PodStatusListMsg) String() string

func (*PodStatusListMsg) Unmarshal 

func (m *PodStatusListMsg) Unmarshal(dAtA []byte) error

func (*PodStatusListMsg) XXX_DiscardUnknown 

func (m *PodStatusListMsg) XXX_DiscardUnknown()

func (*PodStatusListMsg) XXX_Marshal 

func (m *PodStatusListMsg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PodStatusListMsg) XXX_Merge 

func (m *PodStatusListMsg) XXX_Merge(src proto.Message)

func (*PodStatusListMsg) XXX_Size 

func (m *PodStatusListMsg) XXX_Size() int

func (*PodStatusListMsg) XXX_Unmarshal 

func (m *PodStatusListMsg) XXX_Unmarshal(b []byte) error

type PodStatusMsg 

type PodStatusMsg struct {
	// metadata
	Uid string `protobuf:"bytes,1,opt,name=uid,proto3" json:"uid,omitempty"`
	// pod network status, protobuf bytes of abbot proto
	Network []byte `protobuf:"bytes,2,opt,name=network,proto3" json:"network,omitempty"`
	// status
	Containers map[string]*ContainerStatus `` /* 161-byte string literal not displayed */
}

func NewPodStatusMsg 

func NewPodStatusMsg(podUID string, network []byte, containerStatus map[string]*ContainerStatus) *PodStatusMsg

func (*PodStatusMsg) Descriptor 

func (*PodStatusMsg) Descriptor() ([]byte, []int)

func (*PodStatusMsg) Equal 

func (this *PodStatusMsg) Equal(that interface{}) bool

func (*PodStatusMsg) GetContainers 

func (m *PodStatusMsg) GetContainers() map[string]*ContainerStatus

func (*PodStatusMsg) GetNetwork 

func (m *PodStatusMsg) GetNetwork() []byte

func (*PodStatusMsg) GetUid 

func (m *PodStatusMsg) GetUid() string

func (*PodStatusMsg) GoString 

func (this *PodStatusMsg) GoString() string

func (*PodStatusMsg) Marshal 

func (m *PodStatusMsg) Marshal() (dAtA []byte, err error)

func (*PodStatusMsg) MarshalTo 

func (m *PodStatusMsg) MarshalTo(dAtA []byte) (int, error)

func (*PodStatusMsg) MarshalToSizedBuffer 

func (m *PodStatusMsg) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PodStatusMsg) ProtoMessage 

func (*PodStatusMsg) ProtoMessage()

func (*PodStatusMsg) Reset 

func (m *PodStatusMsg) Reset()

func (*PodStatusMsg) Size 

func (m *PodStatusMsg) Size() (n int)

func (*PodStatusMsg) String 

func (this *PodStatusMsg) String() string

func (*PodStatusMsg) Unmarshal 

func (m *PodStatusMsg) Unmarshal(dAtA []byte) error

func (*PodStatusMsg) XXX_DiscardUnknown 

func (m *PodStatusMsg) XXX_DiscardUnknown()

func (*PodStatusMsg) XXX_Marshal 

func (m *PodStatusMsg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PodStatusMsg) XXX_Merge 

func (m *PodStatusMsg) XXX_Merge(src proto.Message)

func (*PodStatusMsg) XXX_Size 

func (m *PodStatusMsg) XXX_Size() int

func (*PodStatusMsg) XXX_Unmarshal 

func (m *PodStatusMsg) XXX_Unmarshal(b []byte) error

type PodVolumeSpec 

type PodVolumeSpec struct {
	// Volumes and devices' host path
	//
	// key: volume or device name
	// value: host path
	HostPaths map[string]string `` /* 177-byte string literal not displayed */
	// Data to populate files in container
	//
	// key: volume name
	// value: data from {ConfigMap, Secret}
	VolumeData map[string]*NamedData `` /* 180-byte string literal not displayed */
}

func (*PodVolumeSpec) Descriptor 

func (*PodVolumeSpec) Descriptor() ([]byte, []int)

func (*PodVolumeSpec) Equal 

func (this *PodVolumeSpec) Equal(that interface{}) bool

func (*PodVolumeSpec) GetHostPaths 

func (m *PodVolumeSpec) GetHostPaths() map[string]string

func (*PodVolumeSpec) GetVolumeData 

func (m *PodVolumeSpec) GetVolumeData() map[string]*NamedData

func (*PodVolumeSpec) GoString 

func (this *PodVolumeSpec) GoString() string

func (*PodVolumeSpec) Marshal 

func (m *PodVolumeSpec) Marshal() (dAtA []byte, err error)

func (*PodVolumeSpec) MarshalTo 

func (m *PodVolumeSpec) MarshalTo(dAtA []byte) (int, error)

func (*PodVolumeSpec) MarshalToSizedBuffer 

func (m *PodVolumeSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PodVolumeSpec) ProtoMessage 

func (*PodVolumeSpec) ProtoMessage()

func (*PodVolumeSpec) Reset 

func (m *PodVolumeSpec) Reset()

func (*PodVolumeSpec) Size 

func (m *PodVolumeSpec) Size() (n int)

func (*PodVolumeSpec) String 

func (this *PodVolumeSpec) String() string

func (*PodVolumeSpec) Unmarshal 

func (m *PodVolumeSpec) Unmarshal(dAtA []byte) error

func (*PodVolumeSpec) XXX_DiscardUnknown 

func (m *PodVolumeSpec) XXX_DiscardUnknown()

func (*PodVolumeSpec) XXX_Marshal 

func (m *PodVolumeSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PodVolumeSpec) XXX_Merge 

func (m *PodVolumeSpec) XXX_Merge(src proto.Message)

func (*PodVolumeSpec) XXX_Size 

func (m *PodVolumeSpec) XXX_Size() int

func (*PodVolumeSpec) XXX_Unmarshal 

func (m *PodVolumeSpec) XXX_Unmarshal(b []byte) error

type PortForwardCmd 

type PortForwardCmd struct {
	PodUid   string `protobuf:"bytes,1,opt,name=pod_uid,json=podUid,proto3" json:"pod_uid,omitempty"`
	Port     int32  `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"`
	Protocol string `protobuf:"bytes,3,opt,name=protocol,proto3" json:"protocol,omitempty"`
}

func NewPortForwardCmd 

func NewPortForwardCmd(podUID string, port int32, protocol string) *PortForwardCmd

func (*PortForwardCmd) Descriptor 

func (*PortForwardCmd) Descriptor() ([]byte, []int)

func (*PortForwardCmd) Equal 

func (this *PortForwardCmd) Equal(that interface{}) bool

func (*PortForwardCmd) GetPodUid 

func (m *PortForwardCmd) GetPodUid() string

func (*PortForwardCmd) GetPort 

func (m *PortForwardCmd) GetPort() int32

func (*PortForwardCmd) GetProtocol 

func (m *PortForwardCmd) GetProtocol() string

func (*PortForwardCmd) GoString 

func (this *PortForwardCmd) GoString() string

func (*PortForwardCmd) Marshal 

func (m *PortForwardCmd) Marshal() (dAtA []byte, err error)

func (*PortForwardCmd) MarshalTo 

func (m *PortForwardCmd) MarshalTo(dAtA []byte) (int, error)

func (*PortForwardCmd) MarshalToSizedBuffer 

func (m *PortForwardCmd) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PortForwardCmd) ProtoMessage 

func (*PortForwardCmd) ProtoMessage()

func (*PortForwardCmd) Reset 

func (m *PortForwardCmd) Reset()

func (*PortForwardCmd) Size 

func (m *PortForwardCmd) Size() (n int)

func (*PortForwardCmd) String 

func (this *PortForwardCmd) String() string

func (*PortForwardCmd) Unmarshal 

func (m *PortForwardCmd) Unmarshal(dAtA []byte) error

func (*PortForwardCmd) XXX_DiscardUnknown 

func (m *PortForwardCmd) XXX_DiscardUnknown()

func (*PortForwardCmd) XXX_Marshal 

func (m *PortForwardCmd) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PortForwardCmd) XXX_Merge 

func (m *PortForwardCmd) XXX_Merge(src proto.Message)

func (*PortForwardCmd) XXX_Size 

func (m *PortForwardCmd) XXX_Size() int

func (*PortForwardCmd) XXX_Unmarshal 

func (m *PortForwardCmd) XXX_Unmarshal(b []byte) error

type RejectCmd 

type RejectCmd struct {
	Reason  RejectionReason `protobuf:"varint,1,opt,name=reason,proto3,enum=aranya.RejectionReason" json:"reason,omitempty"`
	Message string          `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
}

func NewRejectCmd 

func NewRejectCmd(reason RejectionReason, message string) *RejectCmd

func (*RejectCmd) Descriptor 

func (*RejectCmd) Descriptor() ([]byte, []int)

func (*RejectCmd) Equal 

func (this *RejectCmd) Equal(that interface{}) bool

func (*RejectCmd) GetMessage 

func (m *RejectCmd) GetMessage() string

func (*RejectCmd) GetReason 

func (m *RejectCmd) GetReason() RejectionReason

func (*RejectCmd) GoString 

func (this *RejectCmd) GoString() string

func (*RejectCmd) Marshal 

func (m *RejectCmd) Marshal() (dAtA []byte, err error)

func (*RejectCmd) MarshalTo 

func (m *RejectCmd) MarshalTo(dAtA []byte) (int, error)

func (*RejectCmd) MarshalToSizedBuffer 

func (m *RejectCmd) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RejectCmd) ProtoMessage 

func (*RejectCmd) ProtoMessage()

func (*RejectCmd) Reset 

func (m *RejectCmd) Reset()

func (*RejectCmd) Size 

func (m *RejectCmd) Size() (n int)

func (*RejectCmd) String 

func (this *RejectCmd) String() string

func (*RejectCmd) Unmarshal 

func (m *RejectCmd) Unmarshal(dAtA []byte) error

func (*RejectCmd) XXX_DiscardUnknown 

func (m *RejectCmd) XXX_DiscardUnknown()

func (*RejectCmd) XXX_Marshal 

func (m *RejectCmd) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RejectCmd) XXX_Merge 

func (m *RejectCmd) XXX_Merge(src proto.Message)

func (*RejectCmd) XXX_Size 

func (m *RejectCmd) XXX_Size() int

func (*RejectCmd) XXX_Unmarshal 

func (m *RejectCmd) XXX_Unmarshal(b []byte) error

type RejectionReason 

type RejectionReason int32
const (
	REJECTION_INVALID_PROTO         RejectionReason = 1
	REJECTION_ALREADY_CONNECTED     RejectionReason = 2
	REJECTION_INITIAL_CHECK_FAILURE RejectionReason = 3
	REJECTION_INTERNAL_SERVER_ERROR RejectionReason = 4
)

func (RejectionReason) EnumDescriptor 

func (RejectionReason) EnumDescriptor() ([]byte, []int)

func (RejectionReason) String 

func (x RejectionReason) String() string

type RestartPolicy 

type RestartPolicy int32
const (
	RESTART_ALWAYS     RestartPolicy = 0
	RESTART_ON_FAILURE RestartPolicy = 1
	RESTART_NEVER      RestartPolicy = 2
)

func (RestartPolicy) EnumDescriptor 

func (RestartPolicy) EnumDescriptor() ([]byte, []int)

func (RestartPolicy) String 

func (x RestartPolicy) String() string

type SELinuxOptions 

type SELinuxOptions struct {
	Type  string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	Level string `protobuf:"bytes,2,opt,name=level,proto3" json:"level,omitempty"`
	Role  string `protobuf:"bytes,3,opt,name=role,proto3" json:"role,omitempty"`
	User  string `protobuf:"bytes,4,opt,name=user,proto3" json:"user,omitempty"`
}

func (*SELinuxOptions) Descriptor 

func (*SELinuxOptions) Descriptor() ([]byte, []int)

func (*SELinuxOptions) Equal 

func (this *SELinuxOptions) Equal(that interface{}) bool

func (*SELinuxOptions) GetLevel 

func (m *SELinuxOptions) GetLevel() string

func (*SELinuxOptions) GetRole 

func (m *SELinuxOptions) GetRole() string

func (*SELinuxOptions) GetType 

func (m *SELinuxOptions) GetType() string

func (*SELinuxOptions) GetUser 

func (m *SELinuxOptions) GetUser() string

func (*SELinuxOptions) GoString 

func (this *SELinuxOptions) GoString() string

func (*SELinuxOptions) Marshal 

func (m *SELinuxOptions) Marshal() (dAtA []byte, err error)

func (*SELinuxOptions) MarshalTo 

func (m *SELinuxOptions) MarshalTo(dAtA []byte) (int, error)

func (*SELinuxOptions) MarshalToSizedBuffer 

func (m *SELinuxOptions) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SELinuxOptions) ProtoMessage 

func (*SELinuxOptions) ProtoMessage()

func (*SELinuxOptions) Reset 

func (m *SELinuxOptions) Reset()

func (*SELinuxOptions) Size 

func (m *SELinuxOptions) Size() (n int)

func (*SELinuxOptions) String 

func (this *SELinuxOptions) String() string

func (*SELinuxOptions) Unmarshal 

func (m *SELinuxOptions) Unmarshal(dAtA []byte) error

func (*SELinuxOptions) XXX_DiscardUnknown 

func (m *SELinuxOptions) XXX_DiscardUnknown()

func (*SELinuxOptions) XXX_Marshal 

func (m *SELinuxOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SELinuxOptions) XXX_Merge 

func (m *SELinuxOptions) XXX_Merge(src proto.Message)

func (*SELinuxOptions) XXX_Size 

func (m *SELinuxOptions) XXX_Size() int

func (*SELinuxOptions) XXX_Unmarshal 

func (m *SELinuxOptions) XXX_Unmarshal(b []byte) error

type SessionCloseCmd 

type SessionCloseCmd struct {
	Sid uint64 `protobuf:"varint,1,opt,name=sid,proto3" json:"sid,omitempty"`
}

func NewSessionCloseCmd 

func NewSessionCloseCmd(sessionToClose uint64) *SessionCloseCmd

func (*SessionCloseCmd) Descriptor 

func (*SessionCloseCmd) Descriptor() ([]byte, []int)

func (*SessionCloseCmd) Equal 

func (this *SessionCloseCmd) Equal(that interface{}) bool

func (*SessionCloseCmd) GetSid 

func (m *SessionCloseCmd) GetSid() uint64

func (*SessionCloseCmd) GoString 

func (this *SessionCloseCmd) GoString() string

func (*SessionCloseCmd) Marshal 

func (m *SessionCloseCmd) Marshal() (dAtA []byte, err error)

func (*SessionCloseCmd) MarshalTo 

func (m *SessionCloseCmd) MarshalTo(dAtA []byte) (int, error)

func (*SessionCloseCmd) MarshalToSizedBuffer 

func (m *SessionCloseCmd) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SessionCloseCmd) ProtoMessage 

func (*SessionCloseCmd) ProtoMessage()

func (*SessionCloseCmd) Reset 

func (m *SessionCloseCmd) Reset()

func (*SessionCloseCmd) Size 

func (m *SessionCloseCmd) Size() (n int)

func (*SessionCloseCmd) String 

func (this *SessionCloseCmd) String() string

func (*SessionCloseCmd) Unmarshal 

func (m *SessionCloseCmd) Unmarshal(dAtA []byte) error

func (*SessionCloseCmd) XXX_DiscardUnknown 

func (m *SessionCloseCmd) XXX_DiscardUnknown()

func (*SessionCloseCmd) XXX_Marshal 

func (m *SessionCloseCmd) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SessionCloseCmd) XXX_Merge 

func (m *SessionCloseCmd) XXX_Merge(src proto.Message)

func (*SessionCloseCmd) XXX_Size 

func (m *SessionCloseCmd) XXX_Size() int

func (*SessionCloseCmd) XXX_Unmarshal 

func (m *SessionCloseCmd) XXX_Unmarshal(b []byte) error

type StateMsg 

type StateMsg struct {
	Kind     StateMsg_Kind `protobuf:"varint,1,opt,name=kind,proto3,enum=aranya.StateMsg_Kind" json:"kind,omitempty"`
	DeviceId string        `protobuf:"bytes,2,opt,name=device_id,json=deviceId,proto3" json:"device_id,omitempty"`
}

State of agent, online/offline

func NewOfflineStateMsg 

func NewOfflineStateMsg(id string) *StateMsg

func NewOnlineStateMsg 

func NewOnlineStateMsg(id string) *StateMsg

func (*StateMsg) Descriptor 

func (*StateMsg) Descriptor() ([]byte, []int)

func (*StateMsg) Equal 

func (this *StateMsg) Equal(that interface{}) bool

func (*StateMsg) GetDeviceId 

func (m *StateMsg) GetDeviceId() string

func (*StateMsg) GetKind 

func (m *StateMsg) GetKind() StateMsg_Kind

func (*StateMsg) GoString 

func (this *StateMsg) GoString() string

func (*StateMsg) Marshal 

func (m *StateMsg) Marshal() (dAtA []byte, err error)

func (*StateMsg) MarshalTo 

func (m *StateMsg) MarshalTo(dAtA []byte) (int, error)

func (*StateMsg) MarshalToSizedBuffer 

func (m *StateMsg) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*StateMsg) ProtoMessage 

func (*StateMsg) ProtoMessage()

func (*StateMsg) Reset 

func (m *StateMsg) Reset()

func (*StateMsg) Size 

func (m *StateMsg) Size() (n int)

func (*StateMsg) String 

func (this *StateMsg) String() string

func (*StateMsg) Unmarshal 

func (m *StateMsg) Unmarshal(dAtA []byte) error

func (*StateMsg) XXX_DiscardUnknown 

func (m *StateMsg) XXX_DiscardUnknown()

func (*StateMsg) XXX_Marshal 

func (m *StateMsg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StateMsg) XXX_Merge 

func (m *StateMsg) XXX_Merge(src proto.Message)

func (*StateMsg) XXX_Size 

func (m *StateMsg) XXX_Size() int

func (*StateMsg) XXX_Unmarshal 

func (m *StateMsg) XXX_Unmarshal(b []byte) error

type StateMsg_Kind 

type StateMsg_Kind int32
const (
	STATE_ONLINE  StateMsg_Kind = 1
	STATE_OFFLINE StateMsg_Kind = 2
)

func (StateMsg_Kind) EnumDescriptor 

func (StateMsg_Kind) EnumDescriptor() ([]byte, []int)

func (StateMsg_Kind) String 

func (x StateMsg_Kind) String() string

type StorageDeleteCmd 

type StorageDeleteCmd struct {
	RemotePath string `protobuf:"bytes,1,opt,name=remote_path,json=remotePath,proto3" json:"remote_path,omitempty"`
	LocalPath  string `protobuf:"bytes,2,opt,name=local_path,json=localPath,proto3" json:"local_path,omitempty"`
}

func (*StorageDeleteCmd) Descriptor 

func (*StorageDeleteCmd) Descriptor() ([]byte, []int)

func (*StorageDeleteCmd) Equal 

func (this *StorageDeleteCmd) Equal(that interface{}) bool

func (*StorageDeleteCmd) GetLocalPath 

func (m *StorageDeleteCmd) GetLocalPath() string

func (*StorageDeleteCmd) GetRemotePath 

func (m *StorageDeleteCmd) GetRemotePath() string

func (*StorageDeleteCmd) GoString 

func (this *StorageDeleteCmd) GoString() string

func (*StorageDeleteCmd) Marshal 

func (m *StorageDeleteCmd) Marshal() (dAtA []byte, err error)

func (*StorageDeleteCmd) MarshalTo 

func (m *StorageDeleteCmd) MarshalTo(dAtA []byte) (int, error)

func (*StorageDeleteCmd) MarshalToSizedBuffer 

func (m *StorageDeleteCmd) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*StorageDeleteCmd) ProtoMessage 

func (*StorageDeleteCmd) ProtoMessage()

func (*StorageDeleteCmd) Reset 

func (m *StorageDeleteCmd) Reset()

func (*StorageDeleteCmd) Size 

func (m *StorageDeleteCmd) Size() (n int)

func (*StorageDeleteCmd) String 

func (this *StorageDeleteCmd) String() string

func (*StorageDeleteCmd) Unmarshal 

func (m *StorageDeleteCmd) Unmarshal(dAtA []byte) error

func (*StorageDeleteCmd) XXX_DiscardUnknown 

func (m *StorageDeleteCmd) XXX_DiscardUnknown()

func (*StorageDeleteCmd) XXX_Marshal 

func (m *StorageDeleteCmd) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StorageDeleteCmd) XXX_Merge 

func (m *StorageDeleteCmd) XXX_Merge(src proto.Message)

func (*StorageDeleteCmd) XXX_Size 

func (m *StorageDeleteCmd) XXX_Size() int

func (*StorageDeleteCmd) XXX_Unmarshal 

func (m *StorageDeleteCmd) XXX_Unmarshal(b []byte) error

type StorageEnsureCmd 

type StorageEnsureCmd struct {
	RemotePath string `protobuf:"bytes,1,opt,name=remote_path,json=remotePath,proto3" json:"remote_path,omitempty"`
	LocalPath  string `protobuf:"bytes,2,opt,name=local_path,json=localPath,proto3" json:"local_path,omitempty"`
}

func (*StorageEnsureCmd) Descriptor 

func (*StorageEnsureCmd) Descriptor() ([]byte, []int)

func (*StorageEnsureCmd) Equal 

func (this *StorageEnsureCmd) Equal(that interface{}) bool

func (*StorageEnsureCmd) GetLocalPath 

func (m *StorageEnsureCmd) GetLocalPath() string

func (*StorageEnsureCmd) GetRemotePath 

func (m *StorageEnsureCmd) GetRemotePath() string

func (*StorageEnsureCmd) GoString 

func (this *StorageEnsureCmd) GoString() string

func (*StorageEnsureCmd) Marshal 

func (m *StorageEnsureCmd) Marshal() (dAtA []byte, err error)

func (*StorageEnsureCmd) MarshalTo 

func (m *StorageEnsureCmd) MarshalTo(dAtA []byte) (int, error)

func (*StorageEnsureCmd) MarshalToSizedBuffer 

func (m *StorageEnsureCmd) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*StorageEnsureCmd) ProtoMessage 

func (*StorageEnsureCmd) ProtoMessage()

func (*StorageEnsureCmd) Reset 

func (m *StorageEnsureCmd) Reset()

func (*StorageEnsureCmd) Size 

func (m *StorageEnsureCmd) Size() (n int)

func (*StorageEnsureCmd) String 

func (this *StorageEnsureCmd) String() string

func (*StorageEnsureCmd) Unmarshal 

func (m *StorageEnsureCmd) Unmarshal(dAtA []byte) error

func (*StorageEnsureCmd) XXX_DiscardUnknown 

func (m *StorageEnsureCmd) XXX_DiscardUnknown()

func (*StorageEnsureCmd) XXX_Marshal 

func (m *StorageEnsureCmd) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StorageEnsureCmd) XXX_Merge 

func (m *StorageEnsureCmd) XXX_Merge(src proto.Message)

func (*StorageEnsureCmd) XXX_Size 

func (m *StorageEnsureCmd) XXX_Size() int

func (*StorageEnsureCmd) XXX_Unmarshal 

func (m *StorageEnsureCmd) XXX_Unmarshal(b []byte) error

type StorageListCmd 

type StorageListCmd struct {
}

func (*StorageListCmd) Descriptor 

func (*StorageListCmd) Descriptor() ([]byte, []int)

func (*StorageListCmd) Equal 

func (this *StorageListCmd) Equal(that interface{}) bool

func (*StorageListCmd) GoString 

func (this *StorageListCmd) GoString() string

func (*StorageListCmd) Marshal 

func (m *StorageListCmd) Marshal() (dAtA []byte, err error)

func (*StorageListCmd) MarshalTo 

func (m *StorageListCmd) MarshalTo(dAtA []byte) (int, error)

func (*StorageListCmd) MarshalToSizedBuffer 

func (m *StorageListCmd) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*StorageListCmd) ProtoMessage 

func (*StorageListCmd) ProtoMessage()

func (*StorageListCmd) Reset 

func (m *StorageListCmd) Reset()

func (*StorageListCmd) Size 

func (m *StorageListCmd) Size() (n int)

func (*StorageListCmd) String 

func (this *StorageListCmd) String() string

func (*StorageListCmd) Unmarshal 

func (m *StorageListCmd) Unmarshal(dAtA []byte) error

func (*StorageListCmd) XXX_DiscardUnknown 

func (m *StorageListCmd) XXX_DiscardUnknown()

func (*StorageListCmd) XXX_Marshal 

func (m *StorageListCmd) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StorageListCmd) XXX_Merge 

func (m *StorageListCmd) XXX_Merge(src proto.Message)

func (*StorageListCmd) XXX_Size 

func (m *StorageListCmd) XXX_Size() int

func (*StorageListCmd) XXX_Unmarshal 

func (m *StorageListCmd) XXX_Unmarshal(b []byte) error

type StorageState 

type StorageState int32
const (
	STORAGE_STATE_UNKONW    StorageState = 0
	STORAGE_STATE_UNMOUNTED StorageState = 1
	STORAGE_STATE_MOUNTED   StorageState = 2
)

func (StorageState) EnumDescriptor 

func (StorageState) EnumDescriptor() ([]byte, []int)

func (StorageState) String 

func (x StorageState) String() string

type StorageStatusListMsg 

type StorageStatusListMsg struct {
	Storages []*StorageStatusMsg `protobuf:"bytes,1,rep,name=storages,proto3" json:"storages,omitempty"`
}

func (*StorageStatusListMsg) Descriptor 

func (*StorageStatusListMsg) Descriptor() ([]byte, []int)

func (*StorageStatusListMsg) Equal 

func (this *StorageStatusListMsg) Equal(that interface{}) bool

func (*StorageStatusListMsg) GetStorages 

func (m *StorageStatusListMsg) GetStorages() []*StorageStatusMsg

func (*StorageStatusListMsg) GoString 

func (this *StorageStatusListMsg) GoString() string

func (*StorageStatusListMsg) Marshal 

func (m *StorageStatusListMsg) Marshal() (dAtA []byte, err error)

func (*StorageStatusListMsg) MarshalTo 

func (m *StorageStatusListMsg) MarshalTo(dAtA []byte) (int, error)

func (*StorageStatusListMsg) MarshalToSizedBuffer 

func (m *StorageStatusListMsg) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*StorageStatusListMsg) ProtoMessage 

func (*StorageStatusListMsg) ProtoMessage()

func (*StorageStatusListMsg) Reset 

func (m *StorageStatusListMsg) Reset()

func (*StorageStatusListMsg) Size 

func (m *StorageStatusListMsg) Size() (n int)

func (*StorageStatusListMsg) String 

func (this *StorageStatusListMsg) String() string

func (*StorageStatusListMsg) Unmarshal 

func (m *StorageStatusListMsg) Unmarshal(dAtA []byte) error

func (*StorageStatusListMsg) XXX_DiscardUnknown 

func (m *StorageStatusListMsg) XXX_DiscardUnknown()

func (*StorageStatusListMsg) XXX_Marshal 

func (m *StorageStatusListMsg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StorageStatusListMsg) XXX_Merge 

func (m *StorageStatusListMsg) XXX_Merge(src proto.Message)

func (*StorageStatusListMsg) XXX_Size 

func (m *StorageStatusListMsg) XXX_Size() int

func (*StorageStatusListMsg) XXX_Unmarshal 

func (m *StorageStatusListMsg) XXX_Unmarshal(b []byte) error

type StorageStatusMsg 

type StorageStatusMsg struct {
	State      StorageState `protobuf:"varint,1,opt,name=state,proto3,enum=aranya.StorageState" json:"state,omitempty"`
	RemotePath string       `protobuf:"bytes,2,opt,name=remote_path,json=remotePath,proto3" json:"remote_path,omitempty"`
	MountPoint string       `protobuf:"bytes,3,opt,name=mount_point,json=mountPoint,proto3" json:"mount_point,omitempty"`
}

func (*StorageStatusMsg) Descriptor 

func (*StorageStatusMsg) Descriptor() ([]byte, []int)

func (*StorageStatusMsg) Equal 

func (this *StorageStatusMsg) Equal(that interface{}) bool

func (*StorageStatusMsg) GetMountPoint 

func (m *StorageStatusMsg) GetMountPoint() string

func (*StorageStatusMsg) GetRemotePath 

func (m *StorageStatusMsg) GetRemotePath() string

func (*StorageStatusMsg) GetState 

func (m *StorageStatusMsg) GetState() StorageState

func (*StorageStatusMsg) GoString 

func (this *StorageStatusMsg) GoString() string

func (*StorageStatusMsg) Marshal 

func (m *StorageStatusMsg) Marshal() (dAtA []byte, err error)

func (*StorageStatusMsg) MarshalTo 

func (m *StorageStatusMsg) MarshalTo(dAtA []byte) (int, error)

func (*StorageStatusMsg) MarshalToSizedBuffer 

func (m *StorageStatusMsg) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*StorageStatusMsg) ProtoMessage 

func (*StorageStatusMsg) ProtoMessage()

func (*StorageStatusMsg) Reset 

func (m *StorageStatusMsg) Reset()

func (*StorageStatusMsg) Size 

func (m *StorageStatusMsg) Size() (n int)

func (*StorageStatusMsg) String 

func (this *StorageStatusMsg) String() string

func (*StorageStatusMsg) Unmarshal 

func (m *StorageStatusMsg) Unmarshal(dAtA []byte) error

func (*StorageStatusMsg) XXX_DiscardUnknown 

func (m *StorageStatusMsg) XXX_DiscardUnknown()

func (*StorageStatusMsg) XXX_Marshal 

func (m *StorageStatusMsg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StorageStatusMsg) XXX_Merge 

func (m *StorageStatusMsg) XXX_Merge(src proto.Message)

func (*StorageStatusMsg) XXX_Size 

func (m *StorageStatusMsg) XXX_Size() int

func (*StorageStatusMsg) XXX_Unmarshal 

func (m *StorageStatusMsg) XXX_Unmarshal(b []byte) error

type TLSConfig 

type TLSConfig struct {
	ServerName         string   `protobuf:"bytes,1,opt,name=server_name,json=serverName,proto3" json:"server_name,omitempty"`
	InsecureSkipVerify bool     `protobuf:"varint,2,opt,name=insecure_skip_verify,json=insecureSkipVerify,proto3" json:"insecure_skip_verify,omitempty"`
	MinVersion         uint32   `protobuf:"varint,3,opt,name=min_version,json=minVersion,proto3" json:"min_version,omitempty"`
	MaxVersion         uint32   `protobuf:"varint,4,opt,name=max_version,json=maxVersion,proto3" json:"max_version,omitempty"`
	CaCert             []byte   `protobuf:"bytes,5,opt,name=ca_cert,json=caCert,proto3" json:"ca_cert,omitempty"`
	Cert               []byte   `protobuf:"bytes,6,opt,name=cert,proto3" json:"cert,omitempty"`
	Key                []byte   `protobuf:"bytes,7,opt,name=key,proto3" json:"key,omitempty"`
	CipherSuites       []uint32 `protobuf:"varint,8,rep,packed,name=cipher_suites,json=cipherSuites,proto3" json:"cipher_suites,omitempty"`
	NextProtos         []string `protobuf:"bytes,9,rep,name=next_protos,json=nextProtos,proto3" json:"next_protos,omitempty"`
}

func (*TLSConfig) Descriptor 

func (*TLSConfig) Descriptor() ([]byte, []int)

func (*TLSConfig) Equal 

func (this *TLSConfig) Equal(that interface{}) bool

func (*TLSConfig) GetCaCert 

func (m *TLSConfig) GetCaCert() []byte

func (*TLSConfig) GetCert 

func (m *TLSConfig) GetCert() []byte

func (*TLSConfig) GetCipherSuites 

func (m *TLSConfig) GetCipherSuites() []uint32

func (*TLSConfig) GetInsecureSkipVerify 

func (m *TLSConfig) GetInsecureSkipVerify() bool

func (*TLSConfig) GetKey 

func (m *TLSConfig) GetKey() []byte

func (*TLSConfig) GetMaxVersion 

func (m *TLSConfig) GetMaxVersion() uint32

func (*TLSConfig) GetMinVersion 

func (m *TLSConfig) GetMinVersion() uint32

func (*TLSConfig) GetNextProtos 

func (m *TLSConfig) GetNextProtos() []string

func (*TLSConfig) GetServerName 

func (m *TLSConfig) GetServerName() string

func (*TLSConfig) GoString 

func (this *TLSConfig) GoString() string

func (*TLSConfig) Marshal 

func (m *TLSConfig) Marshal() (dAtA []byte, err error)

func (*TLSConfig) MarshalTo 

func (m *TLSConfig) MarshalTo(dAtA []byte) (int, error)

func (*TLSConfig) MarshalToSizedBuffer 

func (m *TLSConfig) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*TLSConfig) ProtoMessage 

func (*TLSConfig) ProtoMessage()

func (*TLSConfig) Reset 

func (m *TLSConfig) Reset()

func (*TLSConfig) Size 

func (m *TLSConfig) Size() (n int)

func (*TLSConfig) String 

func (this *TLSConfig) String() string

func (*TLSConfig) Unmarshal 

func (m *TLSConfig) Unmarshal(dAtA []byte) error

func (*TLSConfig) XXX_DiscardUnknown 

func (m *TLSConfig) XXX_DiscardUnknown()

func (*TLSConfig) XXX_Marshal 

func (m *TLSConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TLSConfig) XXX_Merge 

func (m *TLSConfig) XXX_Merge(src proto.Message)

func (*TLSConfig) XXX_Size 

func (m *TLSConfig) XXX_Size() int

func (*TLSConfig) XXX_Unmarshal 

func (m *TLSConfig) XXX_Unmarshal(b []byte) error

type TerminalResizeCmd 

type TerminalResizeCmd struct {
	Cols uint32 `protobuf:"varint,1,opt,name=cols,proto3" json:"cols,omitempty"`
	Rows uint32 `protobuf:"varint,2,opt,name=rows,proto3" json:"rows,omitempty"`
}

func NewTerminalResizeCmd 

func NewTerminalResizeCmd(cols uint16, rows uint16) *TerminalResizeCmd

func (*TerminalResizeCmd) Descriptor 

func (*TerminalResizeCmd) Descriptor() ([]byte, []int)

func (*TerminalResizeCmd) Equal 

func (this *TerminalResizeCmd) Equal(that interface{}) bool

func (*TerminalResizeCmd) GetCols 

func (m *TerminalResizeCmd) GetCols() uint32

func (*TerminalResizeCmd) GetRows 

func (m *TerminalResizeCmd) GetRows() uint32

func (*TerminalResizeCmd) GoString 

func (this *TerminalResizeCmd) GoString() string

func (*TerminalResizeCmd) Marshal 

func (m *TerminalResizeCmd) Marshal() (dAtA []byte, err error)

func (*TerminalResizeCmd) MarshalTo 

func (m *TerminalResizeCmd) MarshalTo(dAtA []byte) (int, error)

func (*TerminalResizeCmd) MarshalToSizedBuffer 

func (m *TerminalResizeCmd) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*TerminalResizeCmd) ProtoMessage 

func (*TerminalResizeCmd) ProtoMessage()

func (*TerminalResizeCmd) Reset 

func (m *TerminalResizeCmd) Reset()

func (*TerminalResizeCmd) Size 

func (m *TerminalResizeCmd) Size() (n int)

func (*TerminalResizeCmd) String 

func (this *TerminalResizeCmd) String() string

func (*TerminalResizeCmd) Unmarshal 

func (m *TerminalResizeCmd) Unmarshal(dAtA []byte) error

func (*TerminalResizeCmd) XXX_DiscardUnknown 

func (m *TerminalResizeCmd) XXX_DiscardUnknown()

func (*TerminalResizeCmd) XXX_Marshal 

func (m *TerminalResizeCmd) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TerminalResizeCmd) XXX_Merge 

func (m *TerminalResizeCmd) XXX_Merge(src proto.Message)

func (*TerminalResizeCmd) XXX_Size 

func (m *TerminalResizeCmd) XXX_Size() int

func (*TerminalResizeCmd) XXX_Unmarshal 

func (m *TerminalResizeCmd) XXX_Unmarshal(b []byte) error

type UnimplementedEdgeDeviceServer 

type UnimplementedEdgeDeviceServer struct {
}

UnimplementedEdgeDeviceServer can be embedded to have forward compatible implementations.

func (*UnimplementedEdgeDeviceServer) Sync 

func (*UnimplementedEdgeDeviceServer) Sync(srv EdgeDevice_SyncServer) error

Source Files

View all Source files

Directories

Path Synopsis

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.