aranyagopb

package
v0.3.5 Latest Latest
Warning

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

 Go to latest Published: Jan 24, 2021 License: Apache-2.0 Imports: 11 Imported by: 23

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthPeripheral        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowPeripheral          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupPeripheral = 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",
	9:  "CMD_NET",
	10: "CMD_RUNTIME",
	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_STORAGE_LIST",
	42: "CMD_STORAGE_ENSURE",
	43: "CMD_STORAGE_DELETE",
	51: "CMD_PERIPHERAL_LIST",
	52: "CMD_PERIPHERAL_ENSURE",
	53: "CMD_PERIPHERAL_DELETE",
	54: "CMD_PERIPHERAL_OPERATE",
	55: "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":                        9,
	"CMD_RUNTIME":                    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_STORAGE_LIST":               41,
	"CMD_STORAGE_ENSURE":             42,
	"CMD_STORAGE_DELETE":             43,
	"CMD_PERIPHERAL_LIST":            51,
	"CMD_PERIPHERAL_ENSURE":          52,
	"CMD_PERIPHERAL_DELETE":          53,
	"CMD_PERIPHERAL_OPERATE":         54,
	"CMD_PERIPHERAL_COLLECT_METRICS": 55,
}
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 MsgType_name = map[int32]string{
	0: "MSG_DATA",

	1:  "MSG_DATA_STDERR",
	5:  "MSG_DONE",
	6:  "MSG_STATE",
	7:  "MSG_ERROR",
	9:  "MSG_NET",
	10: "MSG_RUNTIME",
	11: "MSG_NODE_STATUS",
	31: "MSG_CRED_STATUS",
	41: "MSG_STORAGE_STATUS",
	42: "MSG_STORAGE_STATUS_LIST",
	51: "MSG_PERIPHERAL_STATUS",
	52: "MSG_PERIPHERAL_STATUS_LIST",
	53: "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_STREAM_CONTINUE":             0,
	"MSG_DATA_STDERR":                 1,
	"MSG_DONE":                        5,
	"MSG_STATE":                       6,
	"MSG_ERROR":                       7,
	"MSG_NET":                         9,
	"MSG_RUNTIME":                     10,
	"MSG_NODE_STATUS":                 11,
	"MSG_CRED_STATUS":                 31,
	"MSG_STORAGE_STATUS":              41,
	"MSG_STORAGE_STATUS_LIST":         42,
	"MSG_PERIPHERAL_STATUS":           51,
	"MSG_PERIPHERAL_STATUS_LIST":      52,
	"MSG_PERIPHERAL_OPERATION_RESULT": 53,
}
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_NUMBER",
}
View Source 
var NodeExtInfo_ValueType_value = map[string]int32{
	"NODE_EXT_INFO_TYPE_STRING": 0,
	"NODE_EXT_INFO_TYPE_NUMBER": 1,
}
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 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 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

This section is empty.

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
	Complete bool `protobuf:"varint,4,opt,name=complete,proto3" json:"complete,omitempty"`
	// payload of encoded XxxCmd or raw data bytes
	//
	// payload can be nil if kind has clear indication of what operation to do
	Payload []byte `protobuf:"bytes,11,opt,name=payload,proto3" json:"payload,omitempty"`
}

func (*Cmd) Descriptor 

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

func (*Cmd) Equal 

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

func (*Cmd) GetComplete added in v0.3.3 

func (m *Cmd) GetComplete() bool

func (*Cmd) GetKind 

func (m *Cmd) GetKind() CmdType

func (*Cmd) GetPayload added in v0.2.0 

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

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
	// to reduce overhead, we also use this identifier to send data targeting the runtime
	// extension connected
	//
	// the agent should cache all non-terminated session ids
	// if the session id doesn't exist, send data to the runtime
	// if there is not runtime connected, discard data
	CMD_DATA_UPSTREAM CmdType = 0
	CMD_SESSION_CLOSE CmdType = 5
	CMD_REJECT        CmdType = 6
	// network operations, protobuf bytes of abbot proto
	CMD_NET CmdType = 9
	// runtime operations, protobuf bytes of runtime.Packet
	CMD_RUNTIME 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
	// 51-59: storage operations (remote csi)
	CMD_STORAGE_LIST   CmdType = 41
	CMD_STORAGE_ENSURE CmdType = 42
	CMD_STORAGE_DELETE CmdType = 43
	// 71-79: peripheral operations
	CMD_PERIPHERAL_LIST            CmdType = 51
	CMD_PERIPHERAL_ENSURE          CmdType = 52
	CMD_PERIPHERAL_DELETE          CmdType = 53
	CMD_PERIPHERAL_OPERATE         CmdType = 54
	CMD_PERIPHERAL_COLLECT_METRICS CmdType = 55
)

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 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 (*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 {
	SshPrivateKeySha256 []byte `protobuf:"bytes,1,opt,name=ssh_private_key_sha256,json=sshPrivateKeySha256,proto3" json:"ssh_private_key_sha256,omitempty"`
}

func (*CredentialStatusMsg) Descriptor 

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

func (*CredentialStatusMsg) Equal 

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

func (*CredentialStatusMsg) GetSshPrivateKeySha256 added in v0.3.0 

func (m *CredentialStatusMsg) GetSshPrivateKeySha256() []byte

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 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 (*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 (*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 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 (*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 MetricsConfigCmd 

type MetricsConfigCmd struct {
	Collect   []string `protobuf:"bytes,1,rep,name=collect,proto3" json:"collect,omitempty"`
	ExtraArgs []string `protobuf:"bytes,2,rep,name=extra_args,json=extraArgs,proto3" json:"extra_args,omitempty"`
}

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) 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 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
	Complete bool `protobuf:"varint,4,opt,name=complete,proto3" json:"complete,omitempty"`
	// payload of encoded XxxMsg or raw data bytes
	//
	// payload can be nil if kind is clearly defined
	Payload []byte `protobuf:"bytes,11,opt,name=payload,proto3" json:"payload,omitempty"`
}

func (*Msg) Descriptor 

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

func (*Msg) Equal 

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

func (*Msg) GetComplete added in v0.3.3 

func (m *Msg) GetComplete() 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() *runtimepb.ImageStatusListMsg

func (*Msg) GetKind 

func (m *Msg) GetKind() MsgType

func (*Msg) GetNodeStatus 

func (m *Msg) GetNodeStatus() *NodeStatusMsg

func (*Msg) GetPayload added in v0.2.0 

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

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() *runtimepb.PodStatusMsg

func (*Msg) GetPodStatusList 

func (m *Msg) GetPodStatusList() *runtimepb.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
	// special message to allow data streaming, aranya can only send data after
	// receiving this message (empty data)
	MSG_STREAM_CONTINUE 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 = 9
	// runtime messages, protobuf bytes of runtime.Packet
	MSG_RUNTIME MsgType = 10
	// 11-19: node msgs
	MSG_NODE_STATUS MsgType = 11
	// 31-39: credential msgs
	MSG_CRED_STATUS MsgType = 31
	// 51-59: storage msgs
	MSG_STORAGE_STATUS      MsgType = 41
	MSG_STORAGE_STATUS_LIST MsgType = 42
	// 71-79: peripheral msgs
	MSG_PERIPHERAL_STATUS           MsgType = 51
	MSG_PERIPHERAL_STATUS_LIST      MsgType = 52
	MSG_PERIPHERAL_OPERATION_RESULT MsgType = 53
)

func (MsgType) EnumDescriptor 

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

func (MsgType) String 

func (x MsgType) String() string

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 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"`
}

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 the new value
	NODE_EXT_INFO_OPERATOR_SET NodeExtInfo_Operator = 0
	// only valid for {string, number}
	NODE_EXT_INFO_OPERATOR_ADD NodeExtInfo_Operator = 1
	// only valid for {number}
	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_NUMBER NodeExtInfo_ValueType = 1
)

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 (*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 (
	// Get dynamic node information only
	// including node conditions and resources
	// not including node system info and node ext info
	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 (*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"`
}

Node Information Sync

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) 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 (*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 (*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 (*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 (*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 (*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 (*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 (*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 (*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 PortForwardCmd 

type PortForwardCmd struct {
	// pod uid to help runtime to find pod ip if no host provided
	PodUid string `protobuf:"bytes,1,opt,name=pod_uid,json=podUid,proto3" json:"pod_uid,omitempty"`
	// Network type of the forwarded endpoint
	Network string `protobuf:"bytes,2,opt,name=network,proto3" json:"network,omitempty"`
	// address part of forwarded endpoint
	// for ip based protocols (e.g. tcp/udp), this is the ip address or hostname
	// for file based protocols (e.g. unix/NamedPipe), this is the file path
	Address string `protobuf:"bytes,3,opt,name=address,proto3" json:"address,omitempty"`
	// port used for ip based protocols (e.g. tcp/udp)
	// for file based protocols (e.g. unix/NamedPipe), this should be ignored
	Port int32 `protobuf:"varint,4,opt,name=port,proto3" json:"port,omitempty"`
}

func (*PortForwardCmd) Descriptor 

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

func (*PortForwardCmd) Equal 

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

func (*PortForwardCmd) GetAddress added in v0.3.3 

func (m *PortForwardCmd) GetAddress() string

func (*PortForwardCmd) GetNetwork added in v0.3.0 

func (m *PortForwardCmd) GetNetwork() string

func (*PortForwardCmd) GetPodUid 

func (m *PortForwardCmd) GetPodUid() string

func (*PortForwardCmd) GetPort 

func (m *PortForwardCmd) GetPort() int32

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 (*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 SessionCloseCmd 

type SessionCloseCmd struct {
	// session id to be closed
	Sid uint64 `protobuf:"varint,1,opt,name=sid,proto3" json:"sid,omitempty"`
}

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 (*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)