arhatgopb

package
v0.1.0 Latest Latest
Warning

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

 Go to latest Published: Oct 3, 2020 License: Apache-2.0 Imports: 14 Imported by: 14

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthDevice        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowDevice          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupDevice = 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:  "_INVALID_CMD",
	11: "CMD_DEV_CONNECT",
	12: "CMD_DEV_OPERATE",
	13: "CMD_DEV_COLLECT_METRICS",
	14: "CMD_DEV_CLOSE",
}
View Source 
var CmdType_value = map[string]int32{
	"_INVALID_CMD":            0,
	"CMD_DEV_CONNECT":         11,
	"CMD_DEV_OPERATE":         12,
	"CMD_DEV_COLLECT_METRICS": 13,
	"CMD_DEV_CLOSE":           14,
}
View Source 
var DeviceEventType_name = map[int32]string{
	0: "_INVALID_DEV_EVENT",
}
View Source 
var DeviceEventType_value = map[string]int32{
	"_INVALID_DEV_EVENT": 0,
}
View Source 
var MsgType_name = map[int32]string{
	0:  "_INVALID_MSG",
	1:  "MSG_ERROR",
	2:  "MSG_DONE",
	3:  "MSG_REGISTER",
	11: "MSG_DEV_OPERATION_RESULT",
	12: "MSG_DEV_METRICS",
	13: "MSG_DEV_EVENTS",
}
View Source 
var MsgType_value = map[string]int32{
	"_INVALID_MSG":             0,
	"MSG_ERROR":                1,
	"MSG_DONE":                 2,
	"MSG_REGISTER":             3,
	"MSG_DEV_OPERATION_RESULT": 11,
	"MSG_DEV_METRICS":          12,
	"MSG_DEV_EVENTS":           13,
}

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"`
	// id assigned by the arhat extension manager
	Id      uint64 `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"`
	Seq     uint64 `protobuf:"varint,3,opt,name=seq,proto3" json:"seq,omitempty"`
	Payload []byte `protobuf:"bytes,4,opt,name=payload,proto3" json:"payload,omitempty"`
}

func NewDeviceCmd 

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

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_DEV_CONNECT         CmdType = 11
	CMD_DEV_OPERATE         CmdType = 12
	CMD_DEV_COLLECT_METRICS CmdType = 13
	CMD_DEV_CLOSE           CmdType = 14
)

func (CmdType) EnumDescriptor 

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

func (CmdType) String 

func (x CmdType) String() string

type DeviceCloseCmd 

type DeviceCloseCmd struct {
}

func (*DeviceCloseCmd) Descriptor 

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

func (*DeviceCloseCmd) Equal 

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

func (*DeviceCloseCmd) GoString 

func (this *DeviceCloseCmd) GoString() string

func (*DeviceCloseCmd) Marshal 

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

func (*DeviceCloseCmd) MarshalTo 

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

func (*DeviceCloseCmd) MarshalToSizedBuffer 

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

func (*DeviceCloseCmd) ProtoMessage 

func (*DeviceCloseCmd) ProtoMessage()

func (*DeviceCloseCmd) Reset 

func (m *DeviceCloseCmd) Reset()

func (*DeviceCloseCmd) Size 

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

func (*DeviceCloseCmd) String 

func (this *DeviceCloseCmd) String() string

func (*DeviceCloseCmd) Unmarshal 

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

func (*DeviceCloseCmd) XXX_DiscardUnknown 

func (m *DeviceCloseCmd) XXX_DiscardUnknown()

func (*DeviceCloseCmd) XXX_Marshal 

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

func (*DeviceCloseCmd) XXX_Merge 

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

func (*DeviceCloseCmd) XXX_Size 

func (m *DeviceCloseCmd) XXX_Size() int

func (*DeviceCloseCmd) XXX_Unmarshal 

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

type DeviceConnectCmd 

type DeviceConnectCmd 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 (*DeviceConnectCmd) Descriptor 

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

func (*DeviceConnectCmd) Equal 

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

func (*DeviceConnectCmd) GetParams 

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

func (*DeviceConnectCmd) GetTarget 

func (m *DeviceConnectCmd) GetTarget() string

func (*DeviceConnectCmd) GetTls 

func (m *DeviceConnectCmd) GetTls() *TLSConfig

func (*DeviceConnectCmd) GoString 

func (this *DeviceConnectCmd) GoString() string

func (*DeviceConnectCmd) Marshal 

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

func (*DeviceConnectCmd) MarshalTo 

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

func (*DeviceConnectCmd) MarshalToSizedBuffer 

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

func (*DeviceConnectCmd) ProtoMessage 

func (*DeviceConnectCmd) ProtoMessage()

func (*DeviceConnectCmd) Reset 

func (m *DeviceConnectCmd) Reset()

func (*DeviceConnectCmd) Size 

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

func (*DeviceConnectCmd) String 

func (this *DeviceConnectCmd) String() string

func (*DeviceConnectCmd) Unmarshal 

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

func (*DeviceConnectCmd) XXX_DiscardUnknown 

func (m *DeviceConnectCmd) XXX_DiscardUnknown()

func (*DeviceConnectCmd) XXX_Marshal 

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

func (*DeviceConnectCmd) XXX_Merge 

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

func (*DeviceConnectCmd) XXX_Size 

func (m *DeviceConnectCmd) XXX_Size() int

func (*DeviceConnectCmd) XXX_Unmarshal 

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

type DeviceEventMsg 

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

func (*DeviceEventMsg) Descriptor 

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

func (*DeviceEventMsg) Equal 

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

func (*DeviceEventMsg) GetKind 

func (m *DeviceEventMsg) GetKind() DeviceEventType

func (*DeviceEventMsg) GoString 

func (this *DeviceEventMsg) GoString() string

func (*DeviceEventMsg) Marshal 

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

func (*DeviceEventMsg) MarshalTo 

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

func (*DeviceEventMsg) MarshalToSizedBuffer 

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

func (*DeviceEventMsg) ProtoMessage 

func (*DeviceEventMsg) ProtoMessage()

func (*DeviceEventMsg) Reset 

func (m *DeviceEventMsg) Reset()

func (*DeviceEventMsg) Size 

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

func (*DeviceEventMsg) String 

func (this *DeviceEventMsg) String() string

func (*DeviceEventMsg) Unmarshal 

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

func (*DeviceEventMsg) XXX_DiscardUnknown 

func (m *DeviceEventMsg) XXX_DiscardUnknown()

func (*DeviceEventMsg) XXX_Marshal 

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

func (*DeviceEventMsg) XXX_Merge 

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

func (*DeviceEventMsg) XXX_Size 

func (m *DeviceEventMsg) XXX_Size() int

func (*DeviceEventMsg) XXX_Unmarshal 

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

type DeviceEventType 

type DeviceEventType int32

func (DeviceEventType) EnumDescriptor 

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

func (DeviceEventType) String 

func (x DeviceEventType) String() string

type DeviceMetricsCollectCmd 

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

func (*DeviceMetricsCollectCmd) Descriptor 

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

func (*DeviceMetricsCollectCmd) Equal 

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

func (*DeviceMetricsCollectCmd) GetParams 

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

func (*DeviceMetricsCollectCmd) GoString 

func (this *DeviceMetricsCollectCmd) GoString() string

func (*DeviceMetricsCollectCmd) Marshal 

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

func (*DeviceMetricsCollectCmd) MarshalTo 

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

func (*DeviceMetricsCollectCmd) MarshalToSizedBuffer 

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

func (*DeviceMetricsCollectCmd) ProtoMessage 

func (*DeviceMetricsCollectCmd) ProtoMessage()

func (*DeviceMetricsCollectCmd) Reset 

func (m *DeviceMetricsCollectCmd) Reset()

func (*DeviceMetricsCollectCmd) Size 

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

func (*DeviceMetricsCollectCmd) String 

func (this *DeviceMetricsCollectCmd) String() string

func (*DeviceMetricsCollectCmd) Unmarshal 

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

func (*DeviceMetricsCollectCmd) XXX_DiscardUnknown 

func (m *DeviceMetricsCollectCmd) XXX_DiscardUnknown()

func (*DeviceMetricsCollectCmd) XXX_Marshal 

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

func (*DeviceMetricsCollectCmd) XXX_Merge 

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

func (*DeviceMetricsCollectCmd) XXX_Size 

func (m *DeviceMetricsCollectCmd) XXX_Size() int

func (*DeviceMetricsCollectCmd) XXX_Unmarshal 

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

type DeviceMetricsMsg 

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

func (*DeviceMetricsMsg) Descriptor 

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

func (*DeviceMetricsMsg) Equal 

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

func (*DeviceMetricsMsg) GetValues 

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

func (*DeviceMetricsMsg) GoString 

func (this *DeviceMetricsMsg) GoString() string

func (*DeviceMetricsMsg) Marshal 

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

func (*DeviceMetricsMsg) MarshalTo 

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

func (*DeviceMetricsMsg) MarshalToSizedBuffer 

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

func (*DeviceMetricsMsg) ProtoMessage 

func (*DeviceMetricsMsg) ProtoMessage()

func (*DeviceMetricsMsg) Reset 

func (m *DeviceMetricsMsg) Reset()

func (*DeviceMetricsMsg) Size 

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

func (*DeviceMetricsMsg) String 

func (this *DeviceMetricsMsg) String() string

func (*DeviceMetricsMsg) Unmarshal 

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

func (*DeviceMetricsMsg) XXX_DiscardUnknown 

func (m *DeviceMetricsMsg) XXX_DiscardUnknown()

func (*DeviceMetricsMsg) XXX_Marshal 

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

func (*DeviceMetricsMsg) XXX_Merge 

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

func (*DeviceMetricsMsg) XXX_Size 

func (m *DeviceMetricsMsg) XXX_Size() int

func (*DeviceMetricsMsg) XXX_Unmarshal 

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

type DeviceMetricsMsg_Value 

type DeviceMetricsMsg_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 (*DeviceMetricsMsg_Value) Descriptor 

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

func (*DeviceMetricsMsg_Value) Equal 

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

func (*DeviceMetricsMsg_Value) GetTimestamp 

func (m *DeviceMetricsMsg_Value) GetTimestamp() int64

func (*DeviceMetricsMsg_Value) GetValue 

func (m *DeviceMetricsMsg_Value) GetValue() float64

func (*DeviceMetricsMsg_Value) GoString 

func (this *DeviceMetricsMsg_Value) GoString() string

func (*DeviceMetricsMsg_Value) Marshal 

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

func (*DeviceMetricsMsg_Value) MarshalTo 

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

func (*DeviceMetricsMsg_Value) MarshalToSizedBuffer 

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

func (*DeviceMetricsMsg_Value) ProtoMessage 

func (*DeviceMetricsMsg_Value) ProtoMessage()

func (*DeviceMetricsMsg_Value) Reset 

func (m *DeviceMetricsMsg_Value) Reset()

func (*DeviceMetricsMsg_Value) Size 

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

func (*DeviceMetricsMsg_Value) String 

func (this *DeviceMetricsMsg_Value) String() string

func (*DeviceMetricsMsg_Value) Unmarshal 

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

func (*DeviceMetricsMsg_Value) XXX_DiscardUnknown 

func (m *DeviceMetricsMsg_Value) XXX_DiscardUnknown()

func (*DeviceMetricsMsg_Value) XXX_Marshal 

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

func (*DeviceMetricsMsg_Value) XXX_Merge 

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

func (*DeviceMetricsMsg_Value) XXX_Size 

func (m *DeviceMetricsMsg_Value) XXX_Size() int

func (*DeviceMetricsMsg_Value) XXX_Unmarshal 

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

type DeviceOperateCmd 

type DeviceOperateCmd 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 (*DeviceOperateCmd) Descriptor 

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

func (*DeviceOperateCmd) Equal 

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

func (*DeviceOperateCmd) GetData 

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

func (*DeviceOperateCmd) GetParams 

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

func (*DeviceOperateCmd) GoString 

func (this *DeviceOperateCmd) GoString() string

func (*DeviceOperateCmd) Marshal 

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

func (*DeviceOperateCmd) MarshalTo 

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

func (*DeviceOperateCmd) MarshalToSizedBuffer 

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

func (*DeviceOperateCmd) ProtoMessage 

func (*DeviceOperateCmd) ProtoMessage()

func (*DeviceOperateCmd) Reset 

func (m *DeviceOperateCmd) Reset()

func (*DeviceOperateCmd) Size 

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

func (*DeviceOperateCmd) String 

func (this *DeviceOperateCmd) String() string

func (*DeviceOperateCmd) Unmarshal 

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

func (*DeviceOperateCmd) XXX_DiscardUnknown 

func (m *DeviceOperateCmd) XXX_DiscardUnknown()

func (*DeviceOperateCmd) XXX_Marshal 

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

func (*DeviceOperateCmd) XXX_Merge 

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

func (*DeviceOperateCmd) XXX_Size 

func (m *DeviceOperateCmd) XXX_Size() int

func (*DeviceOperateCmd) XXX_Unmarshal 

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

type DeviceOperationResultMsg 

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

func (*DeviceOperationResultMsg) Descriptor 

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

func (*DeviceOperationResultMsg) Equal 

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

func (*DeviceOperationResultMsg) GetResult 

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

func (*DeviceOperationResultMsg) GoString 

func (this *DeviceOperationResultMsg) GoString() string

func (*DeviceOperationResultMsg) Marshal 

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

func (*DeviceOperationResultMsg) MarshalTo 

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

func (*DeviceOperationResultMsg) MarshalToSizedBuffer 

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

func (*DeviceOperationResultMsg) ProtoMessage 

func (*DeviceOperationResultMsg) ProtoMessage()

func (*DeviceOperationResultMsg) Reset 

func (m *DeviceOperationResultMsg) Reset()

func (*DeviceOperationResultMsg) Size 

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

func (*DeviceOperationResultMsg) String 

func (this *DeviceOperationResultMsg) String() string

func (*DeviceOperationResultMsg) Unmarshal 

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

func (*DeviceOperationResultMsg) XXX_DiscardUnknown 

func (m *DeviceOperationResultMsg) XXX_DiscardUnknown()

func (*DeviceOperationResultMsg) XXX_Marshal 

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

func (*DeviceOperationResultMsg) XXX_Merge 

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

func (*DeviceOperationResultMsg) XXX_Size 

func (m *DeviceOperationResultMsg) XXX_Size() int

func (*DeviceOperationResultMsg) XXX_Unmarshal 

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

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 Msg 

type Msg struct {
	Kind MsgType `protobuf:"varint,1,opt,name=kind,proto3,enum=arhat.MsgType" json:"kind,omitempty"`
	// id assigned by the arhat extension manager
	Id uint64 `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"`
	// (optional) if this is an answer for a Cmd, set ack to seq in Cmd
	Ack     uint64 `protobuf:"varint,3,opt,name=ack,proto3" json:"ack,omitempty"`
	Payload []byte `protobuf:"bytes,4,opt,name=payload,proto3" json:"payload,omitempty"`
}

func NewDeviceMsg 

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

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_ERROR                MsgType = 1
	MSG_DONE                 MsgType = 2
	MSG_REGISTER             MsgType = 3
	MSG_DEV_OPERATION_RESULT MsgType = 11
	MSG_DEV_METRICS          MsgType = 12
	MSG_DEV_EVENTS           MsgType = 13
)

func (MsgType) EnumDescriptor 

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

func (MsgType) String 

func (x MsgType) String() string

type RegisterMsg 

type RegisterMsg struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
}

func (*RegisterMsg) Descriptor 

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

func (*RegisterMsg) Equal 

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

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) GetTLSConfig 

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

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.