protocol

package
v0.0.0-...-8626583 Latest Latest
Warning

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

 Go to latest Published: Feb 16, 2021 License: GPL-3.0 Imports: 9 Imported by: 1

Documentation

Index

Constants

View Source 
const (
	GettingHeader = iota
	ReadingData
)

region Internal States

View Source 
const (
	Invalid = iota
	OK
	Error
)
View Source 
const (
	DeviceInvalid = iota
	DeviceTestSignal
	DeviceAirspyOne
	DeviceAirspyHf
	DeviceRtlsdr
	DeviceLimeSDRUSB
	DeviceLimeSDRMini
	DeviceSpyServer
	DeviceHackRF
)

DeviceIds IDs

View Source 
const (
	TypeNone = iota
	TypeDeviceInfo
	TypeClientSync
	TypePong
	TypeReadSetting
	TypeIQ
	TypeSmartIQ
	TypeCombined
	TypeCommand
)
View Source 
const (
	CmdHello      = 0
	CmdGetSetting = 1
	CmdSetSetting = 2
	CmdPing       = 3
)
View Source 
const (
	SettingStreamingMode = iota
	SettingStreamingEnabled
	SettingGains
	SettingIqFrequency
	SettingIqDecimation
	SettingDigitalGain
	SettingSmartFrequency
	SettingSmartDecimation
)
View Source 
const (
	DeviceInvalidName     = "Invalid Device"
	DeviceTestSignalName  = "Test Signal Generator"
	DeviceAirspyOneName   = "Airspy Mini / R2"
	DeviceAirspyHFName    = "Airspy HF / HF+"
	DeviceRtlsdrName      = "RTLSDR"
	DeviceLimeSDRUSBName  = "LimeSDR USB"
	DeviceLimeSDRMiniName = "LimeSDR Mini"
	DeviceHackRFName      = "HackRF"
	DeviceSpyserverName   = "SpyServer"
)

DeviceNames names of the device

View Source 
const DefaultPort = 4050
View Source 
const MaxMessageBodySize = 1 << 20

Variables

View Source 
var ChannelType_name = map[int32]string{
	0: "IQ",
	1: "SmartIQ",
}
View Source 
var ChannelType_value = map[string]int32{
	"IQ":      0,
	"SmartIQ": 1,
}
View Source 
var CurrentProtocolVersion = VersionData{
	Major: 0,
	Minor: 1,
	Hash:  0,
}
View Source 
var DeviceName = map[uint32]string{
	DeviceInvalid:     DeviceInvalidName,
	DeviceTestSignal:  DeviceTestSignalName,
	DeviceAirspyOne:   DeviceAirspyOneName,
	DeviceAirspyHf:    DeviceAirspyHFName,
	DeviceRtlsdr:      DeviceRtlsdrName,
	DeviceLimeSDRUSB:  DeviceLimeSDRUSBName,
	DeviceLimeSDRMini: DeviceLimeSDRMiniName,
	DeviceHackRF:      DeviceHackRFName,
	DeviceSpyServer:   DeviceSpyserverName,
}

DeviceName list of device names by their ids

View Source 
var DeviceType_name = map[int32]string{
	0: "DeviceInvalid",
	1: "DeviceTestSignal",
	2: "DeviceAirspyOne",
	3: "DeviceAirspyHf",
	4: "DeviceRtlsdr",
	5: "DeviceLimeSDRUSB",
	6: "DeviceLimeSDRMini",
	7: "DeviceSpyServer",
	8: "DeviceHackRF",
}
View Source 
var DeviceType_value = map[string]int32{
	"DeviceInvalid":     0,
	"DeviceTestSignal":  1,
	"DeviceAirspyOne":   2,
	"DeviceAirspyHf":    3,
	"DeviceRtlsdr":      4,
	"DeviceLimeSDRUSB":  5,
	"DeviceLimeSDRMini": 6,
	"DeviceSpyServer":   7,
	"DeviceHackRF":      8,
}
View Source 
var GlobalAffectedSettings = []uint32{
	SettingGains,
}
View Source 
var MessageHeaderSize = uint32(binary.Size(MessageHeader{}))
View Source 
var PossibleSettings = []uint32{
	SettingStreamingMode,
	SettingStreamingEnabled,
	SettingGains,
	SettingDigitalGain,

	SettingIqFrequency,
	SettingIqDecimation,

	SettingSmartFrequency,
	SettingSmartDecimation,
}
View Source 
var SettingNames = map[uint32]string{
	SettingStreamingMode:    "Streaming Mode",
	SettingStreamingEnabled: "Streaming Enabled",
	SettingGains:            "Gain",
	SettingDigitalGain:      "Digital Gain",
	SettingIqFrequency:      "IQ Frequency",
	SettingIqDecimation:     "IQ Decimation",
	SettingSmartFrequency:   "Smart Frequency",
	SettingSmartDecimation:  "Smart Decimation",
}

SettingNames list of device names by their ids

View Source 
var StatusType_name = map[int32]string{
	0: "Invalid",
	1: "OK",
	2: "Error",
}
View Source 
var StatusType_value = map[string]int32{
	"Invalid": 0,
	"OK":      1,
	"Error":   2,
}

Functions

func GenProtocolVersion 

func GenProtocolVersion(version VersionData) uint64

func IsSettingPossible 

func IsSettingPossible(setting uint32) bool

func ParseCmdGetSettingBody 

func ParseCmdGetSettingBody(data []uint8)

func ParseCmdPingBody 

func ParseCmdPingBody(data []uint8) int64

func ParseCmdSetSettingBody 

func ParseCmdSetSettingBody(data []uint8) (setting uint32, args []uint32)

func RegisterRadioServerServer 

func RegisterRadioServerServer(s *grpc.Server, srv RadioServerServer)

func SettingAffectsGlobal 

func SettingAffectsGlobal(setting uint32) bool

Types

type ByeReturn 

type ByeReturn struct {
	Message              string   `protobuf:"bytes,1,opt,name=Message,proto3" json:"Message,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ByeReturn) Descriptor 

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

func (*ByeReturn) GetMessage 

func (m *ByeReturn) GetMessage() string

func (*ByeReturn) ProtoMessage 

func (*ByeReturn) ProtoMessage()

func (*ByeReturn) Reset 

func (m *ByeReturn) Reset()

func (*ByeReturn) String 

func (m *ByeReturn) String() string

func (*ByeReturn) XXX_DiscardUnknown 

func (m *ByeReturn) XXX_DiscardUnknown()

func (*ByeReturn) XXX_Marshal 

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

func (*ByeReturn) XXX_Merge 

func (dst *ByeReturn) XXX_Merge(src proto.Message)

func (*ByeReturn) XXX_Size 

func (m *ByeReturn) XXX_Size() int

func (*ByeReturn) XXX_Unmarshal 

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

type ChannelConfig 

type ChannelConfig struct {
	LoginInfo            *LoginData `protobuf:"bytes,1,opt,name=LoginInfo,proto3" json:"LoginInfo,omitempty"`
	CenterFrequency      uint32     `protobuf:"varint,2,opt,name=CenterFrequency,proto3" json:"CenterFrequency,omitempty"`
	DecimationStage      uint32     `protobuf:"varint,3,opt,name=DecimationStage,proto3" json:"DecimationStage,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*ChannelConfig) Descriptor 

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

func (*ChannelConfig) GetCenterFrequency 

func (m *ChannelConfig) GetCenterFrequency() uint32

func (*ChannelConfig) GetDecimationStage 

func (m *ChannelConfig) GetDecimationStage() uint32

func (*ChannelConfig) GetLoginInfo 

func (m *ChannelConfig) GetLoginInfo() *LoginData

func (*ChannelConfig) ProtoMessage 

func (*ChannelConfig) ProtoMessage()

func (*ChannelConfig) Reset 

func (m *ChannelConfig) Reset()

func (*ChannelConfig) String 

func (m *ChannelConfig) String() string

func (*ChannelConfig) XXX_DiscardUnknown 

func (m *ChannelConfig) XXX_DiscardUnknown()

func (*ChannelConfig) XXX_Marshal 

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

func (*ChannelConfig) XXX_Merge 

func (dst *ChannelConfig) XXX_Merge(src proto.Message)

func (*ChannelConfig) XXX_Size 

func (m *ChannelConfig) XXX_Size() int

func (*ChannelConfig) XXX_Unmarshal 

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

type ChannelType 

type ChannelType int32
const (
	ChannelType_IQ      ChannelType = 0
	ChannelType_SmartIQ ChannelType = 1
)

func (ChannelType) EnumDescriptor 

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

func (ChannelType) String 

func (x ChannelType) String() string

type ClientSync 

type ClientSync struct {
	AllowControl             uint32
	Gains                    [3]uint32
	DeviceCenterFrequency    uint32
	IQCenterFrequency        uint32
	SmartCenterFrequency     uint32
	MinimumIQCenterFrequency uint32
	MaximumIQCenterFrequency uint32
	MinimumSmartFrequency    uint32
	MaximumSmartFrequency    uint32
}

type DeviceInfo 

type DeviceInfo struct {
	DeviceType           DeviceType `protobuf:"varint,1,opt,name=DeviceType,proto3,enum=protocol.DeviceType" json:"DeviceType,omitempty"`
	DeviceSerial         string     `protobuf:"bytes,2,opt,name=DeviceSerial,proto3" json:"DeviceSerial,omitempty"`
	DeviceName           string     `protobuf:"bytes,3,opt,name=DeviceName,proto3" json:"DeviceName,omitempty"`
	MaximumSampleRate    uint32     `protobuf:"varint,4,opt,name=MaximumSampleRate,proto3" json:"MaximumSampleRate,omitempty"`
	MaximumGain          uint32     `protobuf:"varint,5,opt,name=MaximumGain,proto3" json:"MaximumGain,omitempty"`
	MaximumDecimation    uint32     `protobuf:"varint,6,opt,name=MaximumDecimation,proto3" json:"MaximumDecimation,omitempty"`
	MinimumFrequency     uint32     `protobuf:"varint,7,opt,name=MinimumFrequency,proto3" json:"MinimumFrequency,omitempty"`
	MaximumFrequency     uint32     `protobuf:"varint,8,opt,name=MaximumFrequency,proto3" json:"MaximumFrequency,omitempty"`
	ADCResolution        uint32     `protobuf:"varint,9,opt,name=ADCResolution,proto3" json:"ADCResolution,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*DeviceInfo) Descriptor 

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

func (*DeviceInfo) GetADCResolution 

func (m *DeviceInfo) GetADCResolution() uint32

func (*DeviceInfo) GetDeviceName 

func (m *DeviceInfo) GetDeviceName() string

func (*DeviceInfo) GetDeviceSerial 

func (m *DeviceInfo) GetDeviceSerial() string

func (*DeviceInfo) GetDeviceType 

func (m *DeviceInfo) GetDeviceType() DeviceType

func (*DeviceInfo) GetMaximumDecimation 

func (m *DeviceInfo) GetMaximumDecimation() uint32

func (*DeviceInfo) GetMaximumFrequency 

func (m *DeviceInfo) GetMaximumFrequency() uint32

func (*DeviceInfo) GetMaximumGain 

func (m *DeviceInfo) GetMaximumGain() uint32

func (*DeviceInfo) GetMaximumSampleRate 

func (m *DeviceInfo) GetMaximumSampleRate() uint32

func (*DeviceInfo) GetMinimumFrequency 

func (m *DeviceInfo) GetMinimumFrequency() uint32

func (*DeviceInfo) ProtoMessage 

func (*DeviceInfo) ProtoMessage()

func (*DeviceInfo) Reset 

func (m *DeviceInfo) Reset()

func (*DeviceInfo) String 

func (m *DeviceInfo) String() string

func (*DeviceInfo) XXX_DiscardUnknown 

func (m *DeviceInfo) XXX_DiscardUnknown()

func (*DeviceInfo) XXX_Marshal 

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

func (*DeviceInfo) XXX_Merge 

func (dst *DeviceInfo) XXX_Merge(src proto.Message)

func (*DeviceInfo) XXX_Size 

func (m *DeviceInfo) XXX_Size() int

func (*DeviceInfo) XXX_Unmarshal 

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

type DeviceType 

type DeviceType int32
const (
	DeviceType_DeviceInvalid     DeviceType = 0
	DeviceType_DeviceTestSignal  DeviceType = 1
	DeviceType_DeviceAirspyOne   DeviceType = 2
	DeviceType_DeviceAirspyHf    DeviceType = 3
	DeviceType_DeviceRtlsdr      DeviceType = 4
	DeviceType_DeviceLimeSDRUSB  DeviceType = 5
	DeviceType_DeviceLimeSDRMini DeviceType = 6
	DeviceType_DeviceSpyServer   DeviceType = 7
	DeviceType_DeviceHackRF      DeviceType = 8
)

func (DeviceType) EnumDescriptor 

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

func (DeviceType) String 

func (x DeviceType) String() string

type Empty 

type Empty struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Empty) Descriptor 

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

func (*Empty) ProtoMessage 

func (*Empty) ProtoMessage()

func (*Empty) Reset 

func (m *Empty) Reset()

func (*Empty) String 

func (m *Empty) String() string

func (*Empty) XXX_DiscardUnknown 

func (m *Empty) XXX_DiscardUnknown()

func (*Empty) XXX_Marshal 

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

func (*Empty) XXX_Merge 

func (dst *Empty) XXX_Merge(src proto.Message)

func (*Empty) XXX_Size 

func (m *Empty) XXX_Size() int

func (*Empty) XXX_Unmarshal 

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

type HelloData 

type HelloData struct {
	Name                 string   `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty"`
	Application          string   `protobuf:"bytes,2,opt,name=Application,proto3" json:"Application,omitempty"`
	Username             string   `protobuf:"bytes,3,opt,name=Username,proto3" json:"Username,omitempty"`
	Password             string   `protobuf:"bytes,4,opt,name=Password,proto3" json:"Password,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*HelloData) Descriptor 

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

func (*HelloData) GetApplication 

func (m *HelloData) GetApplication() string

func (*HelloData) GetName 

func (m *HelloData) GetName() string

func (*HelloData) GetPassword 

func (m *HelloData) GetPassword() string

func (*HelloData) GetUsername 

func (m *HelloData) GetUsername() string

func (*HelloData) ProtoMessage 

func (*HelloData) ProtoMessage()

func (*HelloData) Reset 

func (m *HelloData) Reset()

func (*HelloData) String 

func (m *HelloData) String() string

func (*HelloData) XXX_DiscardUnknown 

func (m *HelloData) XXX_DiscardUnknown()

func (*HelloData) XXX_Marshal 

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

func (*HelloData) XXX_Merge 

func (dst *HelloData) XXX_Merge(src proto.Message)

func (*HelloData) XXX_Size 

func (m *HelloData) XXX_Size() int

func (*HelloData) XXX_Unmarshal 

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

type HelloReturn 

type HelloReturn struct {
	Status               StatusType `protobuf:"varint,1,opt,name=Status,proto3,enum=protocol.StatusType" json:"Status,omitempty"`
	Login                *LoginData `protobuf:"bytes,2,opt,name=Login,proto3" json:"Login,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*HelloReturn) Descriptor 

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

func (*HelloReturn) GetLogin 

func (m *HelloReturn) GetLogin() *LoginData

func (*HelloReturn) GetStatus 

func (m *HelloReturn) GetStatus() StatusType

func (*HelloReturn) ProtoMessage 

func (*HelloReturn) ProtoMessage()

func (*HelloReturn) Reset 

func (m *HelloReturn) Reset()

func (*HelloReturn) String 

func (m *HelloReturn) String() string

func (*HelloReturn) XXX_DiscardUnknown 

func (m *HelloReturn) XXX_DiscardUnknown()

func (*HelloReturn) XXX_Marshal 

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

func (*HelloReturn) XXX_Merge 

func (dst *HelloReturn) XXX_Merge(src proto.Message)

func (*HelloReturn) XXX_Size 

func (m *HelloReturn) XXX_Size() int

func (*HelloReturn) XXX_Unmarshal 

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

type IQData 

type IQData struct {
	Timestamp            uint64      `protobuf:"varint,1,opt,name=Timestamp,proto3" json:"Timestamp,omitempty"`
	Status               StatusType  `protobuf:"varint,2,opt,name=status,proto3,enum=protocol.StatusType" json:"status,omitempty"`
	Error                string      `protobuf:"bytes,3,opt,name=Error,proto3" json:"Error,omitempty"`
	Type                 ChannelType `protobuf:"varint,4,opt,name=Type,proto3,enum=protocol.ChannelType" json:"Type,omitempty"`
	Samples              []float32   `protobuf:"fixed32,5,rep,packed,name=Samples,proto3" json:"Samples,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func MakeIQData 

func MakeIQData(channelType ChannelType, samples []complex64) *IQData

func MakeIQDataWithPool 

func MakeIQDataWithPool(channelType ChannelType, samples []complex64, pool sync.Pool) *IQData

func (*IQData) Descriptor 

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

func (*IQData) GetComplexSamples 

func (m *IQData) GetComplexSamples() []complex64

func (*IQData) GetError 

func (m *IQData) GetError() string

func (*IQData) GetSamples 

func (m *IQData) GetSamples() []float32

func (*IQData) GetStatus 

func (m *IQData) GetStatus() StatusType

func (*IQData) GetTimestamp 

func (m *IQData) GetTimestamp() uint64

func (*IQData) GetType 

func (m *IQData) GetType() ChannelType

func (*IQData) ProtoMessage 

func (*IQData) ProtoMessage()

func (*IQData) Reset 

func (m *IQData) Reset()

func (*IQData) String 

func (m *IQData) String() string

func (*IQData) XXX_DiscardUnknown 

func (m *IQData) XXX_DiscardUnknown()

func (*IQData) XXX_Marshal 

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

func (*IQData) XXX_Merge 

func (dst *IQData) XXX_Merge(src proto.Message)

func (*IQData) XXX_Size 

func (m *IQData) XXX_Size() int

func (*IQData) XXX_Unmarshal 

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

type LoginData 

type LoginData struct {
	Token                string   `protobuf:"bytes,1,opt,name=Token,proto3" json:"Token,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*LoginData) Descriptor 

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

func (*LoginData) GetToken 

func (m *LoginData) GetToken() string

func (*LoginData) ProtoMessage 

func (*LoginData) ProtoMessage()

func (*LoginData) Reset 

func (m *LoginData) Reset()

func (*LoginData) String 

func (m *LoginData) String() string

func (*LoginData) XXX_DiscardUnknown 

func (m *LoginData) XXX_DiscardUnknown()

func (*LoginData) XXX_Marshal 

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

func (*LoginData) XXX_Merge 

func (dst *LoginData) XXX_Merge(src proto.Message)

func (*LoginData) XXX_Size 

func (m *LoginData) XXX_Size() int

func (*LoginData) XXX_Unmarshal 

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

type MeData 

type MeData struct {
	Name                 string   `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty"`
	Application          string   `protobuf:"bytes,2,opt,name=Application,proto3" json:"Application,omitempty"`
	Username             string   `protobuf:"bytes,3,opt,name=Username,proto3" json:"Username,omitempty"`
	Address              string   `protobuf:"bytes,4,opt,name=Address,proto3" json:"Address,omitempty"`
	ControlAllowed       bool     `protobuf:"varint,5,opt,name=ControlAllowed,proto3" json:"ControlAllowed,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*MeData) Descriptor 

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

func (*MeData) GetAddress 

func (m *MeData) GetAddress() string

func (*MeData) GetApplication 

func (m *MeData) GetApplication() string

func (*MeData) GetControlAllowed 

func (m *MeData) GetControlAllowed() bool

func (*MeData) GetName 

func (m *MeData) GetName() string

func (*MeData) GetUsername 

func (m *MeData) GetUsername() string

func (*MeData) ProtoMessage 

func (*MeData) ProtoMessage()

func (*MeData) Reset 

func (m *MeData) Reset()

func (*MeData) String 

func (m *MeData) String() string

func (*MeData) XXX_DiscardUnknown 

func (m *MeData) XXX_DiscardUnknown()

func (*MeData) XXX_Marshal 

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

func (*MeData) XXX_Merge 

func (dst *MeData) XXX_Merge(src proto.Message)

func (*MeData) XXX_Size 

func (m *MeData) XXX_Size() int

func (*MeData) XXX_Unmarshal 

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

type MessageHeader 

type MessageHeader struct {
	PacketNumber    uint32
	ProtocolVersion uint64
	MessageType     uint32
	Reserved        uint32
	BodySize        uint32
}

type PingData 

type PingData struct {
	Timestamp            uint64   `protobuf:"varint,1,opt,name=Timestamp,proto3" json:"Timestamp,omitempty"`
	Token                string   `protobuf:"bytes,2,opt,name=Token,proto3" json:"Token,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PingData) Descriptor 

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

func (*PingData) GetTimestamp 

func (m *PingData) GetTimestamp() uint64

func (*PingData) GetToken 

func (m *PingData) GetToken() string

func (*PingData) ProtoMessage 

func (*PingData) ProtoMessage()

func (*PingData) Reset 

func (m *PingData) Reset()

func (*PingData) String 

func (m *PingData) String() string

func (*PingData) XXX_DiscardUnknown 

func (m *PingData) XXX_DiscardUnknown()

func (*PingData) XXX_Marshal 

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

func (*PingData) XXX_Merge 

func (dst *PingData) XXX_Merge(src proto.Message)

func (*PingData) XXX_Size 

func (m *PingData) XXX_Size() int

func (*PingData) XXX_Unmarshal 

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

type PingPacket 

type PingPacket struct {
	Timestamp int64
}

type RadioServerClient 

type RadioServerClient interface {
	Me(ctx context.Context, in *LoginData, opts ...grpc.CallOption) (*MeData, error)
	Hello(ctx context.Context, in *HelloData, opts ...grpc.CallOption) (*HelloReturn, error)
	Bye(ctx context.Context, in *LoginData, opts ...grpc.CallOption) (*ByeReturn, error)
	ServerInfo(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*ServerInfoData, error)
	SmartIQ(ctx context.Context, in *ChannelConfig, opts ...grpc.CallOption) (RadioServer_SmartIQClient, error)
	IQ(ctx context.Context, in *ChannelConfig, opts ...grpc.CallOption) (RadioServer_IQClient, error)
	Ping(ctx context.Context, in *PingData, opts ...grpc.CallOption) (*PingData, error)
}

RadioServerClient is the client API for RadioServer service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewRadioServerClient 

func NewRadioServerClient(cc *grpc.ClientConn) RadioServerClient

type RadioServerServer 

type RadioServerServer interface {
	Me(context.Context, *LoginData) (*MeData, error)
	Hello(context.Context, *HelloData) (*HelloReturn, error)
	Bye(context.Context, *LoginData) (*ByeReturn, error)
	ServerInfo(context.Context, *Empty) (*ServerInfoData, error)
	SmartIQ(*ChannelConfig, RadioServer_SmartIQServer) error
	IQ(*ChannelConfig, RadioServer_IQServer) error
	Ping(context.Context, *PingData) (*PingData, error)
}

RadioServerServer is the server API for RadioServer service.

type RadioServer_IQClient 

type RadioServer_IQClient interface {
	Recv() (*IQData, error)
	grpc.ClientStream
}

type RadioServer_IQServer 

type RadioServer_IQServer interface {
	Send(*IQData) error
	grpc.ServerStream
}

type RadioServer_SmartIQClient 

type RadioServer_SmartIQClient interface {
	Recv() (*IQData, error)
	grpc.ClientStream
}

type RadioServer_SmartIQServer 

type RadioServer_SmartIQServer interface {
	Send(*IQData) error
	grpc.ServerStream
}

type ReadSettingPacket 

type ReadSettingPacket struct {
	Setting  uint32
	BodySize uint32
}

type ServerInfoData 

type ServerInfoData struct {
	ControlAllowed           bool         `protobuf:"varint,1,opt,name=ControlAllowed,proto3" json:"ControlAllowed,omitempty"`
	ServerCenterFrequency    uint32       `protobuf:"varint,2,opt,name=ServerCenterFrequency,proto3" json:"ServerCenterFrequency,omitempty"`
	MinimumIQCenterFrequency uint32       `protobuf:"varint,3,opt,name=MinimumIQCenterFrequency,proto3" json:"MinimumIQCenterFrequency,omitempty"`
	MaximumIQCenterFrequency uint32       `protobuf:"varint,4,opt,name=MaximumIQCenterFrequency,proto3" json:"MaximumIQCenterFrequency,omitempty"`
	MinimumSmartFrequency    uint32       `protobuf:"varint,5,opt,name=MinimumSmartFrequency,proto3" json:"MinimumSmartFrequency,omitempty"`
	MaximumSmartFrequency    uint32       `protobuf:"varint,6,opt,name=MaximumSmartFrequency,proto3" json:"MaximumSmartFrequency,omitempty"`
	DeviceInfo               *DeviceInfo  `protobuf:"bytes,7,opt,name=deviceInfo,proto3" json:"deviceInfo,omitempty"`
	Version                  *VersionData `protobuf:"bytes,8,opt,name=version,proto3" json:"version,omitempty"`
	XXX_NoUnkeyedLiteral     struct{}     `json:"-"`
	XXX_unrecognized         []byte       `json:"-"`
	XXX_sizecache            int32        `json:"-"`
}

func (*ServerInfoData) Descriptor 

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

func (*ServerInfoData) GetControlAllowed 

func (m *ServerInfoData) GetControlAllowed() bool

func (*ServerInfoData) GetDeviceInfo 

func (m *ServerInfoData) GetDeviceInfo() *DeviceInfo

func (*ServerInfoData) GetMaximumIQCenterFrequency 

func (m *ServerInfoData) GetMaximumIQCenterFrequency() uint32

func (*ServerInfoData) GetMaximumSmartFrequency 

func (m *ServerInfoData) GetMaximumSmartFrequency() uint32

func (*ServerInfoData) GetMinimumIQCenterFrequency 

func (m *ServerInfoData) GetMinimumIQCenterFrequency() uint32

func (*ServerInfoData) GetMinimumSmartFrequency 

func (m *ServerInfoData) GetMinimumSmartFrequency() uint32

func (*ServerInfoData) GetServerCenterFrequency 

func (m *ServerInfoData) GetServerCenterFrequency() uint32

func (*ServerInfoData) GetVersion 

func (m *ServerInfoData) GetVersion() *VersionData

func (*ServerInfoData) ProtoMessage 

func (*ServerInfoData) ProtoMessage()

func (*ServerInfoData) Reset 

func (m *ServerInfoData) Reset()

func (*ServerInfoData) String 

func (m *ServerInfoData) String() string

func (*ServerInfoData) XXX_DiscardUnknown 

func (m *ServerInfoData) XXX_DiscardUnknown()

func (*ServerInfoData) XXX_Marshal 

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

func (*ServerInfoData) XXX_Merge 

func (dst *ServerInfoData) XXX_Merge(src proto.Message)

func (*ServerInfoData) XXX_Size 

func (m *ServerInfoData) XXX_Size() int

func (*ServerInfoData) XXX_Unmarshal 

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

type StatusType 

type StatusType int32
const (
	StatusType_Invalid StatusType = 0
	StatusType_OK      StatusType = 1
	StatusType_Error   StatusType = 2
)

func (StatusType) EnumDescriptor 

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

func (StatusType) String 

func (x StatusType) String() string

type VersionData 

type VersionData struct {
	Major                uint32   `protobuf:"varint,1,opt,name=Major,proto3" json:"Major,omitempty"`
	Minor                uint32   `protobuf:"varint,2,opt,name=Minor,proto3" json:"Minor,omitempty"`
	Hash                 uint32   `protobuf:"varint,3,opt,name=Hash,proto3" json:"Hash,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func ParseCmdHelloBody 

func ParseCmdHelloBody(data []uint8) (VersionData, string)

func SplitProtocolVersion 

func SplitProtocolVersion(protocol uint64) VersionData

func (*VersionData) AsString 

func (v *VersionData) AsString() string

func (*VersionData) Descriptor 

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

func (*VersionData) GetHash 

func (m *VersionData) GetHash() uint32

func (*VersionData) GetMajor 

func (m *VersionData) GetMajor() uint32

func (*VersionData) GetMinor 

func (m *VersionData) GetMinor() uint32

func (*VersionData) ProtoMessage 

func (*VersionData) ProtoMessage()

func (*VersionData) Reset 

func (m *VersionData) Reset()

func (*VersionData) String 

func (m *VersionData) String() string

func (*VersionData) ToUint64 

func (v *VersionData) ToUint64() uint64

func (*VersionData) XXX_DiscardUnknown 

func (m *VersionData) XXX_DiscardUnknown()

func (*VersionData) XXX_Marshal 

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

func (*VersionData) XXX_Merge 

func (dst *VersionData) XXX_Merge(src proto.Message)

func (*VersionData) XXX_Size 

func (m *VersionData) XXX_Size() int

func (*VersionData) XXX_Unmarshal 

func (m *VersionData) 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.