arhatgopb

package
Version: v0.4.4 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: 14

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 added in v0.2.0 

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

func (CodecType) EnumDescriptor added in v0.2.0 

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

func (CodecType) String added in v0.2.0 

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 added in v0.2.1 

type ExtensionType int32
const (

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

func (ExtensionType) EnumDescriptor added in v0.2.1 

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

func (ExtensionType) String added in v0.2.1 

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 added in v0.1.1 

type PeripheralCloseCmd struct {
}

func (*PeripheralCloseCmd) Descriptor added in v0.1.1 

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

func (*PeripheralCloseCmd) Equal added in v0.1.1 

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

func (*PeripheralCloseCmd) GoString added in v0.1.1 

func (this *PeripheralCloseCmd) GoString() string

func (*PeripheralCloseCmd) Marshal added in v0.1.1 

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

func (*PeripheralCloseCmd) MarshalTo added in v0.1.1 

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

func (*PeripheralCloseCmd) MarshalToSizedBuffer added in v0.1.1 

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

func (*PeripheralCloseCmd) ProtoMessage added in v0.1.1 

func (*PeripheralCloseCmd) ProtoMessage()

func (*PeripheralCloseCmd) Reset added in v0.1.1 

func (m *PeripheralCloseCmd) Reset()

func (*PeripheralCloseCmd) Size added in v0.1.1 

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

func (*PeripheralCloseCmd) String added in v0.1.1 

func (this *PeripheralCloseCmd) String() string

func (*PeripheralCloseCmd) Unmarshal added in v0.1.1 

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

func (*PeripheralCloseCmd) XXX_DiscardUnknown added in v0.1.1 

func (m *PeripheralCloseCmd) XXX_DiscardUnknown()

func (*PeripheralCloseCmd) XXX_Marshal added in v0.1.1 

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

func (*PeripheralCloseCmd) XXX_Merge added in v0.1.1 

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

func (*PeripheralCloseCmd) XXX_Size added in v0.1.1 

func (m *PeripheralCloseCmd) XXX_Size() int

func (*PeripheralCloseCmd) XXX_Unmarshal added in v0.1.1 

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

type PeripheralConnectCmd added in v0.1.1 

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 added in v0.1.1 

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

func (*PeripheralConnectCmd) Equal added in v0.1.1 

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

func (*PeripheralConnectCmd) GetParams added in v0.1.1 

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

func (*PeripheralConnectCmd) GetTarget added in v0.1.1 

func (m *PeripheralConnectCmd) GetTarget() string

func (*PeripheralConnectCmd) GetTls added in v0.1.1 

func (m *PeripheralConnectCmd) GetTls() *TLSConfig

func (*PeripheralConnectCmd) GoString added in v0.1.1 

func (this *PeripheralConnectCmd) GoString() string

func (*PeripheralConnectCmd) Marshal added in v0.1.1 

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

func (*PeripheralConnectCmd) MarshalTo added in v0.1.1 

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

func (*PeripheralConnectCmd) MarshalToSizedBuffer added in v0.1.1 

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

func (*PeripheralConnectCmd) ProtoMessage added in v0.1.1 

func (*PeripheralConnectCmd) ProtoMessage()

func (*PeripheralConnectCmd) Reset added in v0.1.1 

func (m *PeripheralConnectCmd) Reset()

func (*PeripheralConnectCmd) Size added in v0.1.1 

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

func (*PeripheralConnectCmd) String added in v0.1.1 

func (this *PeripheralConnectCmd) String() string

func (*PeripheralConnectCmd) Unmarshal added in v0.1.1 

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

func (*PeripheralConnectCmd) XXX_DiscardUnknown added in v0.1.1 

func (m *PeripheralConnectCmd) XXX_DiscardUnknown()

func (*PeripheralConnectCmd) XXX_Marshal added in v0.1.1 

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

func (*PeripheralConnectCmd) XXX_Merge added in v0.1.1 

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

func (*PeripheralConnectCmd) XXX_Size added in v0.1.1 

func (m *PeripheralConnectCmd) XXX_Size() int

func (*PeripheralConnectCmd) XXX_Unmarshal added in v0.1.1 

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

type PeripheralEventMsg added in v0.1.1 

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

func (*PeripheralEventMsg) Descriptor added in v0.1.1 

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

func (*PeripheralEventMsg) Equal added in v0.1.1 

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

func (*PeripheralEventMsg) GetKind added in v0.1.1 

func (m *PeripheralEventMsg) GetKind() PeripheralEventType

func (*PeripheralEventMsg) GoString added in v0.1.1 

func (this *PeripheralEventMsg) GoString() string

func (*PeripheralEventMsg) Marshal added in v0.1.1 

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

func (*PeripheralEventMsg) MarshalTo added in v0.1.1 

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

func (*PeripheralEventMsg) MarshalToSizedBuffer added in v0.1.1 

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

func (*PeripheralEventMsg) ProtoMessage added in v0.1.1 

func (*PeripheralEventMsg) ProtoMessage()

func (*PeripheralEventMsg) Reset added in v0.1.1 

func (m *PeripheralEventMsg) Reset()

func (*PeripheralEventMsg) Size added in v0.1.1 

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

func (*PeripheralEventMsg) String added in v0.1.1 

func (this *PeripheralEventMsg) String() string

func (*PeripheralEventMsg) Unmarshal added in v0.1.1 

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

func (*PeripheralEventMsg) XXX_DiscardUnknown added in v0.1.1 

func (m *PeripheralEventMsg) XXX_DiscardUnknown()

func (*PeripheralEventMsg) XXX_Marshal added in v0.1.1 

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

func (*PeripheralEventMsg) XXX_Merge added in v0.1.1 

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

func (*PeripheralEventMsg) XXX_Size added in v0.1.1 

func (m *PeripheralEventMsg) XXX_Size() int

func (*PeripheralEventMsg) XXX_Unmarshal added in v0.1.1 

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

type PeripheralEventType added in v0.1.1 

type PeripheralEventType int32

func (PeripheralEventType) EnumDescriptor added in v0.1.1 

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

func (PeripheralEventType) String added in v0.1.1 

func (x PeripheralEventType) String() string

type PeripheralMetricsCollectCmd added in v0.1.1 

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

func (*PeripheralMetricsCollectCmd) Descriptor added in v0.1.1 

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

func (*PeripheralMetricsCollectCmd) Equal added in v0.1.1 

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

func (*PeripheralMetricsCollectCmd) GetParams added in v0.1.1 

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

func (*PeripheralMetricsCollectCmd) GoString added in v0.1.1 

func (this *PeripheralMetricsCollectCmd) GoString() string

func (*PeripheralMetricsCollectCmd) Marshal added in v0.1.1 

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

func (*PeripheralMetricsCollectCmd) MarshalTo added in v0.1.1 

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

func (*PeripheralMetricsCollectCmd) MarshalToSizedBuffer added in v0.1.1 

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

func (*PeripheralMetricsCollectCmd) ProtoMessage added in v0.1.1 

func (*PeripheralMetricsCollectCmd) ProtoMessage()

func (*PeripheralMetricsCollectCmd) Reset added in v0.1.1 

func (m *PeripheralMetricsCollectCmd) Reset()

func (*PeripheralMetricsCollectCmd) Size added in v0.1.1 

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

func (*PeripheralMetricsCollectCmd) String added in v0.1.1 

func (this *PeripheralMetricsCollectCmd) String() string

func (*PeripheralMetricsCollectCmd) Unmarshal added in v0.1.1 

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

func (*PeripheralMetricsCollectCmd) XXX_DiscardUnknown added in v0.1.1 

func (m *PeripheralMetricsCollectCmd) XXX_DiscardUnknown()

func (*PeripheralMetricsCollectCmd) XXX_Marshal added in v0.1.1 

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

func (*PeripheralMetricsCollectCmd) XXX_Merge added in v0.1.1 

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

func (*PeripheralMetricsCollectCmd) XXX_Size added in v0.1.1 

func (m *PeripheralMetricsCollectCmd) XXX_Size() int

func (*PeripheralMetricsCollectCmd) XXX_Unmarshal added in v0.1.1 

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

type PeripheralMetricsMsg added in v0.1.1 

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

func (*PeripheralMetricsMsg) Descriptor added in v0.1.1 

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

func (*PeripheralMetricsMsg) Equal added in v0.1.1 

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

func (*PeripheralMetricsMsg) GetValues added in v0.1.1 

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

func (*PeripheralMetricsMsg) GoString added in v0.1.1 

func (this *PeripheralMetricsMsg) GoString() string

func (*PeripheralMetricsMsg) Marshal added in v0.1.1 

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

func (*PeripheralMetricsMsg) MarshalTo added in v0.1.1 

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

func (*PeripheralMetricsMsg) MarshalToSizedBuffer added in v0.1.1 

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

func (*PeripheralMetricsMsg) ProtoMessage added in v0.1.1 

func (*PeripheralMetricsMsg) ProtoMessage()

func (*PeripheralMetricsMsg) Reset added in v0.1.1 

func (m *PeripheralMetricsMsg) Reset()

func (*PeripheralMetricsMsg) Size added in v0.1.1 

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

func (*PeripheralMetricsMsg) String added in v0.1.1 

func (this *PeripheralMetricsMsg) String() string

func (*PeripheralMetricsMsg) Unmarshal added in v0.1.1 

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

func (*PeripheralMetricsMsg) XXX_DiscardUnknown added in v0.1.1 

func (m *PeripheralMetricsMsg) XXX_DiscardUnknown()

func (*PeripheralMetricsMsg) XXX_Marshal added in v0.1.1 

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

func (*PeripheralMetricsMsg) XXX_Merge added in v0.1.1 

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

func (*PeripheralMetricsMsg) XXX_Size added in v0.1.1 

func (m *PeripheralMetricsMsg) XXX_Size() int

func (*PeripheralMetricsMsg) XXX_Unmarshal added in v0.1.1 

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

type PeripheralMetricsMsg_Value added in v0.1.1 

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 added in v0.1.1 

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

func (*PeripheralMetricsMsg_Value) Equal added in v0.1.1 

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

func (*PeripheralMetricsMsg_Value) GetTimestamp added in v0.1.1 

func (m *PeripheralMetricsMsg_Value) GetTimestamp() int64

func (*PeripheralMetricsMsg_Value) GetValue added in v0.1.1 

func (m *PeripheralMetricsMsg_Value) GetValue() float64

func (*PeripheralMetricsMsg_Value) GoString added in v0.1.1 

func (this *PeripheralMetricsMsg_Value) GoString() string

func (*PeripheralMetricsMsg_Value) Marshal added in v0.1.1 

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

func (*PeripheralMetricsMsg_Value) MarshalTo added in v0.1.1 

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

func (*PeripheralMetricsMsg_Value) MarshalToSizedBuffer added in v0.1.1 

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

func (*PeripheralMetricsMsg_Value) ProtoMessage added in v0.1.1 

func (*PeripheralMetricsMsg_Value) ProtoMessage()

func (*PeripheralMetricsMsg_Value) Reset added in v0.1.1 

func (m *PeripheralMetricsMsg_Value) Reset()

func (*PeripheralMetricsMsg_Value) Size added in v0.1.1 

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

func (*PeripheralMetricsMsg_Value) String added in v0.1.1 

func (this *PeripheralMetricsMsg_Value) String() string

func (*PeripheralMetricsMsg_Value) Unmarshal added in v0.1.1 

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

func (*PeripheralMetricsMsg_Value) XXX_DiscardUnknown added in v0.1.1 

func (m *PeripheralMetricsMsg_Value) XXX_DiscardUnknown()

func (*PeripheralMetricsMsg_Value) XXX_Marshal added in v0.1.1 

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

func (*PeripheralMetricsMsg_Value) XXX_Merge added in v0.1.1 

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

func (*PeripheralMetricsMsg_Value) XXX_Size added in v0.1.1 

func (m *PeripheralMetricsMsg_Value) XXX_Size() int

func (*PeripheralMetricsMsg_Value) XXX_Unmarshal added in v0.1.1 

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

type PeripheralOperateCmd added in v0.1.1 

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 added in v0.1.1 

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

func (*PeripheralOperateCmd) Equal added in v0.1.1 

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

func (*PeripheralOperateCmd) GetData added in v0.1.1 

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

func (*PeripheralOperateCmd) GetParams added in v0.1.1 

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

func (*PeripheralOperateCmd) GoString added in v0.1.1 

func (this *PeripheralOperateCmd) GoString() string

func (*PeripheralOperateCmd) Marshal added in v0.1.1 

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

func (*PeripheralOperateCmd) MarshalTo added in v0.1.1 

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

func (*PeripheralOperateCmd) MarshalToSizedBuffer added in v0.1.1 

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

func (*PeripheralOperateCmd) ProtoMessage added in v0.1.1 

func (*PeripheralOperateCmd) ProtoMessage()

func (*PeripheralOperateCmd) Reset added in v0.1.1 

func (m *PeripheralOperateCmd) Reset()

func (*PeripheralOperateCmd) Size added in v0.1.1 

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

func (*PeripheralOperateCmd) String added in v0.1.1 

func (this *PeripheralOperateCmd) String() string

func (*PeripheralOperateCmd) Unmarshal added in v0.1.1 

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

func (*PeripheralOperateCmd) XXX_DiscardUnknown added in v0.1.1 

func (m *PeripheralOperateCmd) XXX_DiscardUnknown()

func (*PeripheralOperateCmd) XXX_Marshal added in v0.1.1 

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

func (*PeripheralOperateCmd) XXX_Merge added in v0.1.1 

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

func (*PeripheralOperateCmd) XXX_Size added in v0.1.1 

func (m *PeripheralOperateCmd) XXX_Size() int

func (*PeripheralOperateCmd) XXX_Unmarshal added in v0.1.1 

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

type PeripheralOperationResultMsg added in v0.1.1 

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

func (*PeripheralOperationResultMsg) Descriptor added in v0.1.1 

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

func (*PeripheralOperationResultMsg) Equal added in v0.1.1 

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

func (*PeripheralOperationResultMsg) GetResult added in v0.1.1 

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

func (*PeripheralOperationResultMsg) GoString added in v0.1.1 

func (this *PeripheralOperationResultMsg) GoString() string

func (*PeripheralOperationResultMsg) Marshal added in v0.1.1 

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

func (*PeripheralOperationResultMsg) MarshalTo added in v0.1.1 

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

func (*PeripheralOperationResultMsg) MarshalToSizedBuffer added in v0.1.1 

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

func (*PeripheralOperationResultMsg) ProtoMessage added in v0.1.1 

func (*PeripheralOperationResultMsg) ProtoMessage()

func (*PeripheralOperationResultMsg) Reset added in v0.1.1 

func (m *PeripheralOperationResultMsg) Reset()

func (*PeripheralOperationResultMsg) Size added in v0.1.1 

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

func (*PeripheralOperationResultMsg) String added in v0.1.1 

func (this *PeripheralOperationResultMsg) String() string

func (*PeripheralOperationResultMsg) Unmarshal added in v0.1.1 

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

func (*PeripheralOperationResultMsg) XXX_DiscardUnknown added in v0.1.1 

func (m *PeripheralOperationResultMsg) XXX_DiscardUnknown()

func (*PeripheralOperationResultMsg) XXX_Marshal added in v0.1.1 

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

func (*PeripheralOperationResultMsg) XXX_Merge added in v0.1.1 

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

func (*PeripheralOperationResultMsg) XXX_Size added in v0.1.1 

func (m *PeripheralOperationResultMsg) XXX_Size() int

func (*PeripheralOperationResultMsg) XXX_Unmarshal added in v0.1.1 

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 added in v0.2.0 

func (m *RegisterMsg) GetCodec() CodecType

func (*RegisterMsg) GetExtensionType added in v0.2.1 

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

Source Files

View all

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.