protocol

package
v0.0.0-...-8567bd0 Latest Latest
Warning

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

 Go to latest Published: Nov 29, 2019 License: Apache-2.0 Imports: 3 Imported by: 1

Documentation

Overview

Package protocol contains the communications protocol protobuffer definition

Index

Constants

This section is empty.

Variables

View Source 
var ConnectionRefusedReason_name = map[int32]string{
	0: "UNKNOWN_REASON",
	1: "SERVER_FULL",
	2: "AUTH_FAILED",
}
View Source 
var ConnectionRefusedReason_value = map[string]int32{
	"UNKNOWN_REASON": 0,
	"SERVER_FULL":    1,
	"AUTH_FAILED":    2,
}
View Source 
var Format_name = map[int32]string{
	0: "UNKNOWN_FORMAT",
	1: "PLAIN",
	2: "GZIP",
}
View Source 
var Format_value = map[string]int32{
	"UNKNOWN_FORMAT": 0,
	"PLAIN":          1,
	"GZIP":           2,
}
View Source 
var MessageType_name = map[int32]string{
	0:  "UNKNOWN_MESSAGE_TYPE",
	1:  "WELCOME",
	2:  "CONNECT",
	3:  "WEBRTC_OFFER",
	4:  "WEBRTC_ANSWER",
	5:  "WEBRTC_ICE_CANDIDATE",
	6:  "PING",
	7:  "SUBSCRIPTION",
	8:  "AUTH",
	9:  "TOPIC",
	10: "TOPIC_FW",
	11: "TOPIC_IDENTITY",
	12: "TOPIC_IDENTITY_FW",
	13: "CONNECTION_REFUSED",
	14: "ERROR",
}
View Source 
var MessageType_value = map[string]int32{
	"UNKNOWN_MESSAGE_TYPE": 0,
	"WELCOME":              1,
	"CONNECT":              2,
	"WEBRTC_OFFER":         3,
	"WEBRTC_ANSWER":        4,
	"WEBRTC_ICE_CANDIDATE": 5,
	"PING":                 6,
	"SUBSCRIPTION":         7,
	"AUTH":                 8,
	"TOPIC":                9,
	"TOPIC_FW":             10,
	"TOPIC_IDENTITY":       11,
	"TOPIC_IDENTITY_FW":    12,
	"CONNECTION_REFUSED":   13,
	"ERROR":                14,
}
View Source 
var Role_name = map[int32]string{
	0: "UNKNOWN_ROLE",
	1: "CLIENT",
	2: "COMMUNICATION_SERVER",
	3: "COMMUNICATION_SERVER_HUB",
}
View Source 
var Role_value = map[string]int32{
	"UNKNOWN_ROLE":             0,
	"CLIENT":                   1,
	"COMMUNICATION_SERVER":     2,
	"COMMUNICATION_SERVER_HUB": 3,
}

Functions

This section is empty.

Types

type AuthMessage 

type AuthMessage struct {
	Type                 MessageType `protobuf:"varint,1,opt,name=type,proto3,enum=protocol.MessageType" json:"type,omitempty"`
	Role                 Role        `protobuf:"varint,2,opt,name=role,proto3,enum=protocol.Role" json:"role,omitempty"`
	Body                 []byte      `protobuf:"bytes,3,opt,name=body,proto3" json:"body,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*AuthMessage) Descriptor 

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

func (*AuthMessage) GetBody 

func (m *AuthMessage) GetBody() []byte

func (*AuthMessage) GetRole 

func (m *AuthMessage) GetRole() Role

func (*AuthMessage) GetType 

func (m *AuthMessage) GetType() MessageType

func (*AuthMessage) ProtoMessage 

func (*AuthMessage) ProtoMessage()

func (*AuthMessage) Reset 

func (m *AuthMessage) Reset()

func (*AuthMessage) String 

func (m *AuthMessage) String() string

func (*AuthMessage) XXX_DiscardUnknown 

func (m *AuthMessage) XXX_DiscardUnknown()

func (*AuthMessage) XXX_Marshal 

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

func (*AuthMessage) XXX_Merge 

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

func (*AuthMessage) XXX_Size 

func (m *AuthMessage) XXX_Size() int

func (*AuthMessage) XXX_Unmarshal 

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

type ConnectMessage 

type ConnectMessage struct {
	Type                 MessageType `protobuf:"varint,1,opt,name=type,proto3,enum=protocol.MessageType" json:"type,omitempty"`
	FromAlias            uint64      `protobuf:"varint,2,opt,name=from_alias,json=fromAlias,proto3" json:"from_alias,omitempty"`
	ToAlias              uint64      `protobuf:"varint,3,opt,name=to_alias,json=toAlias,proto3" json:"to_alias,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*ConnectMessage) Descriptor 

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

func (*ConnectMessage) GetFromAlias 

func (m *ConnectMessage) GetFromAlias() uint64

func (*ConnectMessage) GetToAlias 

func (m *ConnectMessage) GetToAlias() uint64

func (*ConnectMessage) GetType 

func (m *ConnectMessage) GetType() MessageType

func (*ConnectMessage) ProtoMessage 

func (*ConnectMessage) ProtoMessage()

func (*ConnectMessage) Reset 

func (m *ConnectMessage) Reset()

func (*ConnectMessage) String 

func (m *ConnectMessage) String() string

func (*ConnectMessage) XXX_DiscardUnknown 

func (m *ConnectMessage) XXX_DiscardUnknown()

func (*ConnectMessage) XXX_Marshal 

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

func (*ConnectMessage) XXX_Merge 

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

func (*ConnectMessage) XXX_Size 

func (m *ConnectMessage) XXX_Size() int

func (*ConnectMessage) XXX_Unmarshal 

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

type ConnectionRefusedMessage 

type ConnectionRefusedMessage struct {
	Type                 MessageType             `protobuf:"varint,1,opt,name=type,proto3,enum=protocol.MessageType" json:"type,omitempty"`
	FromAlias            uint64                  `protobuf:"varint,2,opt,name=from_alias,json=fromAlias,proto3" json:"from_alias,omitempty"`
	ToAlias              uint64                  `protobuf:"varint,3,opt,name=to_alias,json=toAlias,proto3" json:"to_alias,omitempty"`
	Reason               ConnectionRefusedReason `protobuf:"varint,4,opt,name=reason,proto3,enum=protocol.ConnectionRefusedReason" json:"reason,omitempty"`
	Data                 []byte                  `protobuf:"bytes,5,opt,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

func (*ConnectionRefusedMessage) Descriptor 

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

func (*ConnectionRefusedMessage) GetData 

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

func (*ConnectionRefusedMessage) GetFromAlias 

func (m *ConnectionRefusedMessage) GetFromAlias() uint64

func (*ConnectionRefusedMessage) GetReason 

func (m *ConnectionRefusedMessage) GetReason() ConnectionRefusedReason

func (*ConnectionRefusedMessage) GetToAlias 

func (m *ConnectionRefusedMessage) GetToAlias() uint64

func (*ConnectionRefusedMessage) GetType 

func (m *ConnectionRefusedMessage) GetType() MessageType

func (*ConnectionRefusedMessage) ProtoMessage 

func (*ConnectionRefusedMessage) ProtoMessage()

func (*ConnectionRefusedMessage) Reset 

func (m *ConnectionRefusedMessage) Reset()

func (*ConnectionRefusedMessage) String 

func (m *ConnectionRefusedMessage) String() string

func (*ConnectionRefusedMessage) XXX_DiscardUnknown 

func (m *ConnectionRefusedMessage) XXX_DiscardUnknown()

func (*ConnectionRefusedMessage) XXX_Marshal 

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

func (*ConnectionRefusedMessage) XXX_Merge 

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

func (*ConnectionRefusedMessage) XXX_Size 

func (m *ConnectionRefusedMessage) XXX_Size() int

func (*ConnectionRefusedMessage) XXX_Unmarshal 

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

type ConnectionRefusedReason 

type ConnectionRefusedReason int32
const (
	ConnectionRefusedReason_UNKNOWN_REASON ConnectionRefusedReason = 0
	ConnectionRefusedReason_SERVER_FULL    ConnectionRefusedReason = 1
	ConnectionRefusedReason_AUTH_FAILED    ConnectionRefusedReason = 2
)

func (ConnectionRefusedReason) EnumDescriptor 

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

func (ConnectionRefusedReason) String 

func (x ConnectionRefusedReason) String() string

type CoordinatorMessage 

type CoordinatorMessage struct {
	Type                 MessageType `protobuf:"varint,1,opt,name=type,proto3,enum=protocol.MessageType" json:"type,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*CoordinatorMessage) Descriptor 

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

func (*CoordinatorMessage) GetType 

func (m *CoordinatorMessage) GetType() MessageType

func (*CoordinatorMessage) ProtoMessage 

func (*CoordinatorMessage) ProtoMessage()

func (*CoordinatorMessage) Reset 

func (m *CoordinatorMessage) Reset()

func (*CoordinatorMessage) String 

func (m *CoordinatorMessage) String() string

func (*CoordinatorMessage) XXX_DiscardUnknown 

func (m *CoordinatorMessage) XXX_DiscardUnknown()

func (*CoordinatorMessage) XXX_Marshal 

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

func (*CoordinatorMessage) XXX_Merge 

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

func (*CoordinatorMessage) XXX_Size 

func (m *CoordinatorMessage) XXX_Size() int

func (*CoordinatorMessage) XXX_Unmarshal 

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

type Format 

type Format int32
const (
	Format_UNKNOWN_FORMAT Format = 0
	Format_PLAIN          Format = 1
	Format_GZIP           Format = 2
)

func (Format) EnumDescriptor 

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

func (Format) String 

func (x Format) String() string

type IMarshaller 

type IMarshaller interface {
	Marshal(Message) ([]byte, error)
	Unmarshal([]byte, Message) error
}

IMarshaller reprensents the marhsall interface

type Marshaller 

type Marshaller struct{}

Marshaller is the default marshaller

func (*Marshaller) Marshal 

func (*Marshaller) Marshal(msg Message) ([]byte, error)

Marshal a message into a byte array

func (*Marshaller) Unmarshal 

func (*Marshaller) Unmarshal(bytes []byte, msg Message) error

Unmarshal a byte array into the given message

type Message 

type Message = proto.Message

Message convenience re-export

type MessageHeader 

type MessageHeader struct {
	Type                 MessageType `protobuf:"varint,1,opt,name=type,proto3,enum=protocol.MessageType" json:"type,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*MessageHeader) Descriptor 

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

func (*MessageHeader) GetType 

func (m *MessageHeader) GetType() MessageType

func (*MessageHeader) ProtoMessage 

func (*MessageHeader) ProtoMessage()

func (*MessageHeader) Reset 

func (m *MessageHeader) Reset()

func (*MessageHeader) String 

func (m *MessageHeader) String() string

func (*MessageHeader) XXX_DiscardUnknown 

func (m *MessageHeader) XXX_DiscardUnknown()

func (*MessageHeader) XXX_Marshal 

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

func (*MessageHeader) XXX_Merge 

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

func (*MessageHeader) XXX_Size 

func (m *MessageHeader) XXX_Size() int

func (*MessageHeader) XXX_Unmarshal 

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

type MessageType 

type MessageType int32
const (
	MessageType_UNKNOWN_MESSAGE_TYPE MessageType = 0
	MessageType_WELCOME              MessageType = 1
	MessageType_CONNECT              MessageType = 2
	MessageType_WEBRTC_OFFER         MessageType = 3
	MessageType_WEBRTC_ANSWER        MessageType = 4
	MessageType_WEBRTC_ICE_CANDIDATE MessageType = 5
	MessageType_PING                 MessageType = 6
	MessageType_SUBSCRIPTION         MessageType = 7
	MessageType_AUTH                 MessageType = 8
	MessageType_TOPIC                MessageType = 9
	MessageType_TOPIC_FW             MessageType = 10
	MessageType_TOPIC_IDENTITY       MessageType = 11
	MessageType_TOPIC_IDENTITY_FW    MessageType = 12
	MessageType_CONNECTION_REFUSED   MessageType = 13
	MessageType_ERROR                MessageType = 14
)

func (MessageType) EnumDescriptor 

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

func (MessageType) String 

func (x MessageType) String() string

type PingMessage 

type PingMessage struct {
	Type                 MessageType `protobuf:"varint,1,opt,name=type,proto3,enum=protocol.MessageType" json:"type,omitempty"`
	Time                 float64     `protobuf:"fixed64,2,opt,name=time,proto3" json:"time,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*PingMessage) Descriptor 

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

func (*PingMessage) GetTime 

func (m *PingMessage) GetTime() float64

func (*PingMessage) GetType 

func (m *PingMessage) GetType() MessageType

func (*PingMessage) ProtoMessage 

func (*PingMessage) ProtoMessage()

func (*PingMessage) Reset 

func (m *PingMessage) Reset()

func (*PingMessage) String 

func (m *PingMessage) String() string

func (*PingMessage) XXX_DiscardUnknown 

func (m *PingMessage) XXX_DiscardUnknown()

func (*PingMessage) XXX_Marshal 

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

func (*PingMessage) XXX_Merge 

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

func (*PingMessage) XXX_Size 

func (m *PingMessage) XXX_Size() int

func (*PingMessage) XXX_Unmarshal 

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

type Role 

type Role int32
const (
	Role_UNKNOWN_ROLE             Role = 0
	Role_CLIENT                   Role = 1
	Role_COMMUNICATION_SERVER     Role = 2
	Role_COMMUNICATION_SERVER_HUB Role = 3
)

func (Role) EnumDescriptor 

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

func (Role) String 

func (x Role) String() string

type SubscriptionMessage 

type SubscriptionMessage struct {
	Type                 MessageType `protobuf:"varint,1,opt,name=type,proto3,enum=protocol.MessageType" json:"type,omitempty"`
	Format               Format      `protobuf:"varint,2,opt,name=format,proto3,enum=protocol.Format" json:"format,omitempty"`
	Topics               []byte      `protobuf:"bytes,3,opt,name=topics,proto3" json:"topics,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

NOTE: topics is a space separated string in the format specified by Format

func (*SubscriptionMessage) Descriptor 

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

func (*SubscriptionMessage) GetFormat 

func (m *SubscriptionMessage) GetFormat() Format

func (*SubscriptionMessage) GetTopics 

func (m *SubscriptionMessage) GetTopics() []byte

func (*SubscriptionMessage) GetType 

func (m *SubscriptionMessage) GetType() MessageType

func (*SubscriptionMessage) ProtoMessage 

func (*SubscriptionMessage) ProtoMessage()

func (*SubscriptionMessage) Reset 

func (m *SubscriptionMessage) Reset()

func (*SubscriptionMessage) String 

func (m *SubscriptionMessage) String() string

func (*SubscriptionMessage) XXX_DiscardUnknown 

func (m *SubscriptionMessage) XXX_DiscardUnknown()

func (*SubscriptionMessage) XXX_Marshal 

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

func (*SubscriptionMessage) XXX_Merge 

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

func (*SubscriptionMessage) XXX_Size 

func (m *SubscriptionMessage) XXX_Size() int

func (*SubscriptionMessage) XXX_Unmarshal 

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

type TopicFWMessage 

type TopicFWMessage struct {
	Type                 MessageType `protobuf:"varint,1,opt,name=type,proto3,enum=protocol.MessageType" json:"type,omitempty"`
	FromAlias            uint64      `protobuf:"varint,2,opt,name=from_alias,json=fromAlias,proto3" json:"from_alias,omitempty"`
	Body                 []byte      `protobuf:"bytes,3,opt,name=body,proto3" json:"body,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*TopicFWMessage) Descriptor 

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

func (*TopicFWMessage) GetBody 

func (m *TopicFWMessage) GetBody() []byte

func (*TopicFWMessage) GetFromAlias 

func (m *TopicFWMessage) GetFromAlias() uint64

func (*TopicFWMessage) GetType 

func (m *TopicFWMessage) GetType() MessageType

func (*TopicFWMessage) ProtoMessage 

func (*TopicFWMessage) ProtoMessage()

func (*TopicFWMessage) Reset 

func (m *TopicFWMessage) Reset()

func (*TopicFWMessage) String 

func (m *TopicFWMessage) String() string

func (*TopicFWMessage) XXX_DiscardUnknown 

func (m *TopicFWMessage) XXX_DiscardUnknown()

func (*TopicFWMessage) XXX_Marshal 

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

func (*TopicFWMessage) XXX_Merge 

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

func (*TopicFWMessage) XXX_Size 

func (m *TopicFWMessage) XXX_Size() int

func (*TopicFWMessage) XXX_Unmarshal 

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

type TopicIdentityFWMessage 

type TopicIdentityFWMessage struct {
	Type                 MessageType `protobuf:"varint,1,opt,name=type,proto3,enum=protocol.MessageType" json:"type,omitempty"`
	FromAlias            uint64      `protobuf:"varint,2,opt,name=from_alias,json=fromAlias,proto3" json:"from_alias,omitempty"`
	Identity             []byte      `protobuf:"bytes,3,opt,name=identity,proto3" json:"identity,omitempty"`
	Role                 Role        `protobuf:"varint,4,opt,name=role,proto3,enum=protocol.Role" json:"role,omitempty"`
	Body                 []byte      `protobuf:"bytes,5,opt,name=body,proto3" json:"body,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*TopicIdentityFWMessage) Descriptor 

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

func (*TopicIdentityFWMessage) GetBody 

func (m *TopicIdentityFWMessage) GetBody() []byte

func (*TopicIdentityFWMessage) GetFromAlias 

func (m *TopicIdentityFWMessage) GetFromAlias() uint64

func (*TopicIdentityFWMessage) GetIdentity 

func (m *TopicIdentityFWMessage) GetIdentity() []byte

func (*TopicIdentityFWMessage) GetRole 

func (m *TopicIdentityFWMessage) GetRole() Role

func (*TopicIdentityFWMessage) GetType 

func (m *TopicIdentityFWMessage) GetType() MessageType

func (*TopicIdentityFWMessage) ProtoMessage 

func (*TopicIdentityFWMessage) ProtoMessage()

func (*TopicIdentityFWMessage) Reset 

func (m *TopicIdentityFWMessage) Reset()

func (*TopicIdentityFWMessage) String 

func (m *TopicIdentityFWMessage) String() string

func (*TopicIdentityFWMessage) XXX_DiscardUnknown 

func (m *TopicIdentityFWMessage) XXX_DiscardUnknown()

func (*TopicIdentityFWMessage) XXX_Marshal 

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

func (*TopicIdentityFWMessage) XXX_Merge 

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

func (*TopicIdentityFWMessage) XXX_Size 

func (m *TopicIdentityFWMessage) XXX_Size() int

func (*TopicIdentityFWMessage) XXX_Unmarshal 

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

type TopicIdentityMessage 

type TopicIdentityMessage struct {
	Type                 MessageType `protobuf:"varint,1,opt,name=type,proto3,enum=protocol.MessageType" json:"type,omitempty"`
	FromAlias            uint64      `protobuf:"varint,2,opt,name=from_alias,json=fromAlias,proto3" json:"from_alias,omitempty"`
	Topic                string      `protobuf:"bytes,3,opt,name=topic,proto3" json:"topic,omitempty"`
	Identity             []byte      `protobuf:"bytes,4,opt,name=identity,proto3" json:"identity,omitempty"`
	Role                 Role        `protobuf:"varint,5,opt,name=role,proto3,enum=protocol.Role" json:"role,omitempty"`
	Body                 []byte      `protobuf:"bytes,6,opt,name=body,proto3" json:"body,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*TopicIdentityMessage) Descriptor 

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

func (*TopicIdentityMessage) GetBody 

func (m *TopicIdentityMessage) GetBody() []byte

func (*TopicIdentityMessage) GetFromAlias 

func (m *TopicIdentityMessage) GetFromAlias() uint64

func (*TopicIdentityMessage) GetIdentity 

func (m *TopicIdentityMessage) GetIdentity() []byte

func (*TopicIdentityMessage) GetRole 

func (m *TopicIdentityMessage) GetRole() Role

func (*TopicIdentityMessage) GetTopic 

func (m *TopicIdentityMessage) GetTopic() string

func (*TopicIdentityMessage) GetType 

func (m *TopicIdentityMessage) GetType() MessageType

func (*TopicIdentityMessage) ProtoMessage 

func (*TopicIdentityMessage) ProtoMessage()

func (*TopicIdentityMessage) Reset 

func (m *TopicIdentityMessage) Reset()

func (*TopicIdentityMessage) String 

func (m *TopicIdentityMessage) String() string

func (*TopicIdentityMessage) XXX_DiscardUnknown 

func (m *TopicIdentityMessage) XXX_DiscardUnknown()

func (*TopicIdentityMessage) XXX_Marshal 

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

func (*TopicIdentityMessage) XXX_Merge 

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

func (*TopicIdentityMessage) XXX_Size 

func (m *TopicIdentityMessage) XXX_Size() int

func (*TopicIdentityMessage) XXX_Unmarshal 

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

type TopicMessage 

type TopicMessage struct {
	Type                 MessageType `protobuf:"varint,1,opt,name=type,proto3,enum=protocol.MessageType" json:"type,omitempty"`
	FromAlias            uint64      `protobuf:"varint,2,opt,name=from_alias,json=fromAlias,proto3" json:"from_alias,omitempty"`
	Topic                string      `protobuf:"bytes,3,opt,name=topic,proto3" json:"topic,omitempty"`
	Body                 []byte      `protobuf:"bytes,4,opt,name=body,proto3" json:"body,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*TopicMessage) Descriptor 

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

func (*TopicMessage) GetBody 

func (m *TopicMessage) GetBody() []byte

func (*TopicMessage) GetFromAlias 

func (m *TopicMessage) GetFromAlias() uint64

func (*TopicMessage) GetTopic 

func (m *TopicMessage) GetTopic() string

func (*TopicMessage) GetType 

func (m *TopicMessage) GetType() MessageType

func (*TopicMessage) ProtoMessage 

func (*TopicMessage) ProtoMessage()

func (*TopicMessage) Reset 

func (m *TopicMessage) Reset()

func (*TopicMessage) String 

func (m *TopicMessage) String() string

func (*TopicMessage) XXX_DiscardUnknown 

func (m *TopicMessage) XXX_DiscardUnknown()

func (*TopicMessage) XXX_Marshal 

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

func (*TopicMessage) XXX_Merge 

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

func (*TopicMessage) XXX_Size 

func (m *TopicMessage) XXX_Size() int

func (*TopicMessage) XXX_Unmarshal 

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

type WebRtcMessage 

type WebRtcMessage struct {
	Type                 MessageType `protobuf:"varint,1,opt,name=type,proto3,enum=protocol.MessageType" json:"type,omitempty"`
	FromAlias            uint64      `protobuf:"varint,2,opt,name=from_alias,json=fromAlias,proto3" json:"from_alias,omitempty"`
	ToAlias              uint64      `protobuf:"varint,3,opt,name=to_alias,json=toAlias,proto3" json:"to_alias,omitempty"`
	Data                 []byte      `protobuf:"bytes,4,opt,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*WebRtcMessage) Descriptor 

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

func (*WebRtcMessage) GetData 

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

func (*WebRtcMessage) GetFromAlias 

func (m *WebRtcMessage) GetFromAlias() uint64

func (*WebRtcMessage) GetToAlias 

func (m *WebRtcMessage) GetToAlias() uint64

func (*WebRtcMessage) GetType 

func (m *WebRtcMessage) GetType() MessageType

func (*WebRtcMessage) ProtoMessage 

func (*WebRtcMessage) ProtoMessage()

func (*WebRtcMessage) Reset 

func (m *WebRtcMessage) Reset()

func (*WebRtcMessage) String 

func (m *WebRtcMessage) String() string

func (*WebRtcMessage) XXX_DiscardUnknown 

func (m *WebRtcMessage) XXX_DiscardUnknown()

func (*WebRtcMessage) XXX_Marshal 

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

func (*WebRtcMessage) XXX_Merge 

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

func (*WebRtcMessage) XXX_Size 

func (m *WebRtcMessage) XXX_Size() int

func (*WebRtcMessage) XXX_Unmarshal 

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

type WelcomeMessage 

type WelcomeMessage struct {
	Type                 MessageType `protobuf:"varint,1,opt,name=type,proto3,enum=protocol.MessageType" json:"type,omitempty"`
	Alias                uint64      `protobuf:"varint,2,opt,name=alias,proto3" json:"alias,omitempty"`
	AvailableServers     []uint64    `protobuf:"varint,3,rep,packed,name=available_servers,json=availableServers,proto3" json:"available_servers,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*WelcomeMessage) Descriptor 

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

func (*WelcomeMessage) GetAlias 

func (m *WelcomeMessage) GetAlias() uint64

func (*WelcomeMessage) GetAvailableServers 

func (m *WelcomeMessage) GetAvailableServers() []uint64

func (*WelcomeMessage) GetType 

func (m *WelcomeMessage) GetType() MessageType

func (*WelcomeMessage) ProtoMessage 

func (*WelcomeMessage) ProtoMessage()

func (*WelcomeMessage) Reset 

func (m *WelcomeMessage) Reset()

func (*WelcomeMessage) String 

func (m *WelcomeMessage) String() string

func (*WelcomeMessage) XXX_DiscardUnknown 

func (m *WelcomeMessage) XXX_DiscardUnknown()

func (*WelcomeMessage) XXX_Marshal 

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

func (*WelcomeMessage) XXX_Merge 

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

func (*WelcomeMessage) XXX_Size 

func (m *WelcomeMessage) XXX_Size() int

func (*WelcomeMessage) XXX_Unmarshal 

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