arhatgopb

package

Go to main page

Versions in this module

v0

v0.4.4

Jan 24, 2021

v0.4.3

Nov 17, 2020

v0.4.2

Nov 7, 2020

Changes in this version

type CmdType

+ const CMD_DATA_CLOSE

+ const CMD_DATA_INPUT

type MsgType

+ const MSG_DATA_OUTPUT

+ const MSG_RUNTIME_DATA_STDERR

v0.4.1

Nov 7, 2020

Changes in this version

type Cmd

+ Sid uint64

+ func (m *Cmd) GetSid() uint64

type Msg

+ Sid uint64

+ func (m *Msg) GetSid() uint64

v0.4.0

Nov 7, 2020

Changes in this version

type CmdType

+ const CMD_RUNTIME_ARANYA_PROTO

type ExtensionType

+ const EXTENSION_RUNTIME

type MsgType

+ const MSG_RUNTIME_ARANYA_PROTO

v0.3.1

Nov 2, 2020

v0.3.0

Nov 1, 2020

Changes in this version

type CmdType

+ const CMD_PING

type MsgType

+ const MSG_PONG

v0.2.1

Oct 31, 2020

Changes in this version

+ var ExtensionType_name = map[int32]string

+ var ExtensionType_value = map[string]int32

+ type ExtensionType int32

+ const EXTENSION_PERIPHERAL

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

+ func (x ExtensionType) String() string

type RegisterMsg

+ ExtensionType ExtensionType

+ func (m *RegisterMsg) GetExtensionType() ExtensionType

v0.2.0

Oct 31, 2020

Changes in this version

+ var CodecType_name = map[int32]string

+ var CodecType_value = map[string]int32

+ type CodecType int32

+ const CODEC_JSON

+ const CODEC_PROTOBUF

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

+ func (x CodecType) String() string

type RegisterMsg

+ Codec CodecType

+ func (m *RegisterMsg) GetCodec() CodecType

v0.1.1

Oct 23, 2020

Changes in this version

+ var ErrIntOverflowPeripheral = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLengthPeripheral = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrUnexpectedEndOfGroupPeripheral = fmt.Errorf("proto: unexpected end of group")

+ var PeripheralEventType_name = map[int32]string

+ var PeripheralEventType_value = map[string]int32

type Cmd

+ func NewCmd(id, seq uint64, cmd proto.Marshaler) (*Cmd, error)

type CmdType

+ const CMD_PERIPHERAL_CLOSE

+ const CMD_PERIPHERAL_COLLECT_METRICS

+ const CMD_PERIPHERAL_CONNECT

+ const CMD_PERIPHERAL_OPERATE

type Msg

+ func NewMsg(id, ack uint64, msg proto.Marshaler) (*Msg, error)

type MsgType

+ const MSG_PERIPHERAL_EVENTS

+ const MSG_PERIPHERAL_METRICS

+ const MSG_PERIPHERAL_OPERATION_RESULT

+ type PeripheralCloseCmd struct

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

+ func (*PeripheralCloseCmd) ProtoMessage()

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

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

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

+ func (m *PeripheralCloseCmd) Reset()

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

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

+ func (m *PeripheralCloseCmd) XXX_DiscardUnknown()

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

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

+ func (m *PeripheralCloseCmd) XXX_Size() int

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

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

+ func (this *PeripheralCloseCmd) GoString() string

+ func (this *PeripheralCloseCmd) String() string

+ type PeripheralConnectCmd struct

+ Params map[string]string

+ Target string

+ Tls *TLSConfig

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

+ func (*PeripheralConnectCmd) ProtoMessage()

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

+ func (m *PeripheralConnectCmd) GetTarget() string

+ func (m *PeripheralConnectCmd) GetTls() *TLSConfig

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

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

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

+ func (m *PeripheralConnectCmd) Reset()

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

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

+ func (m *PeripheralConnectCmd) XXX_DiscardUnknown()

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

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

+ func (m *PeripheralConnectCmd) XXX_Size() int

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

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

+ func (this *PeripheralConnectCmd) GoString() string

+ func (this *PeripheralConnectCmd) String() string

+ type PeripheralEventMsg struct

+ Kind PeripheralEventType

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

+ func (*PeripheralEventMsg) ProtoMessage()

+ func (m *PeripheralEventMsg) GetKind() PeripheralEventType

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

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

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

+ func (m *PeripheralEventMsg) Reset()

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

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

+ func (m *PeripheralEventMsg) XXX_DiscardUnknown()

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

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

+ func (m *PeripheralEventMsg) XXX_Size() int

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

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

+ func (this *PeripheralEventMsg) GoString() string

+ func (this *PeripheralEventMsg) String() string

+ type PeripheralEventType int32

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

+ func (x PeripheralEventType) String() string

+ type PeripheralMetricsCollectCmd struct

+ Params map[string]string

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

+ func (*PeripheralMetricsCollectCmd) ProtoMessage()

+ func (m *PeripheralMetricsCollectCmd) GetParams() map[string]string

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

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

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

+ func (m *PeripheralMetricsCollectCmd) Reset()

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

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

+ func (m *PeripheralMetricsCollectCmd) XXX_DiscardUnknown()

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

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

+ func (m *PeripheralMetricsCollectCmd) XXX_Size() int

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

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

+ func (this *PeripheralMetricsCollectCmd) GoString() string

+ func (this *PeripheralMetricsCollectCmd) String() string

+ type PeripheralMetricsMsg struct

+ Values []*PeripheralMetricsMsg_Value

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

+ func (*PeripheralMetricsMsg) ProtoMessage()

+ func (m *PeripheralMetricsMsg) GetValues() []*PeripheralMetricsMsg_Value

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

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

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

+ func (m *PeripheralMetricsMsg) Reset()

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

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

+ func (m *PeripheralMetricsMsg) XXX_DiscardUnknown()

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

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

+ func (m *PeripheralMetricsMsg) XXX_Size() int

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

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

+ func (this *PeripheralMetricsMsg) GoString() string

+ func (this *PeripheralMetricsMsg) String() string

+ type PeripheralMetricsMsg_Value struct

+ Timestamp int64

+ Value float64

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

+ func (*PeripheralMetricsMsg_Value) ProtoMessage()

+ func (m *PeripheralMetricsMsg_Value) GetTimestamp() int64

+ func (m *PeripheralMetricsMsg_Value) GetValue() float64

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

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

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

+ func (m *PeripheralMetricsMsg_Value) Reset()

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

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

+ func (m *PeripheralMetricsMsg_Value) XXX_DiscardUnknown()

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

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

+ func (m *PeripheralMetricsMsg_Value) XXX_Size() int

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

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

+ func (this *PeripheralMetricsMsg_Value) GoString() string

+ func (this *PeripheralMetricsMsg_Value) String() string

+ type PeripheralOperateCmd struct

+ Data []byte

+ Params map[string]string

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

+ func (*PeripheralOperateCmd) ProtoMessage()

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

+ func (m *PeripheralOperateCmd) GetParams() map[string]string

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

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

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

+ func (m *PeripheralOperateCmd) Reset()

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

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

+ func (m *PeripheralOperateCmd) XXX_DiscardUnknown()

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

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

+ func (m *PeripheralOperateCmd) XXX_Size() int

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

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

+ func (this *PeripheralOperateCmd) GoString() string

+ func (this *PeripheralOperateCmd) String() string

+ type PeripheralOperationResultMsg struct

+ Result [][]byte

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

+ func (*PeripheralOperationResultMsg) ProtoMessage()

+ func (m *PeripheralOperationResultMsg) GetResult() [][]byte

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

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

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

+ func (m *PeripheralOperationResultMsg) Reset()

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

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

+ func (m *PeripheralOperationResultMsg) XXX_DiscardUnknown()

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

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

+ func (m *PeripheralOperationResultMsg) XXX_Size() int

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

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

+ func (this *PeripheralOperationResultMsg) GoString() string

+ func (this *PeripheralOperationResultMsg) String() string

v0.1.0

Oct 3, 2020

Changes in this version

+ var CmdType_name = map[int32]string

+ var CmdType_value = map[string]int32

+ var DeviceEventType_name = map[int32]string

+ var DeviceEventType_value = map[string]int32

+ var ErrIntOverflowDevice = fmt.Errorf("proto: integer overflow")

+ var ErrIntOverflowProto = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLengthDevice = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrInvalidLengthProto = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrUnexpectedEndOfGroupDevice = fmt.Errorf("proto: unexpected end of group")

+ var ErrUnexpectedEndOfGroupProto = fmt.Errorf("proto: unexpected end of group")

+ var MsgType_name = map[int32]string

+ var MsgType_value = map[string]int32

+ type Cmd struct

+ Id uint64

+ Kind CmdType

+ Payload []byte

+ Seq uint64

+ func NewDeviceCmd(deviceID, seq uint64, cmd proto.Marshaler) (*Cmd, error)

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

+ func (*Cmd) ProtoMessage()

+ func (m *Cmd) GetId() uint64

+ func (m *Cmd) GetKind() CmdType

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

+ func (m *Cmd) GetSeq() uint64

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

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

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

+ func (m *Cmd) Reset()

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

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

+ func (m *Cmd) XXX_DiscardUnknown()

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

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

+ func (m *Cmd) XXX_Size() int

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

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

+ func (this *Cmd) GoString() string

+ func (this *Cmd) String() string

+ type CmdType int32

+ const CMD_DEV_CLOSE

+ const CMD_DEV_COLLECT_METRICS

+ const CMD_DEV_CONNECT

+ const CMD_DEV_OPERATE

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

+ func (x CmdType) String() string

+ type DeviceCloseCmd struct

+ func (*DeviceCloseCmd) Descriptor() ([]byte, []int)

+ func (*DeviceCloseCmd) ProtoMessage()

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

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

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

+ func (m *DeviceCloseCmd) Reset()

+ func (m *DeviceCloseCmd) Size() (n int)

+ func (m *DeviceCloseCmd) Unmarshal(dAtA []byte) error

+ func (m *DeviceCloseCmd) XXX_DiscardUnknown()

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

+ func (m *DeviceCloseCmd) XXX_Merge(src proto.Message)

+ func (m *DeviceCloseCmd) XXX_Size() int

+ func (m *DeviceCloseCmd) XXX_Unmarshal(b []byte) error

+ func (this *DeviceCloseCmd) Equal(that interface{}) bool

+ func (this *DeviceCloseCmd) GoString() string

+ func (this *DeviceCloseCmd) String() string

+ type DeviceConnectCmd struct

+ Params map[string]string

+ Target string

+ Tls *TLSConfig

+ func (*DeviceConnectCmd) Descriptor() ([]byte, []int)

+ func (*DeviceConnectCmd) ProtoMessage()

+ func (m *DeviceConnectCmd) GetParams() map[string]string

+ func (m *DeviceConnectCmd) GetTarget() string

+ func (m *DeviceConnectCmd) GetTls() *TLSConfig

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

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

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

+ func (m *DeviceConnectCmd) Reset()

+ func (m *DeviceConnectCmd) Size() (n int)

+ func (m *DeviceConnectCmd) Unmarshal(dAtA []byte) error

+ func (m *DeviceConnectCmd) XXX_DiscardUnknown()

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

+ func (m *DeviceConnectCmd) XXX_Merge(src proto.Message)

+ func (m *DeviceConnectCmd) XXX_Size() int

+ func (m *DeviceConnectCmd) XXX_Unmarshal(b []byte) error

+ func (this *DeviceConnectCmd) Equal(that interface{}) bool

+ func (this *DeviceConnectCmd) GoString() string

+ func (this *DeviceConnectCmd) String() string

+ type DeviceEventMsg struct

+ Kind DeviceEventType

+ func (*DeviceEventMsg) Descriptor() ([]byte, []int)

+ func (*DeviceEventMsg) ProtoMessage()

+ func (m *DeviceEventMsg) GetKind() DeviceEventType

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

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

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

+ func (m *DeviceEventMsg) Reset()

+ func (m *DeviceEventMsg) Size() (n int)

+ func (m *DeviceEventMsg) Unmarshal(dAtA []byte) error

+ func (m *DeviceEventMsg) XXX_DiscardUnknown()

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

+ func (m *DeviceEventMsg) XXX_Merge(src proto.Message)

+ func (m *DeviceEventMsg) XXX_Size() int

+ func (m *DeviceEventMsg) XXX_Unmarshal(b []byte) error

+ func (this *DeviceEventMsg) Equal(that interface{}) bool

+ func (this *DeviceEventMsg) GoString() string

+ func (this *DeviceEventMsg) String() string

+ type DeviceEventType int32

+ func (DeviceEventType) EnumDescriptor() ([]byte, []int)

+ func (x DeviceEventType) String() string

+ type DeviceMetricsCollectCmd struct

+ Params map[string]string

+ func (*DeviceMetricsCollectCmd) Descriptor() ([]byte, []int)

+ func (*DeviceMetricsCollectCmd) ProtoMessage()

+ func (m *DeviceMetricsCollectCmd) GetParams() map[string]string

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

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

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

+ func (m *DeviceMetricsCollectCmd) Reset()

+ func (m *DeviceMetricsCollectCmd) Size() (n int)

+ func (m *DeviceMetricsCollectCmd) Unmarshal(dAtA []byte) error

+ func (m *DeviceMetricsCollectCmd) XXX_DiscardUnknown()

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

+ func (m *DeviceMetricsCollectCmd) XXX_Merge(src proto.Message)

+ func (m *DeviceMetricsCollectCmd) XXX_Size() int

+ func (m *DeviceMetricsCollectCmd) XXX_Unmarshal(b []byte) error

+ func (this *DeviceMetricsCollectCmd) Equal(that interface{}) bool

+ func (this *DeviceMetricsCollectCmd) GoString() string

+ func (this *DeviceMetricsCollectCmd) String() string

+ type DeviceMetricsMsg struct

+ Values []*DeviceMetricsMsg_Value

+ func (*DeviceMetricsMsg) Descriptor() ([]byte, []int)

+ func (*DeviceMetricsMsg) ProtoMessage()

+ func (m *DeviceMetricsMsg) GetValues() []*DeviceMetricsMsg_Value

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

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

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

+ func (m *DeviceMetricsMsg) Reset()

+ func (m *DeviceMetricsMsg) Size() (n int)

+ func (m *DeviceMetricsMsg) Unmarshal(dAtA []byte) error

+ func (m *DeviceMetricsMsg) XXX_DiscardUnknown()

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

+ func (m *DeviceMetricsMsg) XXX_Merge(src proto.Message)

+ func (m *DeviceMetricsMsg) XXX_Size() int

+ func (m *DeviceMetricsMsg) XXX_Unmarshal(b []byte) error

+ func (this *DeviceMetricsMsg) Equal(that interface{}) bool

+ func (this *DeviceMetricsMsg) GoString() string

+ func (this *DeviceMetricsMsg) String() string

+ type DeviceMetricsMsg_Value struct

+ Timestamp int64

+ Value float64

+ func (*DeviceMetricsMsg_Value) Descriptor() ([]byte, []int)

+ func (*DeviceMetricsMsg_Value) ProtoMessage()

+ func (m *DeviceMetricsMsg_Value) GetTimestamp() int64

+ func (m *DeviceMetricsMsg_Value) GetValue() float64

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

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

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

+ func (m *DeviceMetricsMsg_Value) Reset()

+ func (m *DeviceMetricsMsg_Value) Size() (n int)

+ func (m *DeviceMetricsMsg_Value) Unmarshal(dAtA []byte) error

+ func (m *DeviceMetricsMsg_Value) XXX_DiscardUnknown()

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

+ func (m *DeviceMetricsMsg_Value) XXX_Merge(src proto.Message)

+ func (m *DeviceMetricsMsg_Value) XXX_Size() int

+ func (m *DeviceMetricsMsg_Value) XXX_Unmarshal(b []byte) error

+ func (this *DeviceMetricsMsg_Value) Equal(that interface{}) bool

+ func (this *DeviceMetricsMsg_Value) GoString() string

+ func (this *DeviceMetricsMsg_Value) String() string

+ type DeviceOperateCmd struct

+ Data []byte

+ Params map[string]string

+ func (*DeviceOperateCmd) Descriptor() ([]byte, []int)

+ func (*DeviceOperateCmd) ProtoMessage()

+ func (m *DeviceOperateCmd) GetData() []byte

+ func (m *DeviceOperateCmd) GetParams() map[string]string

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

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

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

+ func (m *DeviceOperateCmd) Reset()

+ func (m *DeviceOperateCmd) Size() (n int)

+ func (m *DeviceOperateCmd) Unmarshal(dAtA []byte) error

+ func (m *DeviceOperateCmd) XXX_DiscardUnknown()

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

+ func (m *DeviceOperateCmd) XXX_Merge(src proto.Message)

+ func (m *DeviceOperateCmd) XXX_Size() int

+ func (m *DeviceOperateCmd) XXX_Unmarshal(b []byte) error

+ func (this *DeviceOperateCmd) Equal(that interface{}) bool

+ func (this *DeviceOperateCmd) GoString() string

+ func (this *DeviceOperateCmd) String() string

+ type DeviceOperationResultMsg struct

+ Result [][]byte

+ func (*DeviceOperationResultMsg) Descriptor() ([]byte, []int)

+ func (*DeviceOperationResultMsg) ProtoMessage()

+ func (m *DeviceOperationResultMsg) GetResult() [][]byte

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

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

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

+ func (m *DeviceOperationResultMsg) Reset()

+ func (m *DeviceOperationResultMsg) Size() (n int)

+ func (m *DeviceOperationResultMsg) Unmarshal(dAtA []byte) error

+ func (m *DeviceOperationResultMsg) XXX_DiscardUnknown()

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

+ func (m *DeviceOperationResultMsg) XXX_Merge(src proto.Message)

+ func (m *DeviceOperationResultMsg) XXX_Size() int

+ func (m *DeviceOperationResultMsg) XXX_Unmarshal(b []byte) error

+ func (this *DeviceOperationResultMsg) Equal(that interface{}) bool

+ func (this *DeviceOperationResultMsg) GoString() string

+ func (this *DeviceOperationResultMsg) String() string

+ type DoneMsg struct

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

+ func (*DoneMsg) ProtoMessage()

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

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

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

+ func (m *DoneMsg) Reset()

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

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

+ func (m *DoneMsg) XXX_DiscardUnknown()

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

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

+ func (m *DoneMsg) XXX_Size() int

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

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

+ func (this *DoneMsg) GoString() string

+ func (this *DoneMsg) String() string

+ type ErrorMsg struct

+ Description string

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

+ func (*ErrorMsg) ProtoMessage()

+ func (m *ErrorMsg) GetDescription() string

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

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

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

+ func (m *ErrorMsg) Reset()

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

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

+ func (m *ErrorMsg) XXX_DiscardUnknown()

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

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

+ func (m *ErrorMsg) XXX_Size() int

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

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

+ func (this *ErrorMsg) GoString() string

+ func (this *ErrorMsg) String() string

+ type Msg struct

+ Ack uint64

+ Id uint64

+ Kind MsgType

+ Payload []byte

+ func NewDeviceMsg(deviceID, ack uint64, msg proto.Marshaler) (*Msg, error)

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

+ func (*Msg) ProtoMessage()

+ func (m *Msg) GetAck() uint64

+ func (m *Msg) GetId() uint64

+ func (m *Msg) GetKind() MsgType

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

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

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

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

+ func (m *Msg) Reset()

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

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

+ func (m *Msg) XXX_DiscardUnknown()

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

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

+ func (m *Msg) XXX_Size() int

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

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

+ func (this *Msg) GoString() string

+ func (this *Msg) String() string

+ type MsgType int32

+ const MSG_DEV_EVENTS

+ const MSG_DEV_METRICS

+ const MSG_DEV_OPERATION_RESULT

+ const MSG_DONE

+ const MSG_ERROR

+ const MSG_REGISTER

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

+ func (x MsgType) String() string

+ type RegisterMsg struct

+ Name string

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

+ func (*RegisterMsg) ProtoMessage()

+ func (m *RegisterMsg) GetName() string

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

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

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

+ func (m *RegisterMsg) Reset()

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

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

+ func (m *RegisterMsg) XXX_DiscardUnknown()

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

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

+ func (m *RegisterMsg) XXX_Size() int

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

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

+ func (this *RegisterMsg) GoString() string

+ func (this *RegisterMsg) String() string

+ type TLSConfig struct

+ CaCert []byte

+ Cert []byte

+ CipherSuites []uint32

+ InsecureSkipVerify bool

+ Key []byte

+ MaxVersion uint32

+ MinVersion uint32

+ NextProtos []string

+ ServerName string

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

+ func (*TLSConfig) ProtoMessage()

+ func (c *TLSConfig) GetTLSConfig() (_ *tls.Config, err error)

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

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

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

+ func (m *TLSConfig) GetInsecureSkipVerify() bool

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

+ func (m *TLSConfig) GetMaxVersion() uint32

+ func (m *TLSConfig) GetMinVersion() uint32

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

+ func (m *TLSConfig) GetServerName() string

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

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

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

+ func (m *TLSConfig) Reset()

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

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

+ func (m *TLSConfig) XXX_DiscardUnknown()

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

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

+ func (m *TLSConfig) XXX_Size() int

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

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

+ func (this *TLSConfig) GoString() string

+ func (this *TLSConfig) String() string

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL