rpc

package
v0.0.0-...-9e07620 Latest Latest
Warning

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

 Go to latest Published: Nov 18, 2021 License: GPL-3.0 Imports: 17 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthSchema        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowSchema          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupSchema = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var StreamType_name = map[int32]string{
	0:  "NONE",
	1:  "VIDEO_RAW",
	2:  "VIDEO_PNG",
	3:  "VIDEO_JPG",
	4:  "VIDEO_H264",
	5:  "VIDEO_H265",
	16: "FEATURES_DNN",
	17: "FEATURES_CV",
	32: "AUDIO_PCM",
	33: "AUDIO_MP3",
	34: "AUDIO_OGG",
	64: "SENSORS_RAW",
}
View Source 
var StreamType_value = map[string]int32{
	"NONE":         0,
	"VIDEO_RAW":    1,
	"VIDEO_PNG":    2,
	"VIDEO_JPG":    3,
	"VIDEO_H264":   4,
	"VIDEO_H265":   5,
	"FEATURES_DNN": 16,
	"FEATURES_CV":  17,
	"AUDIO_PCM":    32,
	"AUDIO_MP3":    33,
	"AUDIO_OGG":    34,
	"SENSORS_RAW":  64,
}

Functions

func New 

func New(db db.DBType) http.Handler

Types

type Blob 

type Blob []byte

func NewPopulatedBlob 

func NewPopulatedBlob(r randySchema) *Blob

func (Blob) Bytes 

func (p Blob) Bytes() []byte

func (Blob) Clone 

func (p Blob) Clone() Blob

func (*Blob) Equal 

func (p *Blob) Equal(that interface{}) bool

func (*Blob) EqualBlob 

func (p *Blob) EqualBlob(that Blob) bool

func (Blob) Marshal 

func (p Blob) Marshal() ([]byte, error)

func (Blob) MarshalTo 

func (p Blob) MarshalTo(data []byte) (n int, err error)

func (*Blob) Release 

func (p *Blob) Release()

func (*Blob) Size 

func (p *Blob) Size() int

func (*Blob) Unmarshal 

func (p *Blob) Unmarshal(data []byte) error

type ChatMsg 

type ChatMsg struct {
	Timestamp int64  `protobuf:"varint,1,opt,name=Timestamp,proto3" json:"Timestamp,omitempty"`
	Username  string `protobuf:"bytes,2,opt,name=Username,proto3" json:"Username,omitempty"`
	Message   string `protobuf:"bytes,3,opt,name=Message,proto3" json:"Message,omitempty"`
}

func NewPopulatedChatMsg 

func NewPopulatedChatMsg(r randySchema, easy bool) *ChatMsg

func (*ChatMsg) Descriptor 

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

func (*ChatMsg) Equal 

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

func (*ChatMsg) GetMessage 

func (m *ChatMsg) GetMessage() string

func (*ChatMsg) GetTimestamp 

func (m *ChatMsg) GetTimestamp() int64

func (*ChatMsg) GetUsername 

func (m *ChatMsg) GetUsername() string

func (*ChatMsg) GoString 

func (this *ChatMsg) GoString() string

func (*ChatMsg) Marshal 

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

func (*ChatMsg) MarshalTo 

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

func (*ChatMsg) MarshalToSizedBuffer 

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

func (*ChatMsg) ProtoMessage 

func (*ChatMsg) ProtoMessage()

func (*ChatMsg) Reset 

func (m *ChatMsg) Reset()

func (*ChatMsg) Size 

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

func (*ChatMsg) String 

func (this *ChatMsg) String() string

func (*ChatMsg) Unmarshal 

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

func (*ChatMsg) XXX_DiscardUnknown 

func (m *ChatMsg) XXX_DiscardUnknown()

func (*ChatMsg) XXX_Marshal 

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

func (*ChatMsg) XXX_Merge 

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

func (*ChatMsg) XXX_Size 

func (m *ChatMsg) XXX_Size() int

func (*ChatMsg) XXX_Unmarshal 

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

type EventMsg 

type EventMsg struct {
	Id    uint64    `protobuf:"varint,1,opt,name=Id,proto3" json:"Id,omitempty"`
	Flags []uint64  `protobuf:"varint,2,rep,packed,name=Flags,proto3" json:"Flags,omitempty"`
	Data  []float32 `protobuf:"fixed32,3,rep,packed,name=Data,proto3" json:"Data,omitempty"`
}

func NewPopulatedEventMsg 

func NewPopulatedEventMsg(r randySchema, easy bool) *EventMsg

func (*EventMsg) Descriptor 

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

func (*EventMsg) Equal 

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

func (*EventMsg) GetData 

func (m *EventMsg) GetData() []float32

func (*EventMsg) GetFlags 

func (m *EventMsg) GetFlags() []uint64

func (*EventMsg) GetId 

func (m *EventMsg) GetId() uint64

func (*EventMsg) GoString 

func (this *EventMsg) GoString() string

func (*EventMsg) Marshal 

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

func (*EventMsg) MarshalTo 

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

func (*EventMsg) MarshalToSizedBuffer 

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

func (*EventMsg) ProtoMessage 

func (*EventMsg) ProtoMessage()

func (*EventMsg) Reset 

func (m *EventMsg) Reset()

func (*EventMsg) Size 

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

func (*EventMsg) String 

func (this *EventMsg) String() string

func (*EventMsg) Unmarshal 

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

func (*EventMsg) XXX_DiscardUnknown 

func (m *EventMsg) XXX_DiscardUnknown()

func (*EventMsg) XXX_Marshal 

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

func (*EventMsg) XXX_Merge 

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

func (*EventMsg) XXX_Size 

func (m *EventMsg) XXX_Size() int

func (*EventMsg) XXX_Unmarshal 

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

type Operator 

type Operator struct {
	Timestamp int64       `protobuf:"varint,1,opt,name=Timestamp,proto3" json:"Timestamp,omitempty"`
	OWD       int64       `protobuf:"varint,2,opt,name=OWD,proto3" json:"OWD,omitempty"`
	Stream    []StreamMsg `protobuf:"bytes,3,rep,name=Stream,proto3" json:"Stream"`
	Events    []EventMsg  `protobuf:"bytes,5,rep,name=Events,proto3" json:"Events"`
}

Message coming from either the Governor or Operator

func NewPopulatedOperator 

func NewPopulatedOperator(r randySchema, easy bool) *Operator

func (*Operator) Descriptor 

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

func (*Operator) Equal 

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

func (*Operator) GetEvents 

func (m *Operator) GetEvents() []EventMsg

func (*Operator) GetOWD 

func (m *Operator) GetOWD() int64

func (*Operator) GetStream 

func (m *Operator) GetStream() []StreamMsg

func (*Operator) GetTimestamp 

func (m *Operator) GetTimestamp() int64

func (*Operator) GoString 

func (this *Operator) GoString() string

func (*Operator) Marshal 

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

func (*Operator) MarshalTo 

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

func (*Operator) MarshalToSizedBuffer 

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

func (*Operator) ProtoMessage 

func (*Operator) ProtoMessage()

func (*Operator) Reset 

func (m *Operator) Reset()

func (*Operator) Size 

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

func (*Operator) String 

func (this *Operator) String() string

func (*Operator) Unmarshal 

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

func (*Operator) XXX_DiscardUnknown 

func (m *Operator) XXX_DiscardUnknown()

func (*Operator) XXX_Marshal 

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

func (*Operator) XXX_Merge 

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

func (*Operator) XXX_Size 

func (m *Operator) XXX_Size() int

func (*Operator) XXX_Unmarshal 

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

type Robot 

type Robot struct {
	Timestamp int64       `protobuf:"varint,1,opt,name=Timestamp,proto3" json:"Timestamp,omitempty"`
	Robot     RobotMsg    `protobuf:"bytes,2,opt,name=Robot,proto3" json:"Robot"`
	Status    StatusMsg   `protobuf:"bytes,3,opt,name=Status,proto3" json:"Status"`
	Stream    []StreamMsg `protobuf:"bytes,4,rep,name=Stream,proto3" json:"Stream"`
}

Message coming from the robot

func NewPopulatedRobot 

func NewPopulatedRobot(r randySchema, easy bool) *Robot

func (*Robot) Descriptor 

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

func (*Robot) Equal 

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

func (*Robot) GetRobot 

func (m *Robot) GetRobot() RobotMsg

func (*Robot) GetStatus 

func (m *Robot) GetStatus() StatusMsg

func (*Robot) GetStream 

func (m *Robot) GetStream() []StreamMsg

func (*Robot) GetTimestamp 

func (m *Robot) GetTimestamp() int64

func (*Robot) GoString 

func (this *Robot) GoString() string

func (*Robot) Marshal 

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

func (*Robot) MarshalTo 

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

func (*Robot) MarshalToSizedBuffer 

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

func (*Robot) ProtoMessage 

func (*Robot) ProtoMessage()

func (*Robot) Reset 

func (m *Robot) Reset()

func (*Robot) Size 

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

func (*Robot) String 

func (this *Robot) String() string

func (*Robot) Unmarshal 

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

func (*Robot) XXX_DiscardUnknown 

func (m *Robot) XXX_DiscardUnknown()

func (*Robot) XXX_Marshal 

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

func (*Robot) XXX_Merge 

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

func (*Robot) XXX_Size 

func (m *Robot) XXX_Size() int

func (*Robot) XXX_Unmarshal 

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

type RobotMsg 

type RobotMsg struct {
	Id           string                `protobuf:"bytes,1,opt,name=Id,proto3" json:"Id,omitempty"`
	Name         string                `protobuf:"bytes,2,opt,name=Name,proto3" json:"Name,omitempty"`
	Description  string                `protobuf:"bytes,3,opt,name=Description,proto3" json:"Description,omitempty"`
	Capabilities []RobotMsg_Capability `protobuf:"bytes,4,rep,name=Capabilities,proto3" json:"Capabilities"`
}

func NewPopulatedRobotMsg 

func NewPopulatedRobotMsg(r randySchema, easy bool) *RobotMsg

func (*RobotMsg) Descriptor 

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

func (*RobotMsg) Equal 

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

func (*RobotMsg) GetCapabilities 

func (m *RobotMsg) GetCapabilities() []RobotMsg_Capability

func (*RobotMsg) GetDescription 

func (m *RobotMsg) GetDescription() string

func (*RobotMsg) GetId 

func (m *RobotMsg) GetId() string

func (*RobotMsg) GetName 

func (m *RobotMsg) GetName() string

func (*RobotMsg) GoString 

func (this *RobotMsg) GoString() string

func (*RobotMsg) Marshal 

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

func (*RobotMsg) MarshalTo 

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

func (*RobotMsg) MarshalToSizedBuffer 

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

func (*RobotMsg) ProtoMessage 

func (*RobotMsg) ProtoMessage()

func (*RobotMsg) Reset 

func (m *RobotMsg) Reset()

func (*RobotMsg) Size 

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

func (*RobotMsg) String 

func (this *RobotMsg) String() string

func (*RobotMsg) Unmarshal 

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

func (*RobotMsg) XXX_DiscardUnknown 

func (m *RobotMsg) XXX_DiscardUnknown()

func (*RobotMsg) XXX_Marshal 

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

func (*RobotMsg) XXX_Merge 

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

func (*RobotMsg) XXX_Size 

func (m *RobotMsg) XXX_Size() int

func (*RobotMsg) XXX_Unmarshal 

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

type RobotMsg_Capability 

type RobotMsg_Capability struct {
	// NOTE:
	// Negative Id refers to stream types:
	//   streamType: abs(Id)
	// Positive Id refers to Event types.
	Id          int64  `protobuf:"varint,1,opt,name=Id,proto3" json:"Id,omitempty"`
	Name        string `protobuf:"bytes,2,opt,name=Name,proto3" json:"Name,omitempty"`
	Description string `protobuf:"bytes,3,opt,name=Description,proto3" json:"Description,omitempty"`
}

func NewPopulatedRobotMsg_Capability 

func NewPopulatedRobotMsg_Capability(r randySchema, easy bool) *RobotMsg_Capability

func (*RobotMsg_Capability) Descriptor 

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

func (*RobotMsg_Capability) Equal 

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

func (*RobotMsg_Capability) GetDescription 

func (m *RobotMsg_Capability) GetDescription() string

func (*RobotMsg_Capability) GetId 

func (m *RobotMsg_Capability) GetId() int64

func (*RobotMsg_Capability) GetName 

func (m *RobotMsg_Capability) GetName() string

func (*RobotMsg_Capability) GoString 

func (this *RobotMsg_Capability) GoString() string

func (*RobotMsg_Capability) Marshal 

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

func (*RobotMsg_Capability) MarshalTo 

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

func (*RobotMsg_Capability) MarshalToSizedBuffer 

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

func (*RobotMsg_Capability) ProtoMessage 

func (*RobotMsg_Capability) ProtoMessage()

func (*RobotMsg_Capability) Reset 

func (m *RobotMsg_Capability) Reset()

func (*RobotMsg_Capability) Size 

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

func (*RobotMsg_Capability) String 

func (this *RobotMsg_Capability) String() string

func (*RobotMsg_Capability) Unmarshal 

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

func (*RobotMsg_Capability) XXX_DiscardUnknown 

func (m *RobotMsg_Capability) XXX_DiscardUnknown()

func (*RobotMsg_Capability) XXX_Marshal 

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

func (*RobotMsg_Capability) XXX_Merge 

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

func (*RobotMsg_Capability) XXX_Size 

func (m *RobotMsg_Capability) XXX_Size() int

func (*RobotMsg_Capability) XXX_Unmarshal 

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

type StatusMsg 

type StatusMsg struct {
	OWD     int64   `protobuf:"varint,1,opt,name=OWD,proto3" json:"OWD,omitempty"`
	RTT     int64   `protobuf:"varint,2,opt,name=RTT,proto3" json:"RTT,omitempty"`
	Jitter  int64   `protobuf:"varint,3,opt,name=Jitter,proto3" json:"Jitter,omitempty"`
	Battery float32 `protobuf:"fixed32,4,opt,name=Battery,proto3" json:"Battery,omitempty"`
	Health  float32 `protobuf:"fixed32,5,opt,name=Health,proto3" json:"Health,omitempty"`
}

func NewPopulatedStatusMsg 

func NewPopulatedStatusMsg(r randySchema, easy bool) *StatusMsg

func (*StatusMsg) Descriptor 

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

func (*StatusMsg) Equal 

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

func (*StatusMsg) GetBattery 

func (m *StatusMsg) GetBattery() float32

func (*StatusMsg) GetHealth 

func (m *StatusMsg) GetHealth() float32

func (*StatusMsg) GetJitter 

func (m *StatusMsg) GetJitter() int64

func (*StatusMsg) GetOWD 

func (m *StatusMsg) GetOWD() int64

func (*StatusMsg) GetRTT 

func (m *StatusMsg) GetRTT() int64

func (*StatusMsg) GoString 

func (this *StatusMsg) GoString() string

func (*StatusMsg) Marshal 

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

func (*StatusMsg) MarshalTo 

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

func (*StatusMsg) MarshalToSizedBuffer 

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

func (*StatusMsg) ProtoMessage 

func (*StatusMsg) ProtoMessage()

func (*StatusMsg) Reset 

func (m *StatusMsg) Reset()

func (*StatusMsg) Size 

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

func (*StatusMsg) String 

func (this *StatusMsg) String() string

func (*StatusMsg) Unmarshal 

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

func (*StatusMsg) XXX_DiscardUnknown 

func (m *StatusMsg) XXX_DiscardUnknown()

func (*StatusMsg) XXX_Marshal 

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

func (*StatusMsg) XXX_Merge 

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

func (*StatusMsg) XXX_Size 

func (m *StatusMsg) XXX_Size() int

func (*StatusMsg) XXX_Unmarshal 

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

type StreamMsg 

type StreamMsg struct {
	Type StreamType `protobuf:"varint,1,opt,name=Type,proto3,enum=rpc.StreamType" json:"Type,omitempty"`
	Data Blob       `protobuf:"bytes,2,opt,name=Data,proto3,customtype=Blob" json:"Data"`
}

func NewPopulatedStreamMsg 

func NewPopulatedStreamMsg(r randySchema, easy bool) *StreamMsg

func (*StreamMsg) Descriptor 

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

func (*StreamMsg) Equal 

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

func (*StreamMsg) GetType 

func (m *StreamMsg) GetType() StreamType

func (*StreamMsg) GoString 

func (this *StreamMsg) GoString() string

func (*StreamMsg) Marshal 

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

func (*StreamMsg) MarshalTo 

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

func (*StreamMsg) MarshalToSizedBuffer 

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

func (*StreamMsg) ProtoMessage 

func (*StreamMsg) ProtoMessage()

func (*StreamMsg) Reset 

func (m *StreamMsg) Reset()

func (*StreamMsg) Size 

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

func (*StreamMsg) String 

func (this *StreamMsg) String() string

func (*StreamMsg) Unmarshal 

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

func (*StreamMsg) XXX_DiscardUnknown 

func (m *StreamMsg) XXX_DiscardUnknown()

func (*StreamMsg) XXX_Marshal 

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

func (*StreamMsg) XXX_Merge 

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

func (*StreamMsg) XXX_Size 

func (m *StreamMsg) XXX_Size() int

func (*StreamMsg) XXX_Unmarshal 

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

type StreamType 

type StreamType int32
const (
	StreamType_NONE         StreamType = 0
	StreamType_VIDEO_RAW    StreamType = 1
	StreamType_VIDEO_PNG    StreamType = 2
	StreamType_VIDEO_JPG    StreamType = 3
	StreamType_VIDEO_H264   StreamType = 4
	StreamType_VIDEO_H265   StreamType = 5
	StreamType_FEATURES_DNN StreamType = 16
	StreamType_FEATURES_CV  StreamType = 17
	StreamType_AUDIO_PCM    StreamType = 32
	StreamType_AUDIO_MP3    StreamType = 33
	StreamType_AUDIO_OGG    StreamType = 34
	StreamType_SENSORS_RAW  StreamType = 64
)

func (StreamType) EnumDescriptor 

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

func (StreamType) String 

func (x StreamType) String() string

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.