model

package
v0.1.6 Latest Latest
Warning

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

 Go to latest Published: Aug 16, 2021 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Overview

This package hosts the MessageTypes and their mappings for Unmarshaling data

Index

Constants

View Source 
const (
	MessageTypeClientPing     = network.MessageType("network-client-ping")
	MessageTypeClientValidate = network.MessageType("network-client-validate")
	MessageTypeClientData     = network.MessageType("network-client-data")
	MessageTypeClientSearch   = network.MessageType("network-client-search")
	MessageTypeClients        = network.MessageType("network-clients")

	MessageTypeStreamConnectionData   = network.MessageType("network-stream-conn-data")
	MessageTypeStreamConnectionStatus = network.MessageType("network-stream-conn-status")

	MessageTypeP2PClientInit        = network.MessageType("p2p-client-init")
	MessageTypeP2PConnectionRequest = network.MessageType("p2p-conn-request")
	MessageTypeP2PConnectionStatus  = network.MessageType("p2p-conn-status")
	MessageTypeP2PConnectionData    = network.MessageType("p2p-conn-data")
	MessageTypeP2PData              = network.MessageType("p2p-data")

	MessageTypeP2PRelayServers        = network.MessageType("p2p-relay-servers")
	MessageTypeP2PRelayValidate       = network.MessageType("p2p-relay-validate")
	MessageTypeP2PRelayAwait          = network.MessageType("p2p-relay-await")
	MessageTypeP2PRelayConnectionData = network.MessageType("p2p-relay-conn-data")
	MessageTypeP2PRelayPeersStatus    = network.MessageType("p2p-relay-peers-status")
	MessageTypeP2PRelayOpenStream     = network.MessageType("p2p-relay-open-stream")
	MessageTypeP2PRelayStreamInfo     = network.MessageType("p2p-relay-stream-info")
)

Variables

View Source 
var (
	ErrorUnmarshalProto = errors.New("unmarshal proto model not found")
)
View Source 
var File_model_broker_proto protoreflect.FileDescriptor
View Source 
var File_model_client_proto protoreflect.FileDescriptor
View Source 
var File_model_generic_proto protoreflect.FileDescriptor
View Source 
var File_model_p2p_proto protoreflect.FileDescriptor
View Source 
var File_model_relay_proto protoreflect.FileDescriptor
View Source 
var File_model_stream_proto protoreflect.FileDescriptor

Functions

func Unmarshal 

func Unmarshal(mtype network.MessageType) (body proto.Message, err error)

Unmarshal data based on the MessageType

Types

type BrokerClientContext 

type BrokerClientContext struct {
	// contains filtered or unexported fields
}

func (*BrokerClientContext) Descriptor deprecated 

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

Deprecated: Use BrokerClientContext.ProtoReflect.Descriptor instead.

func (*BrokerClientContext) ProtoMessage 

func (*BrokerClientContext) ProtoMessage()

func (*BrokerClientContext) ProtoReflect 

func (x *BrokerClientContext) ProtoReflect() protoreflect.Message

func (*BrokerClientContext) Reset 

func (x *BrokerClientContext) Reset()

func (*BrokerClientContext) String 

func (x *BrokerClientContext) String() string

type ClientData 

type ClientData struct {
	Status  bool              `protobuf:"varint,1,opt,name=status,proto3" json:"status,omitempty"`
	Message string            `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	Id      string            `protobuf:"bytes,3,opt,name=id,proto3" json:"id,omitempty"`
	Address string            `protobuf:"bytes,4,opt,name=address,proto3" json:"address,omitempty"`
	Tags    map[string]string `` /* 149-byte string literal not displayed */
	Data    map[string]string `` /* 149-byte string literal not displayed */
	// Types that are assignable to Ctx:
	//	*ClientData_BrokerCtx
	//	*ClientData_RelayCtx
	//	*ClientData_P2PCtx
	Ctx isClientData_Ctx `protobuf_oneof:"ctx"`
	// contains filtered or unexported fields
}

func (*ClientData) Descriptor deprecated 

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

Deprecated: Use ClientData.ProtoReflect.Descriptor instead.

func (*ClientData) GetAddress 

func (x *ClientData) GetAddress() string

func (*ClientData) GetBrokerCtx 

func (x *ClientData) GetBrokerCtx() *BrokerClientContext

func (*ClientData) GetCtx 

func (m *ClientData) GetCtx() isClientData_Ctx

func (*ClientData) GetData 

func (x *ClientData) GetData() map[string]string

func (*ClientData) GetId 

func (x *ClientData) GetId() string

func (*ClientData) GetMessage 

func (x *ClientData) GetMessage() string

func (*ClientData) GetP2PCtx 

func (x *ClientData) GetP2PCtx() *P2PClientContext

func (*ClientData) GetRelayCtx 

func (x *ClientData) GetRelayCtx() *RelayClientContext

func (*ClientData) GetStatus 

func (x *ClientData) GetStatus() bool

func (*ClientData) GetTags 

func (x *ClientData) GetTags() map[string]string

func (*ClientData) ProtoMessage 

func (*ClientData) ProtoMessage()

func (*ClientData) ProtoReflect 

func (x *ClientData) ProtoReflect() protoreflect.Message

func (*ClientData) Reset 

func (x *ClientData) Reset()

func (*ClientData) String 

func (x *ClientData) String() string

type ClientData_BrokerCtx 

type ClientData_BrokerCtx struct {
	BrokerCtx *BrokerClientContext `protobuf:"bytes,7,opt,name=brokerCtx,proto3,oneof"`
}

type ClientData_P2PCtx 

type ClientData_P2PCtx struct {
	P2PCtx *P2PClientContext `protobuf:"bytes,9,opt,name=p2pCtx,proto3,oneof"`
}

type ClientData_RelayCtx 

type ClientData_RelayCtx struct {
	RelayCtx *RelayClientContext `protobuf:"bytes,8,opt,name=relayCtx,proto3,oneof"`
}

type ClientPing 

type ClientPing struct {
	Time string `protobuf:"bytes,1,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

func (*ClientPing) Descriptor deprecated 

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

Deprecated: Use ClientPing.ProtoReflect.Descriptor instead.

func (*ClientPing) GetTime 

func (x *ClientPing) GetTime() string

func (*ClientPing) ProtoMessage 

func (*ClientPing) ProtoMessage()

func (*ClientPing) ProtoReflect 

func (x *ClientPing) ProtoReflect() protoreflect.Message

func (*ClientPing) Reset 

func (x *ClientPing) Reset()

func (*ClientPing) String 

func (x *ClientPing) String() string

type ClientSearch 

type ClientSearch struct {
	Id  string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Tag string `protobuf:"bytes,2,opt,name=tag,proto3" json:"tag,omitempty"`
	// contains filtered or unexported fields
}

func (*ClientSearch) Descriptor deprecated 

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

Deprecated: Use ClientSearch.ProtoReflect.Descriptor instead.

func (*ClientSearch) GetId 

func (x *ClientSearch) GetId() string

func (*ClientSearch) GetTag 

func (x *ClientSearch) GetTag() string

func (*ClientSearch) ProtoMessage 

func (*ClientSearch) ProtoMessage()

func (*ClientSearch) ProtoReflect 

func (x *ClientSearch) ProtoReflect() protoreflect.Message

func (*ClientSearch) Reset 

func (x *ClientSearch) Reset()

func (*ClientSearch) String 

func (x *ClientSearch) String() string

type ClientValidateData 

type ClientValidateData struct {
	Token string            `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"`
	Data  map[string]string `` /* 149-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ClientValidateData) Descriptor deprecated 

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

Deprecated: Use ClientValidateData.ProtoReflect.Descriptor instead.

func (*ClientValidateData) GetData 

func (x *ClientValidateData) GetData() map[string]string

func (*ClientValidateData) GetToken 

func (x *ClientValidateData) GetToken() string

func (*ClientValidateData) ProtoMessage 

func (*ClientValidateData) ProtoMessage()

func (*ClientValidateData) ProtoReflect 

func (x *ClientValidateData) ProtoReflect() protoreflect.Message

func (*ClientValidateData) Reset 

func (x *ClientValidateData) Reset()

func (*ClientValidateData) String 

func (x *ClientValidateData) String() string

type Clients 

type Clients struct {
	Status  bool     `protobuf:"varint,1,opt,name=status,proto3" json:"status,omitempty"`
	Message string   `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	Clients []string `protobuf:"bytes,3,rep,name=clients,proto3" json:"clients,omitempty"`
	// contains filtered or unexported fields
}

func (*Clients) Descriptor deprecated 

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

Deprecated: Use Clients.ProtoReflect.Descriptor instead.

func (*Clients) GetClients 

func (x *Clients) GetClients() []string

func (*Clients) GetMessage 

func (x *Clients) GetMessage() string

func (*Clients) GetStatus 

func (x *Clients) GetStatus() bool

func (*Clients) ProtoMessage 

func (*Clients) ProtoMessage()

func (*Clients) ProtoReflect 

func (x *Clients) ProtoReflect() protoreflect.Message

func (*Clients) Reset 

func (x *Clients) Reset()

func (*Clients) String 

func (x *Clients) String() string

type NoDataMessage 

type NoDataMessage struct {
	// contains filtered or unexported fields
}

func (*NoDataMessage) Descriptor deprecated 

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

Deprecated: Use NoDataMessage.ProtoReflect.Descriptor instead.

func (*NoDataMessage) ProtoMessage 

func (*NoDataMessage) ProtoMessage()

func (*NoDataMessage) ProtoReflect 

func (x *NoDataMessage) ProtoReflect() protoreflect.Message

func (*NoDataMessage) Reset 

func (x *NoDataMessage) Reset()

func (*NoDataMessage) String 

func (x *NoDataMessage) String() string

type P2PClientContext 

type P2PClientContext struct {
	ConnId string `protobuf:"bytes,1,opt,name=connId,proto3" json:"connId,omitempty"`
	PeerId string `protobuf:"bytes,2,opt,name=peerId,proto3" json:"peerId,omitempty"`
	Active bool   `protobuf:"varint,3,opt,name=active,proto3" json:"active,omitempty"`
	// contains filtered or unexported fields
}

func (*P2PClientContext) Descriptor deprecated 

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

Deprecated: Use P2PClientContext.ProtoReflect.Descriptor instead.

func (*P2PClientContext) GetActive 

func (x *P2PClientContext) GetActive() bool

func (*P2PClientContext) GetConnId 

func (x *P2PClientContext) GetConnId() string

func (*P2PClientContext) GetPeerId 

func (x *P2PClientContext) GetPeerId() string

func (*P2PClientContext) ProtoMessage 

func (*P2PClientContext) ProtoMessage()

func (*P2PClientContext) ProtoReflect 

func (x *P2PClientContext) ProtoReflect() protoreflect.Message

func (*P2PClientContext) Reset 

func (x *P2PClientContext) Reset()

func (*P2PClientContext) String 

func (x *P2PClientContext) String() string

type P2PConnectionData 

type P2PConnectionData struct {
	Id           string       `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Mode         string       `protobuf:"bytes,2,opt,name=mode,proto3" json:"mode,omitempty"`
	Status       bool         `protobuf:"varint,3,opt,name=status,proto3" json:"status,omitempty"`
	Retry        bool         `protobuf:"varint,4,opt,name=retry,proto3" json:"retry,omitempty"`
	Message      string       `protobuf:"bytes,5,opt,name=message,proto3" json:"message,omitempty"`
	Peer         *P2PPeerData `protobuf:"bytes,6,opt,name=peer,proto3" json:"peer,omitempty"`
	RelayAddress string       `protobuf:"bytes,7,opt,name=relayAddress,proto3" json:"relayAddress,omitempty"`
	// contains filtered or unexported fields
}

func (*P2PConnectionData) Descriptor deprecated 

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

Deprecated: Use P2PConnectionData.ProtoReflect.Descriptor instead.

func (*P2PConnectionData) GetId 

func (x *P2PConnectionData) GetId() string

func (*P2PConnectionData) GetMessage 

func (x *P2PConnectionData) GetMessage() string

func (*P2PConnectionData) GetMode 

func (x *P2PConnectionData) GetMode() string

func (*P2PConnectionData) GetPeer 

func (x *P2PConnectionData) GetPeer() *P2PPeerData

func (*P2PConnectionData) GetRelayAddress 

func (x *P2PConnectionData) GetRelayAddress() string

func (*P2PConnectionData) GetRetry 

func (x *P2PConnectionData) GetRetry() bool

func (*P2PConnectionData) GetStatus 

func (x *P2PConnectionData) GetStatus() bool

func (*P2PConnectionData) ProtoMessage 

func (*P2PConnectionData) ProtoMessage()

func (*P2PConnectionData) ProtoReflect 

func (x *P2PConnectionData) ProtoReflect() protoreflect.Message

func (*P2PConnectionData) Reset 

func (x *P2PConnectionData) Reset()

func (*P2PConnectionData) String 

func (x *P2PConnectionData) String() string

type P2PConnectionRequest 

type P2PConnectionRequest struct {
	Id           string       `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Mode         string       `protobuf:"bytes,2,opt,name=mode,proto3" json:"mode,omitempty"`
	RelayAddress string       `protobuf:"bytes,3,opt,name=relayAddress,proto3" json:"relayAddress,omitempty"`
	Peer         *P2PPeerData `protobuf:"bytes,4,opt,name=peer,proto3" json:"peer,omitempty"`
	// contains filtered or unexported fields
}

func (*P2PConnectionRequest) Descriptor deprecated 

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

Deprecated: Use P2PConnectionRequest.ProtoReflect.Descriptor instead.

func (*P2PConnectionRequest) GetId 

func (x *P2PConnectionRequest) GetId() string

func (*P2PConnectionRequest) GetMode 

func (x *P2PConnectionRequest) GetMode() string

func (*P2PConnectionRequest) GetPeer 

func (x *P2PConnectionRequest) GetPeer() *P2PPeerData

func (*P2PConnectionRequest) GetRelayAddress 

func (x *P2PConnectionRequest) GetRelayAddress() string

func (*P2PConnectionRequest) ProtoMessage 

func (*P2PConnectionRequest) ProtoMessage()

func (*P2PConnectionRequest) ProtoReflect 

func (x *P2PConnectionRequest) ProtoReflect() protoreflect.Message

func (*P2PConnectionRequest) Reset 

func (x *P2PConnectionRequest) Reset()

func (*P2PConnectionRequest) String 

func (x *P2PConnectionRequest) String() string

type P2PConnectionStatus 

type P2PConnectionStatus struct {
	Id      string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Status  bool   `protobuf:"varint,2,opt,name=status,proto3" json:"status,omitempty"`
	Message string `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*P2PConnectionStatus) Descriptor deprecated 

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

Deprecated: Use P2PConnectionStatus.ProtoReflect.Descriptor instead.

func (*P2PConnectionStatus) GetId 

func (x *P2PConnectionStatus) GetId() string

func (*P2PConnectionStatus) GetMessage 

func (x *P2PConnectionStatus) GetMessage() string

func (*P2PConnectionStatus) GetStatus 

func (x *P2PConnectionStatus) GetStatus() bool

func (*P2PConnectionStatus) ProtoMessage 

func (*P2PConnectionStatus) ProtoMessage()

func (*P2PConnectionStatus) ProtoReflect 

func (x *P2PConnectionStatus) ProtoReflect() protoreflect.Message

func (*P2PConnectionStatus) Reset 

func (x *P2PConnectionStatus) Reset()

func (*P2PConnectionStatus) String 

func (x *P2PConnectionStatus) String() string

type P2PData 

type P2PData struct {
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*P2PData) Descriptor deprecated 

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

Deprecated: Use P2PData.ProtoReflect.Descriptor instead.

func (*P2PData) GetData 

func (x *P2PData) GetData() []byte

func (*P2PData) ProtoMessage 

func (*P2PData) ProtoMessage()

func (*P2PData) ProtoReflect 

func (x *P2PData) ProtoReflect() protoreflect.Message

func (*P2PData) Reset 

func (x *P2PData) Reset()

func (*P2PData) String 

func (x *P2PData) String() string

type P2PPeerData 

type P2PPeerData struct {
	Id        string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Address   string   `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
	Addresses []string `protobuf:"bytes,3,rep,name=addresses,proto3" json:"addresses,omitempty"`
	// contains filtered or unexported fields
}

func (*P2PPeerData) Descriptor deprecated 

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

Deprecated: Use P2PPeerData.ProtoReflect.Descriptor instead.

func (*P2PPeerData) GetAddress 

func (x *P2PPeerData) GetAddress() string

func (*P2PPeerData) GetAddresses 

func (x *P2PPeerData) GetAddresses() []string

func (*P2PPeerData) GetId 

func (x *P2PPeerData) GetId() string

func (*P2PPeerData) ProtoMessage 

func (*P2PPeerData) ProtoMessage()

func (*P2PPeerData) ProtoReflect 

func (x *P2PPeerData) ProtoReflect() protoreflect.Message

func (*P2PPeerData) Reset 

func (x *P2PPeerData) Reset()

func (*P2PPeerData) String 

func (x *P2PPeerData) String() string

type P2PRelayConnectionData 

type P2PRelayConnectionData struct {
	Status     bool         `protobuf:"varint,1,opt,name=status,proto3" json:"status,omitempty"`
	Message    string       `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	Id         string       `protobuf:"bytes,3,opt,name=id,proto3" json:"id,omitempty"`
	Mode       string       `protobuf:"bytes,4,opt,name=mode,proto3" json:"mode,omitempty"`
	Peer       *P2PPeerData `protobuf:"bytes,5,opt,name=peer,proto3" json:"peer,omitempty"`
	SourcePeer *P2PPeerData `protobuf:"bytes,6,opt,name=sourcePeer,proto3" json:"sourcePeer,omitempty"`
	TargetPeer *P2PPeerData `protobuf:"bytes,7,opt,name=targetPeer,proto3" json:"targetPeer,omitempty"`
	// contains filtered or unexported fields
}

func (*P2PRelayConnectionData) Descriptor deprecated 

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

Deprecated: Use P2PRelayConnectionData.ProtoReflect.Descriptor instead.

func (*P2PRelayConnectionData) GetId 

func (x *P2PRelayConnectionData) GetId() string

func (*P2PRelayConnectionData) GetMessage 

func (x *P2PRelayConnectionData) GetMessage() string

func (*P2PRelayConnectionData) GetMode 

func (x *P2PRelayConnectionData) GetMode() string

func (*P2PRelayConnectionData) GetPeer 

func (x *P2PRelayConnectionData) GetPeer() *P2PPeerData

func (*P2PRelayConnectionData) GetSourcePeer 

func (x *P2PRelayConnectionData) GetSourcePeer() *P2PPeerData

func (*P2PRelayConnectionData) GetStatus 

func (x *P2PRelayConnectionData) GetStatus() bool

func (*P2PRelayConnectionData) GetTargetPeer 

func (x *P2PRelayConnectionData) GetTargetPeer() *P2PPeerData

func (*P2PRelayConnectionData) ProtoMessage 

func (*P2PRelayConnectionData) ProtoMessage()

func (*P2PRelayConnectionData) ProtoReflect 

func (x *P2PRelayConnectionData) ProtoReflect() protoreflect.Message

func (*P2PRelayConnectionData) Reset 

func (x *P2PRelayConnectionData) Reset()

func (*P2PRelayConnectionData) String 

func (x *P2PRelayConnectionData) String() string

type P2PRelayOpenStream 

type P2PRelayOpenStream struct {
	Metadata map[string]string `` /* 157-byte string literal not displayed */
	Data     map[string]string `` /* 149-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*P2PRelayOpenStream) Descriptor deprecated 

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

Deprecated: Use P2PRelayOpenStream.ProtoReflect.Descriptor instead.

func (*P2PRelayOpenStream) GetData 

func (x *P2PRelayOpenStream) GetData() map[string]string

func (*P2PRelayOpenStream) GetMetadata 

func (x *P2PRelayOpenStream) GetMetadata() map[string]string

func (*P2PRelayOpenStream) ProtoMessage 

func (*P2PRelayOpenStream) ProtoMessage()

func (*P2PRelayOpenStream) ProtoReflect 

func (x *P2PRelayOpenStream) ProtoReflect() protoreflect.Message

func (*P2PRelayOpenStream) Reset 

func (x *P2PRelayOpenStream) Reset()

func (*P2PRelayOpenStream) String 

func (x *P2PRelayOpenStream) String() string

type P2PRelayPeersStatus 

type P2PRelayPeersStatus struct {
	Status  bool   `protobuf:"varint,1,opt,name=status,proto3" json:"status,omitempty"`
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*P2PRelayPeersStatus) Descriptor deprecated 

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

Deprecated: Use P2PRelayPeersStatus.ProtoReflect.Descriptor instead.

func (*P2PRelayPeersStatus) GetMessage 

func (x *P2PRelayPeersStatus) GetMessage() string

func (*P2PRelayPeersStatus) GetStatus 

func (x *P2PRelayPeersStatus) GetStatus() bool

func (*P2PRelayPeersStatus) ProtoMessage 

func (*P2PRelayPeersStatus) ProtoMessage()

func (*P2PRelayPeersStatus) ProtoReflect 

func (x *P2PRelayPeersStatus) ProtoReflect() protoreflect.Message

func (*P2PRelayPeersStatus) Reset 

func (x *P2PRelayPeersStatus) Reset()

func (*P2PRelayPeersStatus) String 

func (x *P2PRelayPeersStatus) String() string

type P2PRelayServers 

type P2PRelayServers struct {
	Servers []string `protobuf:"bytes,1,rep,name=servers,proto3" json:"servers,omitempty"`
	// contains filtered or unexported fields
}

func (*P2PRelayServers) Descriptor deprecated 

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

Deprecated: Use P2PRelayServers.ProtoReflect.Descriptor instead.

func (*P2PRelayServers) GetServers 

func (x *P2PRelayServers) GetServers() []string

func (*P2PRelayServers) ProtoMessage 

func (*P2PRelayServers) ProtoMessage()

func (*P2PRelayServers) ProtoReflect 

func (x *P2PRelayServers) ProtoReflect() protoreflect.Message

func (*P2PRelayServers) Reset 

func (x *P2PRelayServers) Reset()

func (*P2PRelayServers) String 

func (x *P2PRelayServers) String() string

type P2PRelayStreamInfo 

type P2PRelayStreamInfo struct {
	Status  bool   `protobuf:"varint,1,opt,name=status,proto3" json:"status,omitempty"`
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	Id      string `protobuf:"bytes,3,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*P2PRelayStreamInfo) Descriptor deprecated 

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

Deprecated: Use P2PRelayStreamInfo.ProtoReflect.Descriptor instead.

func (*P2PRelayStreamInfo) GetId 

func (x *P2PRelayStreamInfo) GetId() string

func (*P2PRelayStreamInfo) GetMessage 

func (x *P2PRelayStreamInfo) GetMessage() string

func (*P2PRelayStreamInfo) GetStatus 

func (x *P2PRelayStreamInfo) GetStatus() bool

func (*P2PRelayStreamInfo) ProtoMessage 

func (*P2PRelayStreamInfo) ProtoMessage()

func (*P2PRelayStreamInfo) ProtoReflect 

func (x *P2PRelayStreamInfo) ProtoReflect() protoreflect.Message

func (*P2PRelayStreamInfo) Reset 

func (x *P2PRelayStreamInfo) Reset()

func (*P2PRelayStreamInfo) String 

func (x *P2PRelayStreamInfo) String() string

type RelayClientContext 

type RelayClientContext struct {
	ConnectionId string `protobuf:"bytes,1,opt,name=connectionId,proto3" json:"connectionId,omitempty"`
	SourcePeerId string `protobuf:"bytes,2,opt,name=sourcePeerId,proto3" json:"sourcePeerId,omitempty"`
	TargetPeerId string `protobuf:"bytes,3,opt,name=targetPeerId,proto3" json:"targetPeerId,omitempty"`
	// contains filtered or unexported fields
}

func (*RelayClientContext) Descriptor deprecated 

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

Deprecated: Use RelayClientContext.ProtoReflect.Descriptor instead.

func (*RelayClientContext) GetConnectionId 

func (x *RelayClientContext) GetConnectionId() string

func (*RelayClientContext) GetSourcePeerId 

func (x *RelayClientContext) GetSourcePeerId() string

func (*RelayClientContext) GetTargetPeerId 

func (x *RelayClientContext) GetTargetPeerId() string

func (*RelayClientContext) ProtoMessage 

func (*RelayClientContext) ProtoMessage()

func (*RelayClientContext) ProtoReflect 

func (x *RelayClientContext) ProtoReflect() protoreflect.Message

func (*RelayClientContext) Reset 

func (x *RelayClientContext) Reset()

func (*RelayClientContext) String 

func (x *RelayClientContext) String() string

type StreamConnectionData 

type StreamConnectionData struct {
	Id       string            `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Metadata map[string]string `` /* 157-byte string literal not displayed */
	Data     map[string]string `` /* 149-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*StreamConnectionData) Descriptor deprecated 

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

Deprecated: Use StreamConnectionData.ProtoReflect.Descriptor instead.

func (*StreamConnectionData) GetData 

func (x *StreamConnectionData) GetData() map[string]string

func (*StreamConnectionData) GetId 

func (x *StreamConnectionData) GetId() string

func (*StreamConnectionData) GetMetadata 

func (x *StreamConnectionData) GetMetadata() map[string]string

func (*StreamConnectionData) ProtoMessage 

func (*StreamConnectionData) ProtoMessage()

func (*StreamConnectionData) ProtoReflect 

func (x *StreamConnectionData) ProtoReflect() protoreflect.Message

func (*StreamConnectionData) Reset 

func (x *StreamConnectionData) Reset()

func (*StreamConnectionData) String 

func (x *StreamConnectionData) String() string

type StreamConnectionStatus 

type StreamConnectionStatus struct {
	Id      string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Status  bool   `protobuf:"varint,2,opt,name=status,proto3" json:"status,omitempty"`
	Message string `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamConnectionStatus) Descriptor deprecated 

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

Deprecated: Use StreamConnectionStatus.ProtoReflect.Descriptor instead.

func (*StreamConnectionStatus) GetId 

func (x *StreamConnectionStatus) GetId() string

func (*StreamConnectionStatus) GetMessage 

func (x *StreamConnectionStatus) GetMessage() string

func (*StreamConnectionStatus) GetStatus 

func (x *StreamConnectionStatus) GetStatus() bool

func (*StreamConnectionStatus) ProtoMessage 

func (*StreamConnectionStatus) ProtoMessage()

func (*StreamConnectionStatus) ProtoReflect 

func (x *StreamConnectionStatus) ProtoReflect() protoreflect.Message

func (*StreamConnectionStatus) Reset 

func (x *StreamConnectionStatus) Reset()

func (*StreamConnectionStatus) String 

func (x *StreamConnectionStatus) 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.