proto

package
v0.0.0-...-cb3197c Latest Latest
Warning

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

 Go to latest Published: Jul 28, 2024 License: MPL-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	Status_name = map[int32]string{
		0: "OK",
		1: "ERROR",
	}
	Status_value = map[string]int32{
		"OK":    0,
		"ERROR": 1,
	}
)

Enum value maps for Status.

View Source 
var (
	PeerConnErrorTypes_name = map[int32]string{
		0: "CONNECTION_CLOSED",
		1: "UNKNOWN_ERROR",
		2: "INVALID_RELAY_PEER_CONFIG_ID",
		3: "INVALID_TARGET_PEERID",
		4: "PEER_NOT_FOUND",
		5: "CONNECTION_NOT_OPEN",
		6: "NETWORK_ERROR",
	}
	PeerConnErrorTypes_value = map[string]int32{
		"CONNECTION_CLOSED":            0,
		"UNKNOWN_ERROR":                1,
		"INVALID_RELAY_PEER_CONFIG_ID": 2,
		"INVALID_TARGET_PEERID":        3,
		"PEER_NOT_FOUND":               4,
		"CONNECTION_NOT_OPEN":          5,
		"NETWORK_ERROR":                6,
	}
)

Enum value maps for PeerConnErrorTypes.

View Source 
var (
	RelayErrorTypes_name = map[int32]string{
		0: "UNKNOWN",
		1: "INVALID_CONFIG",
		2: "SERVER_NOT_FOUND",
		3: "INVALID_PEERID",
		4: "RELAY_DESTROYED",
	}
	RelayErrorTypes_value = map[string]int32{
		"UNKNOWN":          0,
		"INVALID_CONFIG":   1,
		"SERVER_NOT_FOUND": 2,
		"INVALID_PEERID":   3,
		"RELAY_DESTROYED":  4,
	}
)

Enum value maps for RelayErrorTypes.

View Source 
var File_webrtc_relay_proto protoreflect.FileDescriptor
View Source 
var WebRTCRelay_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "webrtcrelay.WebRTCRelay",
	HandlerType: (*WebRTCRelayServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ConnectToPeer",
			Handler:    _WebRTCRelay_ConnectToPeer_Handler,
		},
		{
			MethodName: "DisconnectFromPeer",
			Handler:    _WebRTCRelay_DisconnectFromPeer_Handler,
		},
		{
			MethodName: "CallPeer",
			Handler:    _WebRTCRelay_CallPeer_Handler,
		},
		{
			MethodName: "HangupPeer",
			Handler:    _WebRTCRelay_HangupPeer_Handler,
		},
		{
			MethodName: "AddRelayPeer",
			Handler:    _WebRTCRelay_AddRelayPeer_Handler,
		},
		{
			MethodName: "CloseRelayPeer",
			Handler:    _WebRTCRelay_CloseRelayPeer_Handler,
		},
		{
			MethodName: "GetRelayPeerConfig",
			Handler:    _WebRTCRelay_GetRelayPeerConfig_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "GetEventStream",
			Handler:       _WebRTCRelay_GetEventStream_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "SendMsgStream",
			Handler:       _WebRTCRelay_SendMsgStream_Handler,
			ClientStreams: true,
		},
	},
	Metadata: "webrtc-relay.proto",
}

WebRTCRelay_ServiceDesc is the grpc.ServiceDesc for WebRTCRelay service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterWebRTCRelayServer 

func RegisterWebRTCRelayServer(s grpc.ServiceRegistrar, srv WebRTCRelayServer)

Types

type AddRelayRequest 

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

func (*AddRelayRequest) Descriptor deprecated 

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

Deprecated: Use AddRelayRequest.ProtoReflect.Descriptor instead.

func (*AddRelayRequest) ProtoMessage 

func (*AddRelayRequest) ProtoMessage()

func (*AddRelayRequest) ProtoReflect 

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

func (*AddRelayRequest) Reset 

func (x *AddRelayRequest) Reset()

func (*AddRelayRequest) String 

func (x *AddRelayRequest) String() string

type CallRequest 

type CallRequest struct {
	TargetPeerIds   []string     `protobuf:"bytes,1,rep,name=targetPeerIds,proto3" json:"targetPeerIds,omitempty"`
	StreamName      string       `protobuf:"bytes,2,opt,name=streamName,proto3" json:"streamName,omitempty"`
	RelayPeerNumber *uint32      `protobuf:"varint,3,opt,name=relayPeerNumber,proto3,oneof" json:"relayPeerNumber,omitempty"`
	ExchangeId      *uint32      `protobuf:"varint,4,opt,name=exchangeId,proto3,oneof" json:"exchangeId,omitempty"`
	Tracks          []*TrackInfo `protobuf:"bytes,5,rep,name=tracks,proto3" json:"tracks,omitempty"`
	// contains filtered or unexported fields
}

func (*CallRequest) Descriptor deprecated 

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

Deprecated: Use CallRequest.ProtoReflect.Descriptor instead.

func (*CallRequest) GetExchangeId 

func (x *CallRequest) GetExchangeId() uint32

func (*CallRequest) GetRelayPeerNumber 

func (x *CallRequest) GetRelayPeerNumber() uint32

func (*CallRequest) GetStreamName 

func (x *CallRequest) GetStreamName() string

func (*CallRequest) GetTargetPeerIds 

func (x *CallRequest) GetTargetPeerIds() []string

func (*CallRequest) GetTracks 

func (x *CallRequest) GetTracks() []*TrackInfo

func (*CallRequest) ProtoMessage 

func (*CallRequest) ProtoMessage()

func (*CallRequest) ProtoReflect 

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

func (*CallRequest) Reset 

func (x *CallRequest) Reset()

func (*CallRequest) String 

func (x *CallRequest) String() string

type CallResponse 

type CallResponse struct {
	Status Status `protobuf:"varint,1,opt,name=status,proto3,enum=webrtcrelay.Status" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*CallResponse) Descriptor deprecated 

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

Deprecated: Use CallResponse.ProtoReflect.Descriptor instead.

func (*CallResponse) GetStatus 

func (x *CallResponse) GetStatus() Status

func (*CallResponse) ProtoMessage 

func (*CallResponse) ProtoMessage()

func (*CallResponse) ProtoReflect 

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

func (*CallResponse) Reset 

func (x *CallResponse) Reset()

func (*CallResponse) String 

func (x *CallResponse) String() string

type ConnectionRequest 

type ConnectionRequest struct {
	PeerId          string  `protobuf:"bytes,1,opt,name=peerId,proto3" json:"peerId,omitempty"`
	RelayPeerNumber *uint32 `protobuf:"varint,2,opt,name=relayPeerNumber,proto3,oneof" json:"relayPeerNumber,omitempty"`
	ExchangeId      *uint32 `protobuf:"varint,4,opt,name=exchangeId,proto3,oneof" json:"exchangeId,omitempty"`
	// contains filtered or unexported fields
}

func (*ConnectionRequest) Descriptor deprecated 

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

Deprecated: Use ConnectionRequest.ProtoReflect.Descriptor instead.

func (*ConnectionRequest) GetExchangeId 

func (x *ConnectionRequest) GetExchangeId() uint32

func (*ConnectionRequest) GetPeerId 

func (x *ConnectionRequest) GetPeerId() string

func (*ConnectionRequest) GetRelayPeerNumber 

func (x *ConnectionRequest) GetRelayPeerNumber() uint32

func (*ConnectionRequest) ProtoMessage 

func (*ConnectionRequest) ProtoMessage()

func (*ConnectionRequest) ProtoReflect 

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

func (*ConnectionRequest) Reset 

func (x *ConnectionRequest) Reset()

func (*ConnectionRequest) String 

func (x *ConnectionRequest) String() string

type ConnectionResponse 

type ConnectionResponse struct {
	Status Status `protobuf:"varint,1,opt,name=status,proto3,enum=webrtcrelay.Status" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*ConnectionResponse) Descriptor deprecated 

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

Deprecated: Use ConnectionResponse.ProtoReflect.Descriptor instead.

func (*ConnectionResponse) GetStatus 

func (x *ConnectionResponse) GetStatus() Status

func (*ConnectionResponse) ProtoMessage 

func (*ConnectionResponse) ProtoMessage()

func (*ConnectionResponse) ProtoReflect 

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

func (*ConnectionResponse) Reset 

func (x *ConnectionResponse) Reset()

func (*ConnectionResponse) String 

func (x *ConnectionResponse) String() string

type EventStreamRequest 

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

EventStreamRequest should be sent empty (no fields used)

func (*EventStreamRequest) Descriptor deprecated 

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

Deprecated: Use EventStreamRequest.ProtoReflect.Descriptor instead.

func (*EventStreamRequest) ProtoMessage 

func (*EventStreamRequest) ProtoMessage()

func (*EventStreamRequest) ProtoReflect 

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

func (*EventStreamRequest) Reset 

func (x *EventStreamRequest) Reset()

func (*EventStreamRequest) String 

func (x *EventStreamRequest) String() string

type HangupRequest 

type HangupRequest struct {
	PeerId          string  `protobuf:"bytes,2,opt,name=peerId,proto3" json:"peerId,omitempty"`
	RelayPeerNumber *uint32 `protobuf:"varint,1,opt,name=relayPeerNumber,proto3,oneof" json:"relayPeerNumber,omitempty"`
	ExchangeId      *uint32 `protobuf:"varint,4,opt,name=exchangeId,proto3,oneof" json:"exchangeId,omitempty"`
	// contains filtered or unexported fields
}

func (*HangupRequest) Descriptor deprecated 

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

Deprecated: Use HangupRequest.ProtoReflect.Descriptor instead.

func (*HangupRequest) GetExchangeId 

func (x *HangupRequest) GetExchangeId() uint32

func (*HangupRequest) GetPeerId 

func (x *HangupRequest) GetPeerId() string

func (*HangupRequest) GetRelayPeerNumber 

func (x *HangupRequest) GetRelayPeerNumber() uint32

func (*HangupRequest) ProtoMessage 

func (*HangupRequest) ProtoMessage()

func (*HangupRequest) ProtoReflect 

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

func (*HangupRequest) Reset 

func (x *HangupRequest) Reset()

func (*HangupRequest) String 

func (x *HangupRequest) String() string

type HangupResponse 

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

func (*HangupResponse) Descriptor deprecated 

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

Deprecated: Use HangupResponse.ProtoReflect.Descriptor instead.

func (*HangupResponse) GetPeerId 

func (x *HangupResponse) GetPeerId() string

func (*HangupResponse) ProtoMessage 

func (*HangupResponse) ProtoMessage()

func (*HangupResponse) ProtoReflect 

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

func (*HangupResponse) Reset 

func (x *HangupResponse) Reset()

func (*HangupResponse) String 

func (x *HangupResponse) String() string

type MsgRecivedEvent 

type MsgRecivedEvent struct {
	SrcPeerId       string `protobuf:"bytes,1,opt,name=srcPeerId,proto3" json:"srcPeerId,omitempty"`
	RelayPeerNumber uint32 `protobuf:"varint,2,opt,name=relayPeerNumber,proto3" json:"relayPeerNumber,omitempty"`
	Payload         []byte `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

RelayEventStream event that is sent when a message is received from any peer connected to any relayPeer on this webrtc-relay

func (*MsgRecivedEvent) Descriptor deprecated 

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

Deprecated: Use MsgRecivedEvent.ProtoReflect.Descriptor instead.

func (*MsgRecivedEvent) GetPayload 

func (x *MsgRecivedEvent) GetPayload() []byte

func (*MsgRecivedEvent) GetRelayPeerNumber 

func (x *MsgRecivedEvent) GetRelayPeerNumber() uint32

func (*MsgRecivedEvent) GetSrcPeerId 

func (x *MsgRecivedEvent) GetSrcPeerId() string

func (*MsgRecivedEvent) ProtoMessage 

func (*MsgRecivedEvent) ProtoMessage()

func (*MsgRecivedEvent) ProtoReflect 

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

func (*MsgRecivedEvent) Reset 

func (x *MsgRecivedEvent) Reset()

func (*MsgRecivedEvent) String 

func (x *MsgRecivedEvent) String() string

type PeerCalledEvent 

type PeerCalledEvent struct {
	RelayPeerNumber uint32       `protobuf:"varint,1,opt,name=relayPeerNumber,proto3" json:"relayPeerNumber,omitempty"`
	SrcPeerId       string       `protobuf:"bytes,2,opt,name=srcPeerId,proto3" json:"srcPeerId,omitempty"`
	StreamName      string       `protobuf:"bytes,3,opt,name=streamName,proto3" json:"streamName,omitempty"`
	Tracks          []*TrackInfo `protobuf:"bytes,4,rep,name=tracks,proto3" json:"tracks,omitempty"` // more fields tbd
	// contains filtered or unexported fields
}

RelayEventStream event that is sent when a peer opens a media call with any relayPeer on this webrtc-relay

func (*PeerCalledEvent) Descriptor deprecated 

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

Deprecated: Use PeerCalledEvent.ProtoReflect.Descriptor instead.

func (*PeerCalledEvent) GetRelayPeerNumber 

func (x *PeerCalledEvent) GetRelayPeerNumber() uint32

func (*PeerCalledEvent) GetSrcPeerId 

func (x *PeerCalledEvent) GetSrcPeerId() string

func (*PeerCalledEvent) GetStreamName 

func (x *PeerCalledEvent) GetStreamName() string

func (*PeerCalledEvent) GetTracks 

func (x *PeerCalledEvent) GetTracks() []*TrackInfo

func (*PeerCalledEvent) ProtoMessage 

func (*PeerCalledEvent) ProtoMessage()

func (*PeerCalledEvent) ProtoReflect 

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

func (*PeerCalledEvent) Reset 

func (x *PeerCalledEvent) Reset()

func (*PeerCalledEvent) String 

func (x *PeerCalledEvent) String() string

type PeerConnErrorTypes 

type PeerConnErrorTypes int32
const (
	PeerConnErrorTypes_CONNECTION_CLOSED            PeerConnErrorTypes = 0
	PeerConnErrorTypes_UNKNOWN_ERROR                PeerConnErrorTypes = 1
	PeerConnErrorTypes_INVALID_RELAY_PEER_CONFIG_ID PeerConnErrorTypes = 2
	PeerConnErrorTypes_INVALID_TARGET_PEERID        PeerConnErrorTypes = 3
	PeerConnErrorTypes_PEER_NOT_FOUND               PeerConnErrorTypes = 4
	PeerConnErrorTypes_CONNECTION_NOT_OPEN          PeerConnErrorTypes = 5
	PeerConnErrorTypes_NETWORK_ERROR                PeerConnErrorTypes = 6
)

func (PeerConnErrorTypes) Descriptor 

func (PeerConnErrorTypes) Descriptor() protoreflect.EnumDescriptor

func (PeerConnErrorTypes) Enum 

func (x PeerConnErrorTypes) Enum() *PeerConnErrorTypes

func (PeerConnErrorTypes) EnumDescriptor deprecated 

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

Deprecated: Use PeerConnErrorTypes.Descriptor instead.

func (PeerConnErrorTypes) Number 

func (x PeerConnErrorTypes) Number() protoreflect.EnumNumber

func (PeerConnErrorTypes) String 

func (x PeerConnErrorTypes) String() string

func (PeerConnErrorTypes) Type 

func (PeerConnErrorTypes) Type() protoreflect.EnumType

type PeerConnectedEvent 

type PeerConnectedEvent struct {
	RelayPeerNumber uint32 `protobuf:"varint,1,opt,name=relayPeerNumber,proto3" json:"relayPeerNumber,omitempty"`
	SrcPeerId       string `protobuf:"bytes,2,opt,name=srcPeerId,proto3" json:"srcPeerId,omitempty"`
	// contains filtered or unexported fields
}

RelayEventStream event that is sent when a peer connects to (or is succesfully connected to by) any relayPeer on this webrtc-relay

func (*PeerConnectedEvent) Descriptor deprecated 

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

Deprecated: Use PeerConnectedEvent.ProtoReflect.Descriptor instead.

func (*PeerConnectedEvent) GetRelayPeerNumber 

func (x *PeerConnectedEvent) GetRelayPeerNumber() uint32

func (*PeerConnectedEvent) GetSrcPeerId 

func (x *PeerConnectedEvent) GetSrcPeerId() string

func (*PeerConnectedEvent) ProtoMessage 

func (*PeerConnectedEvent) ProtoMessage()

func (*PeerConnectedEvent) ProtoReflect 

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

func (*PeerConnectedEvent) Reset 

func (x *PeerConnectedEvent) Reset()

func (*PeerConnectedEvent) String 

func (x *PeerConnectedEvent) String() string

type PeerDataConnErrorEvent 

type PeerDataConnErrorEvent struct {
	RelayPeerNumber uint32             `protobuf:"varint,1,opt,name=relayPeerNumber,proto3" json:"relayPeerNumber,omitempty"`
	SrcPeerId       string             `protobuf:"bytes,2,opt,name=srcPeerId,proto3" json:"srcPeerId,omitempty"`
	Type            PeerConnErrorTypes `protobuf:"varint,3,opt,name=type,proto3,enum=webrtcrelay.PeerConnErrorTypes" json:"type,omitempty"`
	Msg             string             `protobuf:"bytes,4,opt,name=msg,proto3" json:"msg,omitempty"`
	// contains filtered or unexported fields
}

RelayEventStream event that is sent when any data connection to a remote peer encounters an error

func (*PeerDataConnErrorEvent) Descriptor deprecated 

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

Deprecated: Use PeerDataConnErrorEvent.ProtoReflect.Descriptor instead.

func (*PeerDataConnErrorEvent) GetMsg 

func (x *PeerDataConnErrorEvent) GetMsg() string

func (*PeerDataConnErrorEvent) GetRelayPeerNumber 

func (x *PeerDataConnErrorEvent) GetRelayPeerNumber() uint32

func (*PeerDataConnErrorEvent) GetSrcPeerId 

func (x *PeerDataConnErrorEvent) GetSrcPeerId() string

func (*PeerDataConnErrorEvent) GetType 

func (x *PeerDataConnErrorEvent) GetType() PeerConnErrorTypes

func (*PeerDataConnErrorEvent) ProtoMessage 

func (*PeerDataConnErrorEvent) ProtoMessage()

func (*PeerDataConnErrorEvent) ProtoReflect 

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

func (*PeerDataConnErrorEvent) Reset 

func (x *PeerDataConnErrorEvent) Reset()

func (*PeerDataConnErrorEvent) String 

func (x *PeerDataConnErrorEvent) String() string

type PeerDisconnectedEvent 

type PeerDisconnectedEvent struct {
	RelayPeerNumber uint32 `protobuf:"varint,1,opt,name=relayPeerNumber,proto3" json:"relayPeerNumber,omitempty"`
	SrcPeerId       string `protobuf:"bytes,2,opt,name=srcPeerId,proto3" json:"srcPeerId,omitempty"`
	// contains filtered or unexported fields
}

RelayEventStream event that is sent when a peer disconnects from any relayPeer on this webrtc-relay

func (*PeerDisconnectedEvent) Descriptor deprecated 

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

Deprecated: Use PeerDisconnectedEvent.ProtoReflect.Descriptor instead.

func (*PeerDisconnectedEvent) GetRelayPeerNumber 

func (x *PeerDisconnectedEvent) GetRelayPeerNumber() uint32

func (*PeerDisconnectedEvent) GetSrcPeerId 

func (x *PeerDisconnectedEvent) GetSrcPeerId() string

func (*PeerDisconnectedEvent) ProtoMessage 

func (*PeerDisconnectedEvent) ProtoMessage()

func (*PeerDisconnectedEvent) ProtoReflect 

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

func (*PeerDisconnectedEvent) Reset 

func (x *PeerDisconnectedEvent) Reset()

func (*PeerDisconnectedEvent) String 

func (x *PeerDisconnectedEvent) String() string

type PeerHungupEvent 

type PeerHungupEvent struct {
	RelayPeerNumber uint32 `protobuf:"varint,1,opt,name=relayPeerNumber,proto3" json:"relayPeerNumber,omitempty"`
	SrcPeerId       string `protobuf:"bytes,2,opt,name=srcPeerId,proto3" json:"srcPeerId,omitempty"`
	// contains filtered or unexported fields
}

RelayEventStream event that is sent when a peer hangs up an open media call with any relayPeer on this webrtc-relay

func (*PeerHungupEvent) Descriptor deprecated 

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

Deprecated: Use PeerHungupEvent.ProtoReflect.Descriptor instead.

func (*PeerHungupEvent) GetRelayPeerNumber 

func (x *PeerHungupEvent) GetRelayPeerNumber() uint32

func (*PeerHungupEvent) GetSrcPeerId 

func (x *PeerHungupEvent) GetSrcPeerId() string

func (*PeerHungupEvent) ProtoMessage 

func (*PeerHungupEvent) ProtoMessage()

func (*PeerHungupEvent) ProtoReflect 

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

func (*PeerHungupEvent) Reset 

func (x *PeerHungupEvent) Reset()

func (*PeerHungupEvent) String 

func (x *PeerHungupEvent) String() string

type PeerMediaConnErrorEvent 

type PeerMediaConnErrorEvent struct {
	RelayPeerNumber uint32             `protobuf:"varint,1,opt,name=relayPeerNumber,proto3" json:"relayPeerNumber,omitempty"`
	SrcPeerId       string             `protobuf:"bytes,2,opt,name=srcPeerId,proto3" json:"srcPeerId,omitempty"`
	Type            PeerConnErrorTypes `protobuf:"varint,3,opt,name=type,proto3,enum=webrtcrelay.PeerConnErrorTypes" json:"type,omitempty"`
	Msg             string             `protobuf:"bytes,4,opt,name=msg,proto3" json:"msg,omitempty"`
	// contains filtered or unexported fields
}

RelayEventStream event that is sent when any media connection to a remote peer encounters an error

func (*PeerMediaConnErrorEvent) Descriptor deprecated 

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

Deprecated: Use PeerMediaConnErrorEvent.ProtoReflect.Descriptor instead.

func (*PeerMediaConnErrorEvent) GetMsg 

func (x *PeerMediaConnErrorEvent) GetMsg() string

func (*PeerMediaConnErrorEvent) GetRelayPeerNumber 

func (x *PeerMediaConnErrorEvent) GetRelayPeerNumber() uint32

func (*PeerMediaConnErrorEvent) GetSrcPeerId 

func (x *PeerMediaConnErrorEvent) GetSrcPeerId() string

func (*PeerMediaConnErrorEvent) GetType 

func (x *PeerMediaConnErrorEvent) GetType() PeerConnErrorTypes

func (*PeerMediaConnErrorEvent) ProtoMessage 

func (*PeerMediaConnErrorEvent) ProtoMessage()

func (*PeerMediaConnErrorEvent) ProtoReflect 

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

func (*PeerMediaConnErrorEvent) Reset 

func (x *PeerMediaConnErrorEvent) Reset()

func (*PeerMediaConnErrorEvent) String 

func (x *PeerMediaConnErrorEvent) String() string

type RTCPFeedback 

type RTCPFeedback struct {

	// Type is the type of feedback.
	// see: https://draft.ortc.org/#dom-rtcrtcpfeedback
	// valid: ack, ccm, nack, goog-remb, transport-cc
	Type string `protobuf:"bytes,1,opt,name=Type,proto3" json:"Type,omitempty"`
	// The parameter value depends on the type.
	// For example, type="nack" parameter="pli" will send Picture Loss Indicator packets.
	Parameter string `protobuf:"bytes,2,opt,name=Parameter,proto3" json:"Parameter,omitempty"`
	// contains filtered or unexported fields
}

func (*RTCPFeedback) Descriptor deprecated 

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

Deprecated: Use RTCPFeedback.ProtoReflect.Descriptor instead.

func (*RTCPFeedback) GetParameter 

func (x *RTCPFeedback) GetParameter() string

func (*RTCPFeedback) GetType 

func (x *RTCPFeedback) GetType() string

func (*RTCPFeedback) ProtoMessage 

func (*RTCPFeedback) ProtoMessage()

func (*RTCPFeedback) ProtoReflect 

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

func (*RTCPFeedback) Reset 

func (x *RTCPFeedback) Reset()

func (*RTCPFeedback) String 

func (x *RTCPFeedback) String() string

type RTPCodecParams 

type RTPCodecParams struct {
	MimeType     string          `protobuf:"bytes,1,opt,name=MimeType,proto3" json:"MimeType,omitempty"`
	ClockRate    *uint32         `protobuf:"varint,2,opt,name=ClockRate,proto3,oneof" json:"ClockRate,omitempty"`
	Channels     *uint32         `protobuf:"varint,3,opt,name=Channels,proto3,oneof" json:"Channels,omitempty"`
	SDPFmtpLine  *string         `protobuf:"bytes,4,opt,name=SDPFmtpLine,proto3,oneof" json:"SDPFmtpLine,omitempty"`
	RTCPFeedback []*RTCPFeedback `protobuf:"bytes,5,rep,name=RTCPFeedback,proto3" json:"RTCPFeedback,omitempty"`
	PayloadType  *uint32         `protobuf:"varint,6,opt,name=PayloadType,proto3,oneof" json:"PayloadType,omitempty"` //PayloadType identifies the format of the RTP payload and determines its interpretation by the application. Each codec in a RTP Session will have a different PayloadType See: https://tools.ietf.org/html/rfc3550#section-3
	// contains filtered or unexported fields
}

RTPCodecParameters is a sequence containing the media codecs that an RtpSender will choose from, as well as entries for RTX, RED and FEC mechanisms. This also includes the PayloadType that has been negotiated https://w3c.github.io/webrtc-pc/#rtcrtpcodecparameters RTPCodecCapability provides information about codec capabilities. https://w3c.github.io/webrtc-pc/#dictionary-rtcrtpcodeccapability-members

func (*RTPCodecParams) Descriptor deprecated 

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

Deprecated: Use RTPCodecParams.ProtoReflect.Descriptor instead.

func (*RTPCodecParams) GetChannels 

func (x *RTPCodecParams) GetChannels() uint32

func (*RTPCodecParams) GetClockRate 

func (x *RTPCodecParams) GetClockRate() uint32

func (*RTPCodecParams) GetMimeType 

func (x *RTPCodecParams) GetMimeType() string

func (*RTPCodecParams) GetPayloadType 

func (x *RTPCodecParams) GetPayloadType() uint32

func (*RTPCodecParams) GetRTCPFeedback 

func (x *RTPCodecParams) GetRTCPFeedback() []*RTCPFeedback

func (*RTPCodecParams) GetSDPFmtpLine 

func (x *RTPCodecParams) GetSDPFmtpLine() string

func (*RTPCodecParams) ProtoMessage 

func (*RTPCodecParams) ProtoMessage()

func (*RTPCodecParams) ProtoReflect 

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

func (*RTPCodecParams) Reset 

func (x *RTPCodecParams) Reset()

func (*RTPCodecParams) String 

func (x *RTPCodecParams) String() string

type RelayConfig 

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

func (*RelayConfig) Descriptor deprecated 

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

Deprecated: Use RelayConfig.ProtoReflect.Descriptor instead.

func (*RelayConfig) ProtoMessage 

func (*RelayConfig) ProtoMessage()

func (*RelayConfig) ProtoReflect 

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

func (*RelayConfig) Reset 

func (x *RelayConfig) Reset()

func (*RelayConfig) String 

func (x *RelayConfig) String() string

type RelayConnectedEvent 

type RelayConnectedEvent struct {
	RelayPeerNumber uint32 `protobuf:"varint,1,opt,name=relayPeerNumber,proto3" json:"relayPeerNumber,omitempty"`
	// contains filtered or unexported fields
}

RelayEventStream event that is sent when any relayPeer on this webrtc-relay successfully (re)connects to the peerjs server it is setup to connect to

func (*RelayConnectedEvent) Descriptor deprecated 

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

Deprecated: Use RelayConnectedEvent.ProtoReflect.Descriptor instead.

func (*RelayConnectedEvent) GetRelayPeerNumber 

func (x *RelayConnectedEvent) GetRelayPeerNumber() uint32

func (*RelayConnectedEvent) ProtoMessage 

func (*RelayConnectedEvent) ProtoMessage()

func (*RelayConnectedEvent) ProtoReflect 

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

func (*RelayConnectedEvent) Reset 

func (x *RelayConnectedEvent) Reset()

func (*RelayConnectedEvent) String 

func (x *RelayConnectedEvent) String() string

type RelayDisconnectedEvent 

type RelayDisconnectedEvent struct {
	RelayPeerNumber uint32 `protobuf:"varint,1,opt,name=relayPeerNumber,proto3" json:"relayPeerNumber,omitempty"`
	// contains filtered or unexported fields
}

RelayEventStream event that is sent when any relayPeer on this webrtc-relay disconnects from the peerjs server it is setup to connect to

func (*RelayDisconnectedEvent) Descriptor deprecated 

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

Deprecated: Use RelayDisconnectedEvent.ProtoReflect.Descriptor instead.

func (*RelayDisconnectedEvent) GetRelayPeerNumber 

func (x *RelayDisconnectedEvent) GetRelayPeerNumber() uint32

func (*RelayDisconnectedEvent) ProtoMessage 

func (*RelayDisconnectedEvent) ProtoMessage()

func (*RelayDisconnectedEvent) ProtoReflect 

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

func (*RelayDisconnectedEvent) Reset 

func (x *RelayDisconnectedEvent) Reset()

func (*RelayDisconnectedEvent) String 

func (x *RelayDisconnectedEvent) String() string

type RelayErrorEvent 

type RelayErrorEvent struct {
	RelayPeerNumber uint32          `protobuf:"varint,1,opt,name=relayPeerNumber,proto3" json:"relayPeerNumber,omitempty"`
	Type            RelayErrorTypes `protobuf:"varint,2,opt,name=type,proto3,enum=webrtcrelay.RelayErrorTypes" json:"type,omitempty"`
	Msg             string          `protobuf:"bytes,3,opt,name=msg,proto3" json:"msg,omitempty"`
	// contains filtered or unexported fields
}

RelayEventStream event that is sent when a relayPeer encounters an error

func (*RelayErrorEvent) Descriptor deprecated 

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

Deprecated: Use RelayErrorEvent.ProtoReflect.Descriptor instead.

func (*RelayErrorEvent) GetMsg 

func (x *RelayErrorEvent) GetMsg() string

func (*RelayErrorEvent) GetRelayPeerNumber 

func (x *RelayErrorEvent) GetRelayPeerNumber() uint32

func (*RelayErrorEvent) GetType 

func (x *RelayErrorEvent) GetType() RelayErrorTypes

func (*RelayErrorEvent) ProtoMessage 

func (*RelayErrorEvent) ProtoMessage()

func (*RelayErrorEvent) ProtoReflect 

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

func (*RelayErrorEvent) Reset 

func (x *RelayErrorEvent) Reset()

func (*RelayErrorEvent) String 

func (x *RelayErrorEvent) String() string

type RelayErrorTypes 

type RelayErrorTypes int32
const (
	RelayErrorTypes_UNKNOWN          RelayErrorTypes = 0
	RelayErrorTypes_INVALID_CONFIG   RelayErrorTypes = 1
	RelayErrorTypes_SERVER_NOT_FOUND RelayErrorTypes = 2
	RelayErrorTypes_INVALID_PEERID   RelayErrorTypes = 3
	RelayErrorTypes_RELAY_DESTROYED  RelayErrorTypes = 4
)

func (RelayErrorTypes) Descriptor 

func (RelayErrorTypes) Descriptor() protoreflect.EnumDescriptor

func (RelayErrorTypes) Enum 

func (x RelayErrorTypes) Enum() *RelayErrorTypes

func (RelayErrorTypes) EnumDescriptor deprecated 

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

Deprecated: Use RelayErrorTypes.Descriptor instead.

func (RelayErrorTypes) Number 

func (x RelayErrorTypes) Number() protoreflect.EnumNumber

func (RelayErrorTypes) String 

func (x RelayErrorTypes) String() string

func (RelayErrorTypes) Type 

func (RelayErrorTypes) Type() protoreflect.EnumType

type RelayEventStream 

type RelayEventStream struct {
	ExchangeId *uint32 `protobuf:"varint,1,opt,name=exchangeId,proto3,oneof" json:"exchangeId,omitempty"`
	// Types that are assignable to Event:
	//
	//	*RelayEventStream_MsgRecived
	//	*RelayEventStream_RelayConnected
	//	*RelayEventStream_RelayDisconnected
	//	*RelayEventStream_RelayError
	//	*RelayEventStream_PeerConnected
	//	*RelayEventStream_PeerDisconnected
	//	*RelayEventStream_PeerCalled
	//	*RelayEventStream_PeerHungup
	//	*RelayEventStream_PeerDataConnError
	//	*RelayEventStream_PeerMediaConnError
	Event isRelayEventStream_Event `protobuf_oneof:"event"`
	// contains filtered or unexported fields
}

func (*RelayEventStream) Descriptor deprecated 

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

Deprecated: Use RelayEventStream.ProtoReflect.Descriptor instead.

func (*RelayEventStream) GetEvent 

func (m *RelayEventStream) GetEvent() isRelayEventStream_Event

func (*RelayEventStream) GetExchangeId 

func (x *RelayEventStream) GetExchangeId() uint32

func (*RelayEventStream) GetMsgRecived 

func (x *RelayEventStream) GetMsgRecived() *MsgRecivedEvent

func (*RelayEventStream) GetPeerCalled 

func (x *RelayEventStream) GetPeerCalled() *PeerCalledEvent

func (*RelayEventStream) GetPeerConnected 

func (x *RelayEventStream) GetPeerConnected() *PeerConnectedEvent

func (*RelayEventStream) GetPeerDataConnError 

func (x *RelayEventStream) GetPeerDataConnError() *PeerDataConnErrorEvent

func (*RelayEventStream) GetPeerDisconnected 

func (x *RelayEventStream) GetPeerDisconnected() *PeerDisconnectedEvent

func (*RelayEventStream) GetPeerHungup 

func (x *RelayEventStream) GetPeerHungup() *PeerHungupEvent

func (*RelayEventStream) GetPeerMediaConnError 

func (x *RelayEventStream) GetPeerMediaConnError() *PeerMediaConnErrorEvent

func (*RelayEventStream) GetRelayConnected 

func (x *RelayEventStream) GetRelayConnected() *RelayConnectedEvent

func (*RelayEventStream) GetRelayDisconnected 

func (x *RelayEventStream) GetRelayDisconnected() *RelayDisconnectedEvent

func (*RelayEventStream) GetRelayError 

func (x *RelayEventStream) GetRelayError() *RelayErrorEvent

func (*RelayEventStream) ProtoMessage 

func (*RelayEventStream) ProtoMessage()

func (*RelayEventStream) ProtoReflect 

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

func (*RelayEventStream) Reset 

func (x *RelayEventStream) Reset()

func (*RelayEventStream) String 

func (x *RelayEventStream) String() string

type RelayEventStream_MsgRecived 

type RelayEventStream_MsgRecived struct {
	MsgRecived *MsgRecivedEvent `protobuf:"bytes,2,opt,name=msgRecived,proto3,oneof"`
}

type RelayEventStream_PeerCalled 

type RelayEventStream_PeerCalled struct {
	PeerCalled *PeerCalledEvent `protobuf:"bytes,10,opt,name=peerCalled,proto3,oneof"`
}

type RelayEventStream_PeerConnected 

type RelayEventStream_PeerConnected struct {
	PeerConnected *PeerConnectedEvent `protobuf:"bytes,8,opt,name=peerConnected,proto3,oneof"`
}

type RelayEventStream_PeerDataConnError 

type RelayEventStream_PeerDataConnError struct {
	PeerDataConnError *PeerDataConnErrorEvent `protobuf:"bytes,12,opt,name=peerDataConnError,proto3,oneof"`
}

type RelayEventStream_PeerDisconnected 

type RelayEventStream_PeerDisconnected struct {
	PeerDisconnected *PeerDisconnectedEvent `protobuf:"bytes,9,opt,name=peerDisconnected,proto3,oneof"`
}

type RelayEventStream_PeerHungup 

type RelayEventStream_PeerHungup struct {
	PeerHungup *PeerHungupEvent `protobuf:"bytes,11,opt,name=peerHungup,proto3,oneof"`
}

type RelayEventStream_PeerMediaConnError 

type RelayEventStream_PeerMediaConnError struct {
	PeerMediaConnError *PeerMediaConnErrorEvent `protobuf:"bytes,13,opt,name=peerMediaConnError,proto3,oneof"`
}

type RelayEventStream_RelayConnected 

type RelayEventStream_RelayConnected struct {
	RelayConnected *RelayConnectedEvent `protobuf:"bytes,3,opt,name=relayConnected,proto3,oneof"`
}

type RelayEventStream_RelayDisconnected 

type RelayEventStream_RelayDisconnected struct {
	RelayDisconnected *RelayDisconnectedEvent `protobuf:"bytes,4,opt,name=relayDisconnected,proto3,oneof"`
}

type RelayEventStream_RelayError 

type RelayEventStream_RelayError struct {
	RelayError *RelayErrorEvent `protobuf:"bytes,5,opt,name=relayError,proto3,oneof"`
}

type RelayPeerNumber 

type RelayPeerNumber struct {
	Number uint32 `protobuf:"varint,1,opt,name=number,proto3" json:"number,omitempty"`
	// contains filtered or unexported fields
}

func (*RelayPeerNumber) Descriptor deprecated 

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

Deprecated: Use RelayPeerNumber.ProtoReflect.Descriptor instead.

func (*RelayPeerNumber) GetNumber 

func (x *RelayPeerNumber) GetNumber() uint32

func (*RelayPeerNumber) ProtoMessage 

func (*RelayPeerNumber) ProtoMessage()

func (*RelayPeerNumber) ProtoReflect 

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

func (*RelayPeerNumber) Reset 

func (x *RelayPeerNumber) Reset()

func (*RelayPeerNumber) String 

func (x *RelayPeerNumber) String() string

type SendMsgRequest 

type SendMsgRequest struct {
	TargetPeerIds   []string `protobuf:"bytes,1,rep,name=targetPeerIds,proto3" json:"targetPeerIds,omitempty"`
	Payload         []byte   `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
	RelayPeerNumber *uint32  `protobuf:"varint,3,opt,name=relayPeerNumber,proto3,oneof" json:"relayPeerNumber,omitempty"`
	ExchangeId      *uint32  `protobuf:"varint,4,opt,name=exchangeId,proto3,oneof" json:"exchangeId,omitempty"`
	// contains filtered or unexported fields
}

func (*SendMsgRequest) Descriptor deprecated 

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

Deprecated: Use SendMsgRequest.ProtoReflect.Descriptor instead.

func (*SendMsgRequest) GetExchangeId 

func (x *SendMsgRequest) GetExchangeId() uint32

func (*SendMsgRequest) GetPayload 

func (x *SendMsgRequest) GetPayload() []byte

func (*SendMsgRequest) GetRelayPeerNumber 

func (x *SendMsgRequest) GetRelayPeerNumber() uint32

func (*SendMsgRequest) GetTargetPeerIds 

func (x *SendMsgRequest) GetTargetPeerIds() []string

func (*SendMsgRequest) ProtoMessage 

func (*SendMsgRequest) ProtoMessage()

func (*SendMsgRequest) ProtoReflect 

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

func (*SendMsgRequest) Reset 

func (x *SendMsgRequest) Reset()

func (*SendMsgRequest) String 

func (x *SendMsgRequest) String() string

type SendMsgResponse 

type SendMsgResponse struct {
	Status Status `protobuf:"varint,1,opt,name=status,proto3,enum=webrtcrelay.Status" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*SendMsgResponse) Descriptor deprecated 

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

Deprecated: Use SendMsgResponse.ProtoReflect.Descriptor instead.

func (*SendMsgResponse) GetStatus 

func (x *SendMsgResponse) GetStatus() Status

func (*SendMsgResponse) ProtoMessage 

func (*SendMsgResponse) ProtoMessage()

func (*SendMsgResponse) ProtoReflect 

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

func (*SendMsgResponse) Reset 

func (x *SendMsgResponse) Reset()

func (*SendMsgResponse) String 

func (x *SendMsgResponse) String() string

type Status 

type Status int32
const (
	Status_OK    Status = 0
	Status_ERROR Status = 1
)

func (Status) Descriptor 

func (Status) Descriptor() protoreflect.EnumDescriptor

func (Status) Enum 

func (x Status) Enum() *Status

func (Status) EnumDescriptor deprecated 

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

Deprecated: Use Status.Descriptor instead.

func (Status) Number 

func (x Status) Number() protoreflect.EnumNumber

func (Status) String 

func (x Status) String() string

func (Status) Type 

func (Status) Type() protoreflect.EnumType

type TrackInfo 

type TrackInfo struct {
	Name         string          `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // the unique ID of this track within a media stream
	Kind         string          `protobuf:"bytes,2,opt,name=kind,proto3" json:"kind,omitempty"` // audio|video
	Codec        *RTPCodecParams `protobuf:"bytes,3,opt,name=codec,proto3" json:"codec,omitempty"`
	RtpSourceUrl *string         `protobuf:"bytes,4,opt,name=rtpSourceUrl,proto3,oneof" json:"rtpSourceUrl,omitempty"` // only for tracks streamed by/from the backend (for now)
	// contains filtered or unexported fields
}

func (*TrackInfo) Descriptor deprecated 

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

Deprecated: Use TrackInfo.ProtoReflect.Descriptor instead.

func (*TrackInfo) GetCodec 

func (x *TrackInfo) GetCodec() *RTPCodecParams

func (*TrackInfo) GetKind 

func (x *TrackInfo) GetKind() string

func (*TrackInfo) GetName 

func (x *TrackInfo) GetName() string

func (*TrackInfo) GetRtpSourceUrl 

func (x *TrackInfo) GetRtpSourceUrl() string

func (*TrackInfo) ProtoMessage 

func (*TrackInfo) ProtoMessage()

func (*TrackInfo) ProtoReflect 

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

func (*TrackInfo) Reset 

func (x *TrackInfo) Reset()

func (*TrackInfo) String 

func (x *TrackInfo) String() string

type UnimplementedWebRTCRelayServer 

type UnimplementedWebRTCRelayServer struct {
}

UnimplementedWebRTCRelayServer must be embedded to have forward compatible implementations.

func (UnimplementedWebRTCRelayServer) AddRelayPeer 

func (UnimplementedWebRTCRelayServer) AddRelayPeer(context.Context, *AddRelayRequest) (*RelayErrorEvent, error)

func (UnimplementedWebRTCRelayServer) CallPeer 

func (UnimplementedWebRTCRelayServer) CallPeer(context.Context, *CallRequest) (*CallResponse, error)

func (UnimplementedWebRTCRelayServer) CloseRelayPeer 

func (UnimplementedWebRTCRelayServer) CloseRelayPeer(context.Context, *RelayPeerNumber) (*RelayErrorEvent, error)

func (UnimplementedWebRTCRelayServer) ConnectToPeer 

func (UnimplementedWebRTCRelayServer) ConnectToPeer(context.Context, *ConnectionRequest) (*ConnectionResponse, error)

func (UnimplementedWebRTCRelayServer) DisconnectFromPeer 

func (UnimplementedWebRTCRelayServer) DisconnectFromPeer(context.Context, *ConnectionRequest) (*ConnectionResponse, error)

func (UnimplementedWebRTCRelayServer) GetEventStream 

func (UnimplementedWebRTCRelayServer) GetEventStream(*EventStreamRequest, WebRTCRelay_GetEventStreamServer) error

func (UnimplementedWebRTCRelayServer) GetRelayPeerConfig 

func (UnimplementedWebRTCRelayServer) GetRelayPeerConfig(context.Context, *RelayPeerNumber) (*RelayConfig, error)

func (UnimplementedWebRTCRelayServer) HangupPeer 

func (UnimplementedWebRTCRelayServer) HangupPeer(context.Context, *ConnectionRequest) (*CallResponse, error)

func (UnimplementedWebRTCRelayServer) SendMsgStream 

func (UnimplementedWebRTCRelayServer) SendMsgStream(WebRTCRelay_SendMsgStreamServer) error

type UnsafeWebRTCRelayServer 

type UnsafeWebRTCRelayServer interface {
	// contains filtered or unexported methods
}

UnsafeWebRTCRelayServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to WebRTCRelayServer will result in compilation errors.

type WebRTCRelayClient 

type WebRTCRelayClient interface {
	// Get a stream of events from the webrtc-relay including recived messages, peer dis/connection events & errors, relay dis/connection events & errors.
	// Events that happen as a result of an RPC call WILL BE sent on this stream with the exchangeId set to the.
	// see the RelayEventStream type for more details - This is a server-side streaming RPC
	// The grpc client should send an empty EventStreamRequest message to start the stream
	GetEventStream(ctx context.Context, in *EventStreamRequest, opts ...grpc.CallOption) (WebRTCRelay_GetEventStreamClient, error)
	// Tell the webrtc-relay to connect to a peer
	// If errors/events happen later because of DisconnectFromPeer(), they will get sent on the RelayEventStream with the same exchangeId as included in this rpc ConnectionRequest (not returned to this RPC call)
	ConnectToPeer(ctx context.Context, in *ConnectionRequest, opts ...grpc.CallOption) (*ConnectionResponse, error)
	// Tell the webrtc-relay to disconnect from a peer it has an open connection with
	// If errors/events happen later because of DisconnectFromPeer(), they will get sent on the RelayEventStream with the same exchangeId as included in this rpc ConnectionRequest (not returned to this RPC call)
	DisconnectFromPeer(ctx context.Context, in *ConnectionRequest, opts ...grpc.CallOption) (*ConnectionResponse, error)
	// Tell the webrtc-relay to call a peer with a given stream name and media track
	// can be used to initiate a call or to add a media track to an existing call (untested)
	// If errors/events happen later because of CallPeer(), they will get sent on the RelayEventStream with the same exchangeId as included in this rpc CallRequest (not returned to this RPC call)
	CallPeer(ctx context.Context, in *CallRequest, opts ...grpc.CallOption) (*CallResponse, error)
	// Tell the webrtc-relay to stop the media call with a peer (does not cause relay to disconnect any open datachannels with the peer)
	// If errors/events happen later because of HangupPeer(), they will get sent on the RelayEventStream with the same exchangeId as included in this rpc ConnectionRequest (not returned to this RPC call)
	HangupPeer(ctx context.Context, in *ConnectionRequest, opts ...grpc.CallOption) (*CallResponse, error)
	// Opens a stream to the webrtc-relay which can be used to send lots of messages to one or more connected peers.
	// If errors/events happen because of a sending a message, they will get sent on the RelayEventStream with the same exchangeId as included in this rpc SendMsgRequest (not returned to this RPC call)
	SendMsgStream(ctx context.Context, opts ...grpc.CallOption) (WebRTCRelay_SendMsgStreamClient, error)
	// Adds a new Relay Peer to the webrtc-relay instance, and starts it (not yet implemented)
	AddRelayPeer(ctx context.Context, in *AddRelayRequest, opts ...grpc.CallOption) (*RelayErrorEvent, error)
	// Stops a Relay Peer runnin in the webrtc-relay instance, and removes it from the instance (not yet implemented)
	CloseRelayPeer(ctx context.Context, in *RelayPeerNumber, opts ...grpc.CallOption) (*RelayErrorEvent, error)
	// Gets the config and actual peerId of the webrtc-relay instance (not yet implemented)
	GetRelayPeerConfig(ctx context.Context, in *RelayPeerNumber, opts ...grpc.CallOption) (*RelayConfig, error)
}

WebRTCRelayClient is the client API for WebRTCRelay service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewWebRTCRelayClient 

func NewWebRTCRelayClient(cc grpc.ClientConnInterface) WebRTCRelayClient

type WebRTCRelayServer 

type WebRTCRelayServer interface {
	// Get a stream of events from the webrtc-relay including recived messages, peer dis/connection events & errors, relay dis/connection events & errors.
	// Events that happen as a result of an RPC call WILL BE sent on this stream with the exchangeId set to the.
	// see the RelayEventStream type for more details - This is a server-side streaming RPC
	// The grpc client should send an empty EventStreamRequest message to start the stream
	GetEventStream(*EventStreamRequest, WebRTCRelay_GetEventStreamServer) error
	// Tell the webrtc-relay to connect to a peer
	// If errors/events happen later because of DisconnectFromPeer(), they will get sent on the RelayEventStream with the same exchangeId as included in this rpc ConnectionRequest (not returned to this RPC call)
	ConnectToPeer(context.Context, *ConnectionRequest) (*ConnectionResponse, error)
	// Tell the webrtc-relay to disconnect from a peer it has an open connection with
	// If errors/events happen later because of DisconnectFromPeer(), they will get sent on the RelayEventStream with the same exchangeId as included in this rpc ConnectionRequest (not returned to this RPC call)
	DisconnectFromPeer(context.Context, *ConnectionRequest) (*ConnectionResponse, error)
	// Tell the webrtc-relay to call a peer with a given stream name and media track
	// can be used to initiate a call or to add a media track to an existing call (untested)
	// If errors/events happen later because of CallPeer(), they will get sent on the RelayEventStream with the same exchangeId as included in this rpc CallRequest (not returned to this RPC call)
	CallPeer(context.Context, *CallRequest) (*CallResponse, error)
	// Tell the webrtc-relay to stop the media call with a peer (does not cause relay to disconnect any open datachannels with the peer)
	// If errors/events happen later because of HangupPeer(), they will get sent on the RelayEventStream with the same exchangeId as included in this rpc ConnectionRequest (not returned to this RPC call)
	HangupPeer(context.Context, *ConnectionRequest) (*CallResponse, error)
	// Opens a stream to the webrtc-relay which can be used to send lots of messages to one or more connected peers.
	// If errors/events happen because of a sending a message, they will get sent on the RelayEventStream with the same exchangeId as included in this rpc SendMsgRequest (not returned to this RPC call)
	SendMsgStream(WebRTCRelay_SendMsgStreamServer) error
	// Adds a new Relay Peer to the webrtc-relay instance, and starts it (not yet implemented)
	AddRelayPeer(context.Context, *AddRelayRequest) (*RelayErrorEvent, error)
	// Stops a Relay Peer runnin in the webrtc-relay instance, and removes it from the instance (not yet implemented)
	CloseRelayPeer(context.Context, *RelayPeerNumber) (*RelayErrorEvent, error)
	// Gets the config and actual peerId of the webrtc-relay instance (not yet implemented)
	GetRelayPeerConfig(context.Context, *RelayPeerNumber) (*RelayConfig, error)
	// contains filtered or unexported methods
}

WebRTCRelayServer is the server API for WebRTCRelay service. All implementations must embed UnimplementedWebRTCRelayServer for forward compatibility

type WebRTCRelay_GetEventStreamClient 

type WebRTCRelay_GetEventStreamClient interface {
	Recv() (*RelayEventStream, error)
	grpc.ClientStream
}

type WebRTCRelay_GetEventStreamServer 

type WebRTCRelay_GetEventStreamServer interface {
	Send(*RelayEventStream) error
	grpc.ServerStream
}

type WebRTCRelay_SendMsgStreamClient 

type WebRTCRelay_SendMsgStreamClient interface {
	Send(*SendMsgRequest) error
	CloseAndRecv() (*ConnectionResponse, error)
	grpc.ClientStream
}

type WebRTCRelay_SendMsgStreamServer 

type WebRTCRelay_SendMsgStreamServer interface {
	SendAndClose(*ConnectionResponse) error
	Recv() (*SendMsgRequest, error)
	grpc.ServerStream
}

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.