message

package
v0.3.3 Latest Latest
Warning

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

 Go to latest Published: May 29, 2020 License: GPL-3.0 Imports: 4 Imported by: 1

Documentation

Index

Constants

View Source 
const (
	AnnounceMessage         = 0x00
	DeviceAllowedMessage    = 0x10
	DeviceDisallowedMessage = 0x11
	StreamDataMessage       = 0x20
	PeerOnlineMessage       = 0xF0
	PeerOfflineMessage      = 0xF1
	WriteRequestMessage     = 0xF2
)

Messages opCodes

View Source 
const ServiceNumber uint32 = 0xECC377BC

ServiceNumber service identifier on mesh network. Insure protocol compatibility of all devices on mesh

Variables

This section is empty.

Functions

func FindOpCode 

func FindOpCode(message proto.Message) (byte, error)

FindOpCode message opCode from message type

func FromBuffer 

func FromBuffer(buffer []byte) (proto.Message, error)

FromBuffer get message instance from raw bytes buffer

func ToBuffer 

func ToBuffer(message proto.Message) ([]byte, error)

ToBuffer get bytes buffer from message instance

Types

type Announce 

type Announce struct {
	ServiceNumber        uint32   `protobuf:"varint,1,opt,name=service_number,json=serviceNumber,proto3" json:"service_number,omitempty"`
	DeviceName           string   `protobuf:"bytes,2,opt,name=device_name,json=deviceName,proto3" json:"device_name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Announce) Descriptor 

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

func (*Announce) GetDeviceName 

func (m *Announce) GetDeviceName() string

func (*Announce) GetServiceNumber 

func (m *Announce) GetServiceNumber() uint32

func (*Announce) ProtoMessage 

func (*Announce) ProtoMessage()

func (*Announce) Reset 

func (m *Announce) Reset()

func (*Announce) String 

func (m *Announce) String() string

func (*Announce) XXX_DiscardUnknown 

func (m *Announce) XXX_DiscardUnknown()

func (*Announce) XXX_Marshal 

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

func (*Announce) XXX_Merge 

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

func (*Announce) XXX_Size 

func (m *Announce) XXX_Size() int

func (*Announce) XXX_Unmarshal 

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

type DeviceAllowed 

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

func (*DeviceAllowed) Descriptor 

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

func (*DeviceAllowed) GetId 

func (m *DeviceAllowed) GetId() string

func (*DeviceAllowed) ProtoMessage 

func (*DeviceAllowed) ProtoMessage()

func (*DeviceAllowed) Reset 

func (m *DeviceAllowed) Reset()

func (*DeviceAllowed) String 

func (m *DeviceAllowed) String() string

func (*DeviceAllowed) XXX_DiscardUnknown 

func (m *DeviceAllowed) XXX_DiscardUnknown()

func (*DeviceAllowed) XXX_Marshal 

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

func (*DeviceAllowed) XXX_Merge 

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

func (*DeviceAllowed) XXX_Size 

func (m *DeviceAllowed) XXX_Size() int

func (*DeviceAllowed) XXX_Unmarshal 

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

type DeviceDisallowed 

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

func (*DeviceDisallowed) Descriptor 

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

func (*DeviceDisallowed) GetId 

func (m *DeviceDisallowed) GetId() string

func (*DeviceDisallowed) ProtoMessage 

func (*DeviceDisallowed) ProtoMessage()

func (*DeviceDisallowed) Reset 

func (m *DeviceDisallowed) Reset()

func (*DeviceDisallowed) String 

func (m *DeviceDisallowed) String() string

func (*DeviceDisallowed) XXX_DiscardUnknown 

func (m *DeviceDisallowed) XXX_DiscardUnknown()

func (*DeviceDisallowed) XXX_Marshal 

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

func (*DeviceDisallowed) XXX_Merge 

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

func (*DeviceDisallowed) XXX_Size 

func (m *DeviceDisallowed) XXX_Size() int

func (*DeviceDisallowed) XXX_Unmarshal 

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

type PeerOffline 

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

func (*PeerOffline) Descriptor 

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

func (*PeerOffline) GetId 

func (m *PeerOffline) GetId() string

func (*PeerOffline) ProtoMessage 

func (*PeerOffline) ProtoMessage()

func (*PeerOffline) Reset 

func (m *PeerOffline) Reset()

func (*PeerOffline) String 

func (m *PeerOffline) String() string

func (*PeerOffline) XXX_DiscardUnknown 

func (m *PeerOffline) XXX_DiscardUnknown()

func (*PeerOffline) XXX_Marshal 

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

func (*PeerOffline) XXX_Merge 

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

func (*PeerOffline) XXX_Size 

func (m *PeerOffline) XXX_Size() int

func (*PeerOffline) XXX_Unmarshal 

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

type PeerOnline 

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

func (*PeerOnline) Descriptor 

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

func (*PeerOnline) GetId 

func (m *PeerOnline) GetId() string

func (*PeerOnline) ProtoMessage 

func (*PeerOnline) ProtoMessage()

func (*PeerOnline) Reset 

func (m *PeerOnline) Reset()

func (*PeerOnline) String 

func (m *PeerOnline) String() string

func (*PeerOnline) XXX_DiscardUnknown 

func (m *PeerOnline) XXX_DiscardUnknown()

func (*PeerOnline) XXX_Marshal 

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

func (*PeerOnline) XXX_Merge 

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

func (*PeerOnline) XXX_Size 

func (m *PeerOnline) XXX_Size() int

func (*PeerOnline) XXX_Unmarshal 

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

type Receiver 

type Receiver interface {
	GetChan() chan proto.Message
}

Receiver interface of a internal message receiver

type StreamData 

type StreamData struct {
	SamplesLeft          []float64 `protobuf:"fixed64,1,rep,packed,name=samplesLeft,proto3" json:"samplesLeft,omitempty"`
	SamplesRight         []float64 `protobuf:"fixed64,2,rep,packed,name=samplesRight,proto3" json:"samplesRight,omitempty"`
	NextAt               int64     `protobuf:"varint,3,opt,name=nextAt,proto3" json:"nextAt,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*StreamData) Descriptor 

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

func (*StreamData) GetNextAt added in v0.3.0 

func (m *StreamData) GetNextAt() int64

func (*StreamData) GetSamplesLeft 

func (m *StreamData) GetSamplesLeft() []float64

func (*StreamData) GetSamplesRight 

func (m *StreamData) GetSamplesRight() []float64

func (*StreamData) ProtoMessage 

func (*StreamData) ProtoMessage()

func (*StreamData) Reset 

func (m *StreamData) Reset()

func (*StreamData) String 

func (m *StreamData) String() string

func (*StreamData) XXX_DiscardUnknown 

func (m *StreamData) XXX_DiscardUnknown()

func (*StreamData) XXX_Marshal 

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

func (*StreamData) XXX_Merge 

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

func (*StreamData) XXX_Size 

func (m *StreamData) XXX_Size() int

func (*StreamData) XXX_Unmarshal 

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

type WriteRequest 

type WriteRequest struct {
	DeviceName           string   `protobuf:"bytes,1,opt,name=device_name,json=deviceName,proto3" json:"device_name,omitempty"`
	Message              []byte   `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*WriteRequest) Descriptor 

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

func (*WriteRequest) GetDeviceName 

func (m *WriteRequest) GetDeviceName() string

func (*WriteRequest) GetMessage 

func (m *WriteRequest) GetMessage() []byte

func (*WriteRequest) ProtoMessage 

func (*WriteRequest) ProtoMessage()

func (*WriteRequest) Reset 

func (m *WriteRequest) Reset()

func (*WriteRequest) String 

func (m *WriteRequest) String() string

func (*WriteRequest) XXX_DiscardUnknown 

func (m *WriteRequest) XXX_DiscardUnknown()

func (*WriteRequest) XXX_Marshal 

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

func (*WriteRequest) XXX_Merge 

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

func (*WriteRequest) XXX_Size 

func (m *WriteRequest) XXX_Size() int

func (*WriteRequest) XXX_Unmarshal 

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