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_INPUT",
	10: "CMD_DATA_CLOSE",
	1:  "CMD_PING",
	11: "CMD_PERIPHERAL_CONNECT",
	12: "CMD_PERIPHERAL_OPERATE",
	13: "CMD_PERIPHERAL_COLLECT_METRICS",
	14: "CMD_PERIPHERAL_CLOSE",
	20: "CMD_RUNTIME_ARANYA_PROTO",
}
View Source
var CmdType_value = map[string]int32{
	"CMD_DATA_INPUT":                 0,
	"CMD_DATA_CLOSE":                 10,
	"CMD_PING":                       1,
	"CMD_PERIPHERAL_CONNECT":         11,
	"CMD_PERIPHERAL_OPERATE":         12,
	"CMD_PERIPHERAL_COLLECT_METRICS": 13,
	"CMD_PERIPHERAL_CLOSE":           14,
	"CMD_RUNTIME_ARANYA_PROTO":       20,
}
View Source
var CodecType_name = map[int32]string{
	0: "_INVALID_CODEC",
	1: "CODEC_PROTOBUF",
	2: "CODEC_JSON",
}
View Source
var CodecType_value = map[string]int32{
	"_INVALID_CODEC": 0,
	"CODEC_PROTOBUF": 1,
	"CODEC_JSON":     2,
}
View Source
var ExtensionType_name = map[int32]string{
	0: "_INVALID_EXTENSION",
	1: "EXTENSION_PERIPHERAL",
	2: "EXTENSION_RUNTIME",
}
View Source
var ExtensionType_value = map[string]int32{
	"_INVALID_EXTENSION":   0,
	"EXTENSION_PERIPHERAL": 1,
	"EXTENSION_RUNTIME":    2,
}
View Source
var MsgType_name = map[int32]string{
	0:  "MSG_DATA_OUTPUT",
	1:  "MSG_PONG",
	2:  "MSG_ERROR",
	3:  "MSG_DONE",
	10: "MSG_REGISTER",
	11: "MSG_PERIPHERAL_OPERATION_RESULT",
	12: "MSG_PERIPHERAL_METRICS",
	13: "MSG_PERIPHERAL_EVENTS",
	20: "MSG_RUNTIME_ARANYA_PROTO",
	21: "MSG_RUNTIME_DATA_STDERR",
}
View Source
var MsgType_value = map[string]int32{
	"MSG_DATA_OUTPUT":                 0,
	"MSG_PONG":                        1,
	"MSG_ERROR":                       2,
	"MSG_DONE":                        3,
	"MSG_REGISTER":                    10,
	"MSG_PERIPHERAL_OPERATION_RESULT": 11,
	"MSG_PERIPHERAL_METRICS":          12,
	"MSG_PERIPHERAL_EVENTS":           13,
	"MSG_RUNTIME_ARANYA_PROTO":        20,
	"MSG_RUNTIME_DATA_STDERR":         21,
}
View Source
var PeripheralEventType_name = map[int32]string{
	0: "_INVALID_PERIPHERAL_EVENT",
}
View Source
var PeripheralEventType_value = map[string]int32{
	"_INVALID_PERIPHERAL_EVENT": 0,
}

Functions

This section is empty.

Types

type Cmd

type Cmd struct {
	Kind CmdType `protobuf:"varint,1,opt,name=kind,proto3,enum=arhat.CmdType" json:"kind,omitempty"`
	// for peripheral extensions: this is the id assigned by the arhat peripheral manager
	// for runtime extensions: this is the session id assigned by aranya
	Id uint64 `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"`
	// for peripheral extensions: this is used to identify request/reponse pair
	// for runtime extensions:
	//      this is used to identify data sequence in this session, also assigned by aranya
	//      this is designed to support unordered data transmission
	Seq     uint64 `protobuf:"varint,3,opt,name=seq,proto3" json:"seq,omitempty"`
	Payload []byte `protobuf:"bytes,10,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) GetId

func (m *Cmd) GetId() uint64

func (*Cmd) GetKind

func (m *Cmd) GetKind() CmdType

func (*Cmd) GetPayload

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

func (*Cmd) GetSeq

func (m *Cmd) GetSeq() 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 (
	CMD_DATA_INPUT                 CmdType = 0
	CMD_DATA_CLOSE                 CmdType = 10
	CMD_PING                       CmdType = 1
	CMD_PERIPHERAL_CONNECT         CmdType = 11
	CMD_PERIPHERAL_OPERATE         CmdType = 12
	CMD_PERIPHERAL_COLLECT_METRICS CmdType = 13
	CMD_PERIPHERAL_CLOSE           CmdType = 14
	// aranya-proto runtime commands (pod management)
	// payload is always encoded in protobuf bytes
	// see https://github.com/arhat-dev/aranya-proto/blob/master/src/cmd_pod.proto
	CMD_RUNTIME_ARANYA_PROTO CmdType = 20
)

func (CmdType) EnumDescriptor

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

func (CmdType) String

func (x CmdType) String() string

type CodecType

type CodecType int32
const (
	CODEC_PROTOBUF CodecType = 1
	CODEC_JSON     CodecType = 2
)

func (CodecType) EnumDescriptor

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

func (CodecType) String

func (x CodecType) String() string

type DoneMsg

type DoneMsg struct {
}

func (*DoneMsg) Descriptor

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

func (*DoneMsg) Equal

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

func (*DoneMsg) GoString

func (this *DoneMsg) GoString() string

func (*DoneMsg) Marshal

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

func (*DoneMsg) MarshalTo

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

func (*DoneMsg) MarshalToSizedBuffer

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

func (*DoneMsg) ProtoMessage

func (*DoneMsg) ProtoMessage()

func (*DoneMsg) Reset

func (m *DoneMsg) Reset()

func (*DoneMsg) Size

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

func (*DoneMsg) String

func (this *DoneMsg) String() string

func (*DoneMsg) Unmarshal

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

func (*DoneMsg) XXX_DiscardUnknown

func (m *DoneMsg) XXX_DiscardUnknown()

func (*DoneMsg) XXX_Marshal

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

func (*DoneMsg) XXX_Merge

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

func (*DoneMsg) XXX_Size

func (m *DoneMsg) XXX_Size() int

func (*DoneMsg) XXX_Unmarshal

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

type ErrorMsg

type ErrorMsg struct {
	Description string `protobuf:"bytes,1,opt,name=description,proto3" json:"description,omitempty"`
}

func (*ErrorMsg) Descriptor

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

func (*ErrorMsg) Equal

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

func (*ErrorMsg) GetDescription

func (m *ErrorMsg) GetDescription() string

func (*ErrorMsg) GoString

func (this *ErrorMsg) GoString() string

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 ExtensionType

type ExtensionType int32
const (

	// Peripheral management extension
	EXTENSION_PERIPHERAL ExtensionType = 1
	// Runtime implementation for kubernetes pods
	EXTENSION_RUNTIME ExtensionType = 2
)

func (ExtensionType) EnumDescriptor

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

func (ExtensionType) String

func (x ExtensionType) String() string

type Msg

type Msg struct {
	Kind MsgType `protobuf:"varint,1,opt,name=kind,proto3,enum=arhat.MsgType" json:"kind,omitempty"`
	// for peripheral extensions: this is the id assigned by the arhat peripheral manager
	// for runtime extensions: this is the session id assigned by aranya
	Id uint64 `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"`
	// optional ack number
	// for peripheral extensions: if set, to acknowledge Cmd with same seq value
	// for runtime extensions: the data sequence in the session
	Ack     uint64 `protobuf:"varint,3,opt,name=ack,proto3" json:"ack,omitempty"`
	Payload []byte `protobuf:"bytes,10,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) GetAck

func (m *Msg) GetAck() uint64

func (*Msg) GetId

func (m *Msg) GetId() uint64

func (*Msg) GetKind

func (m *Msg) GetKind() MsgType

func (*Msg) GetPayload

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

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_OUTPUT                 MsgType = 0
	MSG_PONG                        MsgType = 1
	MSG_ERROR                       MsgType = 2
	MSG_DONE                        MsgType = 3
	MSG_REGISTER                    MsgType = 10
	MSG_PERIPHERAL_OPERATION_RESULT MsgType = 11
	MSG_PERIPHERAL_METRICS          MsgType = 12
	MSG_PERIPHERAL_EVENTS           MsgType = 13
	// message response for aranya-proto runtime command
	// payload MUST be encoded in protobuf bytes
	// see https://github.com/arhat-dev/aranya-proto/blob/master/src/cmd_pod.proto
	MSG_RUNTIME_ARANYA_PROTO MsgType = 20
	MSG_RUNTIME_DATA_STDERR  MsgType = 21
)

func (MsgType) EnumDescriptor

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

func (MsgType) String

func (x MsgType) String() string

type PeripheralCloseCmd

type PeripheralCloseCmd struct {
}

func (*PeripheralCloseCmd) Descriptor

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

func (*PeripheralCloseCmd) Equal

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

func (*PeripheralCloseCmd) GoString

func (this *PeripheralCloseCmd) GoString() string

func (*PeripheralCloseCmd) Marshal

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

func (*PeripheralCloseCmd) MarshalTo

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

func (*PeripheralCloseCmd) MarshalToSizedBuffer

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

func (*PeripheralCloseCmd) ProtoMessage

func (*PeripheralCloseCmd) ProtoMessage()

func (*PeripheralCloseCmd) Reset

func (m *PeripheralCloseCmd) Reset()

func (*PeripheralCloseCmd) Size

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

func (*PeripheralCloseCmd) String

func (this *PeripheralCloseCmd) String() string

func (*PeripheralCloseCmd) Unmarshal

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

func (*PeripheralCloseCmd) XXX_DiscardUnknown

func (m *PeripheralCloseCmd) XXX_DiscardUnknown()

func (*PeripheralCloseCmd) XXX_Marshal

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

func (*PeripheralCloseCmd) XXX_Merge

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

func (*PeripheralCloseCmd) XXX_Size

func (m *PeripheralCloseCmd) XXX_Size() int

func (*PeripheralCloseCmd) XXX_Unmarshal

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

type PeripheralConnectCmd

type PeripheralConnectCmd struct {
	Target string            `protobuf:"bytes,1,opt,name=target,proto3" json:"target,omitempty"`
	Params map[string]string `` /* 153-byte string literal not displayed */
	Tls    *TLSConfig        `protobuf:"bytes,3,opt,name=tls,proto3" json:"tls,omitempty"`
}

func (*PeripheralConnectCmd) Descriptor

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

func (*PeripheralConnectCmd) Equal

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

func (*PeripheralConnectCmd) GetParams

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

func (*PeripheralConnectCmd) GetTarget

func (m *PeripheralConnectCmd) GetTarget() string

func (*PeripheralConnectCmd) GetTls

func (m *PeripheralConnectCmd) GetTls() *TLSConfig

func (*PeripheralConnectCmd) GoString

func (this *PeripheralConnectCmd) GoString() string

func (*PeripheralConnectCmd) Marshal

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

func (*PeripheralConnectCmd) MarshalTo

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

func (*PeripheralConnectCmd) MarshalToSizedBuffer

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

func (*PeripheralConnectCmd) ProtoMessage

func (*PeripheralConnectCmd) ProtoMessage()

func (*PeripheralConnectCmd) Reset

func (m *PeripheralConnectCmd) Reset()

func (*PeripheralConnectCmd) Size

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

func (*PeripheralConnectCmd) String

func (this *PeripheralConnectCmd) String() string

func (*PeripheralConnectCmd) Unmarshal

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

func (*PeripheralConnectCmd) XXX_DiscardUnknown

func (m *PeripheralConnectCmd) XXX_DiscardUnknown()

func (*PeripheralConnectCmd) XXX_Marshal

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

func (*PeripheralConnectCmd) XXX_Merge

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

func (*PeripheralConnectCmd) XXX_Size

func (m *PeripheralConnectCmd) XXX_Size() int

func (*PeripheralConnectCmd) XXX_Unmarshal

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

type PeripheralEventMsg

type PeripheralEventMsg struct {
	Kind PeripheralEventType `protobuf:"varint,1,opt,name=kind,proto3,enum=arhat.PeripheralEventType" json:"kind,omitempty"`
}

func (*PeripheralEventMsg) Descriptor

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

func (*PeripheralEventMsg) Equal

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

func (*PeripheralEventMsg) GetKind

func (*PeripheralEventMsg) GoString

func (this *PeripheralEventMsg) GoString() string

func (*PeripheralEventMsg) Marshal

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

func (*PeripheralEventMsg) MarshalTo

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

func (*PeripheralEventMsg) MarshalToSizedBuffer

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

func (*PeripheralEventMsg) ProtoMessage

func (*PeripheralEventMsg) ProtoMessage()

func (*PeripheralEventMsg) Reset

func (m *PeripheralEventMsg) Reset()

func (*PeripheralEventMsg) Size

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

func (*PeripheralEventMsg) String

func (this *PeripheralEventMsg) String() string

func (*PeripheralEventMsg) Unmarshal

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

func (*PeripheralEventMsg) XXX_DiscardUnknown

func (m *PeripheralEventMsg) XXX_DiscardUnknown()

func (*PeripheralEventMsg) XXX_Marshal

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

func (*PeripheralEventMsg) XXX_Merge

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

func (*PeripheralEventMsg) XXX_Size

func (m *PeripheralEventMsg) XXX_Size() int

func (*PeripheralEventMsg) XXX_Unmarshal

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

type PeripheralEventType

type PeripheralEventType int32

func (PeripheralEventType) EnumDescriptor

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

func (PeripheralEventType) String

func (x PeripheralEventType) String() string

type PeripheralMetricsCollectCmd

type PeripheralMetricsCollectCmd struct {
	Params map[string]string `` /* 153-byte string literal not displayed */
}

func (*PeripheralMetricsCollectCmd) Descriptor

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

func (*PeripheralMetricsCollectCmd) Equal

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

func (*PeripheralMetricsCollectCmd) GetParams

func (m *PeripheralMetricsCollectCmd) GetParams() map[string]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 PeripheralMetricsMsg

type PeripheralMetricsMsg struct {
	Values []*PeripheralMetricsMsg_Value `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
}

func (*PeripheralMetricsMsg) Descriptor

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

func (*PeripheralMetricsMsg) Equal

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

func (*PeripheralMetricsMsg) GetValues

func (*PeripheralMetricsMsg) GoString

func (this *PeripheralMetricsMsg) GoString() string

func (*PeripheralMetricsMsg) Marshal

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

func (*PeripheralMetricsMsg) MarshalTo

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

func (*PeripheralMetricsMsg) MarshalToSizedBuffer

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

func (*PeripheralMetricsMsg) ProtoMessage

func (*PeripheralMetricsMsg) ProtoMessage()

func (*PeripheralMetricsMsg) Reset

func (m *PeripheralMetricsMsg) Reset()

func (*PeripheralMetricsMsg) Size

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

func (*PeripheralMetricsMsg) String

func (this *PeripheralMetricsMsg) String() string

func (*PeripheralMetricsMsg) Unmarshal

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

func (*PeripheralMetricsMsg) XXX_DiscardUnknown

func (m *PeripheralMetricsMsg) XXX_DiscardUnknown()

func (*PeripheralMetricsMsg) XXX_Marshal

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

func (*PeripheralMetricsMsg) XXX_Merge

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

func (*PeripheralMetricsMsg) XXX_Size

func (m *PeripheralMetricsMsg) XXX_Size() int

func (*PeripheralMetricsMsg) XXX_Unmarshal

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

type PeripheralMetricsMsg_Value

type PeripheralMetricsMsg_Value struct {
	Value float64 `protobuf:"fixed64,1,opt,name=value,proto3" json:"value,omitempty"`
	// unix timestamp
	Timestamp int64 `protobuf:"varint,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
}

func (*PeripheralMetricsMsg_Value) Descriptor

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

func (*PeripheralMetricsMsg_Value) Equal

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

func (*PeripheralMetricsMsg_Value) GetTimestamp

func (m *PeripheralMetricsMsg_Value) GetTimestamp() int64

func (*PeripheralMetricsMsg_Value) GetValue

func (m *PeripheralMetricsMsg_Value) GetValue() float64

func (*PeripheralMetricsMsg_Value) GoString

func (this *PeripheralMetricsMsg_Value) GoString() string

func (*PeripheralMetricsMsg_Value) Marshal

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

func (*PeripheralMetricsMsg_Value) MarshalTo

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

func (*PeripheralMetricsMsg_Value) MarshalToSizedBuffer

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

func (*PeripheralMetricsMsg_Value) ProtoMessage

func (*PeripheralMetricsMsg_Value) ProtoMessage()

func (*PeripheralMetricsMsg_Value) Reset

func (m *PeripheralMetricsMsg_Value) Reset()

func (*PeripheralMetricsMsg_Value) Size

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

func (*PeripheralMetricsMsg_Value) String

func (this *PeripheralMetricsMsg_Value) String() string

func (*PeripheralMetricsMsg_Value) Unmarshal

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

func (*PeripheralMetricsMsg_Value) XXX_DiscardUnknown

func (m *PeripheralMetricsMsg_Value) XXX_DiscardUnknown()

func (*PeripheralMetricsMsg_Value) XXX_Marshal

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

func (*PeripheralMetricsMsg_Value) XXX_Merge

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

func (*PeripheralMetricsMsg_Value) XXX_Size

func (m *PeripheralMetricsMsg_Value) XXX_Size() int

func (*PeripheralMetricsMsg_Value) XXX_Unmarshal

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

type PeripheralOperateCmd

type PeripheralOperateCmd struct {
	Params map[string]string `` /* 153-byte string literal not displayed */
	// (optional) operation data
	Data []byte `protobuf:"bytes,2,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) GetParams

func (m *PeripheralOperateCmd) GetParams() map[string]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 PeripheralOperationResultMsg

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

func (*PeripheralOperationResultMsg) Descriptor

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

func (*PeripheralOperationResultMsg) Equal

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

func (*PeripheralOperationResultMsg) GetResult

func (m *PeripheralOperationResultMsg) GetResult() [][]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 RegisterMsg

type RegisterMsg struct {
	Name          string        `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Codec         CodecType     `protobuf:"varint,2,opt,name=codec,proto3,enum=arhat.CodecType" json:"codec,omitempty"`
	ExtensionType ExtensionType `` /* 126-byte string literal not displayed */
}

    RegisterMsg is always sent in json codec, so the extension server can decoded it and determine real codec used in the stream

    func (*RegisterMsg) Descriptor

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

    func (*RegisterMsg) Equal

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

    func (*RegisterMsg) GetCodec

    func (m *RegisterMsg) GetCodec() CodecType

    func (*RegisterMsg) GetExtensionType

    func (m *RegisterMsg) GetExtensionType() ExtensionType

    func (*RegisterMsg) GetName

    func (m *RegisterMsg) GetName() string

    func (*RegisterMsg) GoString

    func (this *RegisterMsg) GoString() string

    func (*RegisterMsg) Marshal

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

    func (*RegisterMsg) MarshalTo

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

    func (*RegisterMsg) MarshalToSizedBuffer

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

    func (*RegisterMsg) ProtoMessage

    func (*RegisterMsg) ProtoMessage()

    func (*RegisterMsg) Reset

    func (m *RegisterMsg) Reset()

    func (*RegisterMsg) Size

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

    func (*RegisterMsg) String

    func (this *RegisterMsg) String() string

    func (*RegisterMsg) Unmarshal

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

    func (*RegisterMsg) XXX_DiscardUnknown

    func (m *RegisterMsg) XXX_DiscardUnknown()

    func (*RegisterMsg) XXX_Marshal

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

    func (*RegisterMsg) XXX_Merge

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

    func (*RegisterMsg) XXX_Size

    func (m *RegisterMsg) XXX_Size() int

    func (*RegisterMsg) XXX_Unmarshal

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

    type TLSConfig

    type TLSConfig struct {
    	ServerName         string   `protobuf:"bytes,1,opt,name=server_name,json=serverName,proto3" json:"server_name,omitempty"`
    	InsecureSkipVerify bool     `protobuf:"varint,2,opt,name=insecure_skip_verify,json=insecureSkipVerify,proto3" json:"insecure_skip_verify,omitempty"`
    	MinVersion         uint32   `protobuf:"varint,3,opt,name=min_version,json=minVersion,proto3" json:"min_version,omitempty"`
    	MaxVersion         uint32   `protobuf:"varint,4,opt,name=max_version,json=maxVersion,proto3" json:"max_version,omitempty"`
    	CaCert             []byte   `protobuf:"bytes,5,opt,name=ca_cert,json=caCert,proto3" json:"ca_cert,omitempty"`
    	Cert               []byte   `protobuf:"bytes,6,opt,name=cert,proto3" json:"cert,omitempty"`
    	Key                []byte   `protobuf:"bytes,7,opt,name=key,proto3" json:"key,omitempty"`
    	CipherSuites       []uint32 `protobuf:"varint,8,rep,packed,name=cipher_suites,json=cipherSuites,proto3" json:"cipher_suites,omitempty"`
    	NextProtos         []string `protobuf:"bytes,9,rep,name=next_protos,json=nextProtos,proto3" json:"next_protos,omitempty"`
    }

    func (*TLSConfig) Descriptor

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

    func (*TLSConfig) Equal

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

    func (*TLSConfig) GetCaCert

    func (m *TLSConfig) GetCaCert() []byte

    func (*TLSConfig) GetCert

    func (m *TLSConfig) GetCert() []byte

    func (*TLSConfig) GetCipherSuites

    func (m *TLSConfig) GetCipherSuites() []uint32

    func (*TLSConfig) GetInsecureSkipVerify

    func (m *TLSConfig) GetInsecureSkipVerify() bool

    func (*TLSConfig) GetKey

    func (m *TLSConfig) GetKey() []byte

    func (*TLSConfig) GetMaxVersion

    func (m *TLSConfig) GetMaxVersion() uint32

    func (*TLSConfig) GetMinVersion

    func (m *TLSConfig) GetMinVersion() uint32

    func (*TLSConfig) GetNextProtos

    func (m *TLSConfig) GetNextProtos() []string

    func (*TLSConfig) GetServerName

    func (m *TLSConfig) GetServerName() string

    func (*TLSConfig) GoString

    func (this *TLSConfig) GoString() string

    func (*TLSConfig) Marshal

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

    func (*TLSConfig) MarshalTo

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

    func (*TLSConfig) MarshalToSizedBuffer

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

    func (*TLSConfig) ProtoMessage

    func (*TLSConfig) ProtoMessage()

    func (*TLSConfig) Reset

    func (m *TLSConfig) Reset()

    func (*TLSConfig) Size

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

    func (*TLSConfig) String

    func (this *TLSConfig) String() string

    func (*TLSConfig) Unmarshal

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

    func (*TLSConfig) XXX_DiscardUnknown

    func (m *TLSConfig) XXX_DiscardUnknown()

    func (*TLSConfig) XXX_Marshal

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

    func (*TLSConfig) XXX_Merge

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

    func (*TLSConfig) XXX_Size

    func (m *TLSConfig) XXX_Size() int

    func (*TLSConfig) XXX_Unmarshal

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