Documentation
¶
Index ¶
- Variables
- type StreamMessageRequest
- func (*StreamMessageRequest) Descriptor() ([]byte, []int)deprecated
- func (x *StreamMessageRequest) GetInitialize() *StreamMessageRequest_Initialize
- func (x *StreamMessageRequest) GetJoinChannel() *StreamMessageRequest_JoinChannel
- func (m *StreamMessageRequest) GetMessage() isStreamMessageRequest_Message
- func (x *StreamMessageRequest) GetPrepareForJoinChannel() *StreamMessageRequest_PrepareForJoinChannel
- func (x *StreamMessageRequest) GetResumeConsumer() *StreamMessageRequest_ResumeConsumer
- func (m *StreamMessageRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *StreamMessageRequest) MarshalToVT(dAtA []byte) (int, error)
- func (m *StreamMessageRequest) MarshalVT() (dAtA []byte, err error)
- func (*StreamMessageRequest) ProtoMessage()
- func (x *StreamMessageRequest) ProtoReflect() protoreflect.Message
- func (x *StreamMessageRequest) Reset()
- func (m *StreamMessageRequest) SizeVT() (n int)
- func (x *StreamMessageRequest) String() string
- func (m *StreamMessageRequest) UnmarshalVT(dAtA []byte) error
- type StreamMessageRequest_Initialize
- func (*StreamMessageRequest_Initialize) Descriptor() ([]byte, []int)deprecated
- func (x *StreamMessageRequest_Initialize) GetChannelId() uint64
- func (x *StreamMessageRequest_Initialize) GetGuildId() uint64
- func (m *StreamMessageRequest_Initialize) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *StreamMessageRequest_Initialize) MarshalToVT(dAtA []byte) (int, error)
- func (m *StreamMessageRequest_Initialize) MarshalVT() (dAtA []byte, err error)
- func (*StreamMessageRequest_Initialize) ProtoMessage()
- func (x *StreamMessageRequest_Initialize) ProtoReflect() protoreflect.Message
- func (x *StreamMessageRequest_Initialize) Reset()
- func (m *StreamMessageRequest_Initialize) SizeVT() (n int)
- func (x *StreamMessageRequest_Initialize) String() string
- func (m *StreamMessageRequest_Initialize) UnmarshalVT(dAtA []byte) error
- type StreamMessageRequest_Initialize_
- type StreamMessageRequest_JoinChannel
- func (*StreamMessageRequest_JoinChannel) Descriptor() ([]byte, []int)deprecated
- func (x *StreamMessageRequest_JoinChannel) GetConsumerDtlsParamaters() string
- func (x *StreamMessageRequest_JoinChannel) GetProducerDtlsParamaters() string
- func (x *StreamMessageRequest_JoinChannel) GetRtpParamaters() string
- func (m *StreamMessageRequest_JoinChannel) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *StreamMessageRequest_JoinChannel) MarshalToVT(dAtA []byte) (int, error)
- func (m *StreamMessageRequest_JoinChannel) MarshalVT() (dAtA []byte, err error)
- func (*StreamMessageRequest_JoinChannel) ProtoMessage()
- func (x *StreamMessageRequest_JoinChannel) ProtoReflect() protoreflect.Message
- func (x *StreamMessageRequest_JoinChannel) Reset()
- func (m *StreamMessageRequest_JoinChannel) SizeVT() (n int)
- func (x *StreamMessageRequest_JoinChannel) String() string
- func (m *StreamMessageRequest_JoinChannel) UnmarshalVT(dAtA []byte) error
- type StreamMessageRequest_JoinChannel_
- type StreamMessageRequest_PrepareForJoinChannel
- func (*StreamMessageRequest_PrepareForJoinChannel) Descriptor() ([]byte, []int)deprecated
- func (x *StreamMessageRequest_PrepareForJoinChannel) GetRtpCapabilities() string
- func (m *StreamMessageRequest_PrepareForJoinChannel) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *StreamMessageRequest_PrepareForJoinChannel) MarshalToVT(dAtA []byte) (int, error)
- func (m *StreamMessageRequest_PrepareForJoinChannel) MarshalVT() (dAtA []byte, err error)
- func (*StreamMessageRequest_PrepareForJoinChannel) ProtoMessage()
- func (x *StreamMessageRequest_PrepareForJoinChannel) ProtoReflect() protoreflect.Message
- func (x *StreamMessageRequest_PrepareForJoinChannel) Reset()
- func (m *StreamMessageRequest_PrepareForJoinChannel) SizeVT() (n int)
- func (x *StreamMessageRequest_PrepareForJoinChannel) String() string
- func (m *StreamMessageRequest_PrepareForJoinChannel) UnmarshalVT(dAtA []byte) error
- type StreamMessageRequest_PrepareForJoinChannel_
- type StreamMessageRequest_ResumeConsumer
- func (*StreamMessageRequest_ResumeConsumer) Descriptor() ([]byte, []int)deprecated
- func (x *StreamMessageRequest_ResumeConsumer) GetConsumerId() string
- func (m *StreamMessageRequest_ResumeConsumer) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *StreamMessageRequest_ResumeConsumer) MarshalToVT(dAtA []byte) (int, error)
- func (m *StreamMessageRequest_ResumeConsumer) MarshalVT() (dAtA []byte, err error)
- func (*StreamMessageRequest_ResumeConsumer) ProtoMessage()
- func (x *StreamMessageRequest_ResumeConsumer) ProtoReflect() protoreflect.Message
- func (x *StreamMessageRequest_ResumeConsumer) Reset()
- func (m *StreamMessageRequest_ResumeConsumer) SizeVT() (n int)
- func (x *StreamMessageRequest_ResumeConsumer) String() string
- func (m *StreamMessageRequest_ResumeConsumer) UnmarshalVT(dAtA []byte) error
- type StreamMessageRequest_ResumeConsumer_
- type StreamMessageResponse
- func (*StreamMessageResponse) Descriptor() ([]byte, []int)deprecated
- func (x *StreamMessageResponse) GetInitialized() *StreamMessageResponse_Initialized
- func (x *StreamMessageResponse) GetJoinedChannel() *StreamMessageResponse_JoinedChannel
- func (m *StreamMessageResponse) GetMessage() isStreamMessageResponse_Message
- func (x *StreamMessageResponse) GetPreparedForJoinChannel() *StreamMessageResponse_PreparedForJoinChannel
- func (x *StreamMessageResponse) GetUserJoined() *StreamMessageResponse_UserJoined
- func (x *StreamMessageResponse) GetUserLeft() *StreamMessageResponse_UserLeft
- func (m *StreamMessageResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *StreamMessageResponse) MarshalToVT(dAtA []byte) (int, error)
- func (m *StreamMessageResponse) MarshalVT() (dAtA []byte, err error)
- func (*StreamMessageResponse) ProtoMessage()
- func (x *StreamMessageResponse) ProtoReflect() protoreflect.Message
- func (x *StreamMessageResponse) Reset()
- func (m *StreamMessageResponse) SizeVT() (n int)
- func (x *StreamMessageResponse) String() string
- func (m *StreamMessageResponse) UnmarshalVT(dAtA []byte) error
- type StreamMessageResponse_Initialized
- func (*StreamMessageResponse_Initialized) Descriptor() ([]byte, []int)deprecated
- func (x *StreamMessageResponse_Initialized) GetRtpCapabilities() string
- func (m *StreamMessageResponse_Initialized) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *StreamMessageResponse_Initialized) MarshalToVT(dAtA []byte) (int, error)
- func (m *StreamMessageResponse_Initialized) MarshalVT() (dAtA []byte, err error)
- func (*StreamMessageResponse_Initialized) ProtoMessage()
- func (x *StreamMessageResponse_Initialized) ProtoReflect() protoreflect.Message
- func (x *StreamMessageResponse_Initialized) Reset()
- func (m *StreamMessageResponse_Initialized) SizeVT() (n int)
- func (x *StreamMessageResponse_Initialized) String() string
- func (m *StreamMessageResponse_Initialized) UnmarshalVT(dAtA []byte) error
- type StreamMessageResponse_Initialized_
- type StreamMessageResponse_JoinedChannel
- func (*StreamMessageResponse_JoinedChannel) Descriptor() ([]byte, []int)deprecated
- func (x *StreamMessageResponse_JoinedChannel) GetOtherUsers() []*UserConsumerOptions
- func (m *StreamMessageResponse_JoinedChannel) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *StreamMessageResponse_JoinedChannel) MarshalToVT(dAtA []byte) (int, error)
- func (m *StreamMessageResponse_JoinedChannel) MarshalVT() (dAtA []byte, err error)
- func (*StreamMessageResponse_JoinedChannel) ProtoMessage()
- func (x *StreamMessageResponse_JoinedChannel) ProtoReflect() protoreflect.Message
- func (x *StreamMessageResponse_JoinedChannel) Reset()
- func (m *StreamMessageResponse_JoinedChannel) SizeVT() (n int)
- func (x *StreamMessageResponse_JoinedChannel) String() string
- func (m *StreamMessageResponse_JoinedChannel) UnmarshalVT(dAtA []byte) error
- type StreamMessageResponse_JoinedChannel_
- type StreamMessageResponse_PreparedForJoinChannel
- func (*StreamMessageResponse_PreparedForJoinChannel) Descriptor() ([]byte, []int)deprecated
- func (x *StreamMessageResponse_PreparedForJoinChannel) GetConsumerTransportOptions() *TransportOptions
- func (x *StreamMessageResponse_PreparedForJoinChannel) GetProducerTransportOptions() *TransportOptions
- func (m *StreamMessageResponse_PreparedForJoinChannel) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *StreamMessageResponse_PreparedForJoinChannel) MarshalToVT(dAtA []byte) (int, error)
- func (m *StreamMessageResponse_PreparedForJoinChannel) MarshalVT() (dAtA []byte, err error)
- func (*StreamMessageResponse_PreparedForJoinChannel) ProtoMessage()
- func (x *StreamMessageResponse_PreparedForJoinChannel) ProtoReflect() protoreflect.Message
- func (x *StreamMessageResponse_PreparedForJoinChannel) Reset()
- func (m *StreamMessageResponse_PreparedForJoinChannel) SizeVT() (n int)
- func (x *StreamMessageResponse_PreparedForJoinChannel) String() string
- func (m *StreamMessageResponse_PreparedForJoinChannel) UnmarshalVT(dAtA []byte) error
- type StreamMessageResponse_PreparedForJoinChannel_
- type StreamMessageResponse_UserJoined
- func (*StreamMessageResponse_UserJoined) Descriptor() ([]byte, []int)deprecated
- func (x *StreamMessageResponse_UserJoined) GetData() *UserConsumerOptions
- func (m *StreamMessageResponse_UserJoined) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *StreamMessageResponse_UserJoined) MarshalToVT(dAtA []byte) (int, error)
- func (m *StreamMessageResponse_UserJoined) MarshalVT() (dAtA []byte, err error)
- func (*StreamMessageResponse_UserJoined) ProtoMessage()
- func (x *StreamMessageResponse_UserJoined) ProtoReflect() protoreflect.Message
- func (x *StreamMessageResponse_UserJoined) Reset()
- func (m *StreamMessageResponse_UserJoined) SizeVT() (n int)
- func (x *StreamMessageResponse_UserJoined) String() string
- func (m *StreamMessageResponse_UserJoined) UnmarshalVT(dAtA []byte) error
- type StreamMessageResponse_UserJoined_
- type StreamMessageResponse_UserLeft
- func (*StreamMessageResponse_UserLeft) Descriptor() ([]byte, []int)deprecated
- func (x *StreamMessageResponse_UserLeft) GetUserId() uint64
- func (m *StreamMessageResponse_UserLeft) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *StreamMessageResponse_UserLeft) MarshalToVT(dAtA []byte) (int, error)
- func (m *StreamMessageResponse_UserLeft) MarshalVT() (dAtA []byte, err error)
- func (*StreamMessageResponse_UserLeft) ProtoMessage()
- func (x *StreamMessageResponse_UserLeft) ProtoReflect() protoreflect.Message
- func (x *StreamMessageResponse_UserLeft) Reset()
- func (m *StreamMessageResponse_UserLeft) SizeVT() (n int)
- func (x *StreamMessageResponse_UserLeft) String() string
- func (m *StreamMessageResponse_UserLeft) UnmarshalVT(dAtA []byte) error
- type StreamMessageResponse_UserLeft_
- type TransportOptions
- func (*TransportOptions) Descriptor() ([]byte, []int)deprecated
- func (x *TransportOptions) GetDtlsParameters() string
- func (x *TransportOptions) GetIceCandidates() []string
- func (x *TransportOptions) GetIceParameters() string
- func (x *TransportOptions) GetId() string
- func (m *TransportOptions) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *TransportOptions) MarshalToVT(dAtA []byte) (int, error)
- func (m *TransportOptions) MarshalVT() (dAtA []byte, err error)
- func (*TransportOptions) ProtoMessage()
- func (x *TransportOptions) ProtoReflect() protoreflect.Message
- func (x *TransportOptions) Reset()
- func (m *TransportOptions) SizeVT() (n int)
- func (x *TransportOptions) String() string
- func (m *TransportOptions) UnmarshalVT(dAtA []byte) error
- type UserConsumerOptions
- func (*UserConsumerOptions) Descriptor() ([]byte, []int)deprecated
- func (x *UserConsumerOptions) GetConsumerId() string
- func (x *UserConsumerOptions) GetProducerId() string
- func (x *UserConsumerOptions) GetRtpParameters() string
- func (x *UserConsumerOptions) GetUserId() uint64
- func (m *UserConsumerOptions) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *UserConsumerOptions) MarshalToVT(dAtA []byte) (int, error)
- func (m *UserConsumerOptions) MarshalVT() (dAtA []byte, err error)
- func (*UserConsumerOptions) ProtoMessage()
- func (x *UserConsumerOptions) ProtoReflect() protoreflect.Message
- func (x *UserConsumerOptions) Reset()
- func (m *UserConsumerOptions) SizeVT() (n int)
- func (x *UserConsumerOptions) String() string
- func (m *UserConsumerOptions) UnmarshalVT(dAtA []byte) error
- type VoiceService
- type VoiceServiceHandler
Constants ¶
This section is empty.
Variables ¶
var ( ErrInvalidLength = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflow = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroup = fmt.Errorf("proto: unexpected end of group") )
var File_voice_v1_voice_proto protoreflect.FileDescriptor
Functions ¶
This section is empty.
Types ¶
type StreamMessageRequest ¶
type StreamMessageRequest struct { // Message for this response. // // Types that are assignable to Message: // *StreamMessageRequest_Initialize_ // *StreamMessageRequest_PrepareForJoinChannel_ // *StreamMessageRequest_JoinChannel_ // *StreamMessageRequest_ResumeConsumer_ Message isStreamMessageRequest_Message `protobuf_oneof:"message"` // contains filtered or unexported fields }
Used in `StreamMessage` endpoint.
func (*StreamMessageRequest) Descriptor
deprecated
func (*StreamMessageRequest) Descriptor() ([]byte, []int)
Deprecated: Use StreamMessageRequest.ProtoReflect.Descriptor instead.
func (*StreamMessageRequest) GetInitialize ¶
func (x *StreamMessageRequest) GetInitialize() *StreamMessageRequest_Initialize
func (*StreamMessageRequest) GetJoinChannel ¶
func (x *StreamMessageRequest) GetJoinChannel() *StreamMessageRequest_JoinChannel
func (*StreamMessageRequest) GetMessage ¶
func (m *StreamMessageRequest) GetMessage() isStreamMessageRequest_Message
func (*StreamMessageRequest) GetPrepareForJoinChannel ¶
func (x *StreamMessageRequest) GetPrepareForJoinChannel() *StreamMessageRequest_PrepareForJoinChannel
func (*StreamMessageRequest) GetResumeConsumer ¶
func (x *StreamMessageRequest) GetResumeConsumer() *StreamMessageRequest_ResumeConsumer
func (*StreamMessageRequest) MarshalToSizedBufferVT ¶
func (m *StreamMessageRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*StreamMessageRequest) MarshalToVT ¶
func (m *StreamMessageRequest) MarshalToVT(dAtA []byte) (int, error)
func (*StreamMessageRequest) MarshalVT ¶
func (m *StreamMessageRequest) MarshalVT() (dAtA []byte, err error)
func (*StreamMessageRequest) ProtoMessage ¶
func (*StreamMessageRequest) ProtoMessage()
func (*StreamMessageRequest) ProtoReflect ¶
func (x *StreamMessageRequest) ProtoReflect() protoreflect.Message
func (*StreamMessageRequest) Reset ¶
func (x *StreamMessageRequest) Reset()
func (*StreamMessageRequest) SizeVT ¶
func (m *StreamMessageRequest) SizeVT() (n int)
func (*StreamMessageRequest) String ¶
func (x *StreamMessageRequest) String() string
func (*StreamMessageRequest) UnmarshalVT ¶
func (m *StreamMessageRequest) UnmarshalVT(dAtA []byte) error
type StreamMessageRequest_Initialize ¶
type StreamMessageRequest_Initialize struct { // Guild ID of the guild where the channel is. GuildId uint64 `protobuf:"varint,1,opt,name=guild_id,json=guildId,proto3" json:"guild_id,omitempty"` // Channel ID of the voice channel to initialize for. ChannelId uint64 `protobuf:"varint,2,opt,name=channel_id,json=channelId,proto3" json:"channel_id,omitempty"` // contains filtered or unexported fields }
IDs that will be used to know which channel this WS will operate in.
func (*StreamMessageRequest_Initialize) Descriptor
deprecated
func (*StreamMessageRequest_Initialize) Descriptor() ([]byte, []int)
Deprecated: Use StreamMessageRequest_Initialize.ProtoReflect.Descriptor instead.
func (*StreamMessageRequest_Initialize) GetChannelId ¶
func (x *StreamMessageRequest_Initialize) GetChannelId() uint64
func (*StreamMessageRequest_Initialize) GetGuildId ¶
func (x *StreamMessageRequest_Initialize) GetGuildId() uint64
func (*StreamMessageRequest_Initialize) MarshalToSizedBufferVT ¶
func (m *StreamMessageRequest_Initialize) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*StreamMessageRequest_Initialize) MarshalToVT ¶
func (m *StreamMessageRequest_Initialize) MarshalToVT(dAtA []byte) (int, error)
func (*StreamMessageRequest_Initialize) MarshalVT ¶
func (m *StreamMessageRequest_Initialize) MarshalVT() (dAtA []byte, err error)
func (*StreamMessageRequest_Initialize) ProtoMessage ¶
func (*StreamMessageRequest_Initialize) ProtoMessage()
func (*StreamMessageRequest_Initialize) ProtoReflect ¶
func (x *StreamMessageRequest_Initialize) ProtoReflect() protoreflect.Message
func (*StreamMessageRequest_Initialize) Reset ¶
func (x *StreamMessageRequest_Initialize) Reset()
func (*StreamMessageRequest_Initialize) SizeVT ¶
func (m *StreamMessageRequest_Initialize) SizeVT() (n int)
func (*StreamMessageRequest_Initialize) String ¶
func (x *StreamMessageRequest_Initialize) String() string
func (*StreamMessageRequest_Initialize) UnmarshalVT ¶
func (m *StreamMessageRequest_Initialize) UnmarshalVT(dAtA []byte) error
type StreamMessageRequest_Initialize_ ¶
type StreamMessageRequest_Initialize_ struct { // Sent to initialize the WS and receive necessary information. Initialize *StreamMessageRequest_Initialize `protobuf:"bytes,1,opt,name=initialize,proto3,oneof"` }
func (*StreamMessageRequest_Initialize_) MarshalToSizedBufferVT ¶
func (m *StreamMessageRequest_Initialize_) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*StreamMessageRequest_Initialize_) MarshalToVT ¶
func (m *StreamMessageRequest_Initialize_) MarshalToVT(dAtA []byte) (int, error)
func (*StreamMessageRequest_Initialize_) SizeVT ¶
func (m *StreamMessageRequest_Initialize_) SizeVT() (n int)
type StreamMessageRequest_JoinChannel ¶
type StreamMessageRequest_JoinChannel struct { // RTP paramaters in JSON. Corresponds to `RtpParameters` in mediasoup's TypeScript API. RtpParamaters string `protobuf:"bytes,1,opt,name=rtp_paramaters,json=rtpParamaters,proto3" json:"rtp_paramaters,omitempty"` // DTLS paramaters for producer transport, in JSON. Corresponds to `DtlsParameters` in mediasoup's TypeScript API. ProducerDtlsParamaters string `` /* 129-byte string literal not displayed */ // DTLS paramaters for consumer transport, in JSON. Corresponds to `DtlsParameters` in mediasoup's TypeScript API. ConsumerDtlsParamaters string `` /* 129-byte string literal not displayed */ // contains filtered or unexported fields }
Data needed to join a channel.
This takes one RTP paramaters for one track, which will be assumed to be Audio.
It also takes DTLS paramaters for connecting both producer and consumer.
func (*StreamMessageRequest_JoinChannel) Descriptor
deprecated
func (*StreamMessageRequest_JoinChannel) Descriptor() ([]byte, []int)
Deprecated: Use StreamMessageRequest_JoinChannel.ProtoReflect.Descriptor instead.
func (*StreamMessageRequest_JoinChannel) GetConsumerDtlsParamaters ¶
func (x *StreamMessageRequest_JoinChannel) GetConsumerDtlsParamaters() string
func (*StreamMessageRequest_JoinChannel) GetProducerDtlsParamaters ¶
func (x *StreamMessageRequest_JoinChannel) GetProducerDtlsParamaters() string
func (*StreamMessageRequest_JoinChannel) GetRtpParamaters ¶
func (x *StreamMessageRequest_JoinChannel) GetRtpParamaters() string
func (*StreamMessageRequest_JoinChannel) MarshalToSizedBufferVT ¶
func (m *StreamMessageRequest_JoinChannel) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*StreamMessageRequest_JoinChannel) MarshalToVT ¶
func (m *StreamMessageRequest_JoinChannel) MarshalToVT(dAtA []byte) (int, error)
func (*StreamMessageRequest_JoinChannel) MarshalVT ¶
func (m *StreamMessageRequest_JoinChannel) MarshalVT() (dAtA []byte, err error)
func (*StreamMessageRequest_JoinChannel) ProtoMessage ¶
func (*StreamMessageRequest_JoinChannel) ProtoMessage()
func (*StreamMessageRequest_JoinChannel) ProtoReflect ¶
func (x *StreamMessageRequest_JoinChannel) ProtoReflect() protoreflect.Message
func (*StreamMessageRequest_JoinChannel) Reset ¶
func (x *StreamMessageRequest_JoinChannel) Reset()
func (*StreamMessageRequest_JoinChannel) SizeVT ¶
func (m *StreamMessageRequest_JoinChannel) SizeVT() (n int)
func (*StreamMessageRequest_JoinChannel) String ¶
func (x *StreamMessageRequest_JoinChannel) String() string
func (*StreamMessageRequest_JoinChannel) UnmarshalVT ¶
func (m *StreamMessageRequest_JoinChannel) UnmarshalVT(dAtA []byte) error
type StreamMessageRequest_JoinChannel_ ¶
type StreamMessageRequest_JoinChannel_ struct { // Sent to join a channel. JoinChannel *StreamMessageRequest_JoinChannel `protobuf:"bytes,3,opt,name=join_channel,json=joinChannel,proto3,oneof"` }
func (*StreamMessageRequest_JoinChannel_) MarshalToSizedBufferVT ¶
func (m *StreamMessageRequest_JoinChannel_) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*StreamMessageRequest_JoinChannel_) MarshalToVT ¶
func (m *StreamMessageRequest_JoinChannel_) MarshalToVT(dAtA []byte) (int, error)
func (*StreamMessageRequest_JoinChannel_) SizeVT ¶
func (m *StreamMessageRequest_JoinChannel_) SizeVT() (n int)
type StreamMessageRequest_PrepareForJoinChannel ¶
type StreamMessageRequest_PrepareForJoinChannel struct { // RTP capabilities in JSON. RtpCapabilities string `protobuf:"bytes,1,opt,name=rtp_capabilities,json=rtpCapabilities,proto3" json:"rtp_capabilities,omitempty"` // contains filtered or unexported fields }
Data needed to prepare for joining a channel.
func (*StreamMessageRequest_PrepareForJoinChannel) Descriptor
deprecated
func (*StreamMessageRequest_PrepareForJoinChannel) Descriptor() ([]byte, []int)
Deprecated: Use StreamMessageRequest_PrepareForJoinChannel.ProtoReflect.Descriptor instead.
func (*StreamMessageRequest_PrepareForJoinChannel) GetRtpCapabilities ¶
func (x *StreamMessageRequest_PrepareForJoinChannel) GetRtpCapabilities() string
func (*StreamMessageRequest_PrepareForJoinChannel) MarshalToSizedBufferVT ¶
func (m *StreamMessageRequest_PrepareForJoinChannel) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*StreamMessageRequest_PrepareForJoinChannel) MarshalToVT ¶
func (m *StreamMessageRequest_PrepareForJoinChannel) MarshalToVT(dAtA []byte) (int, error)
func (*StreamMessageRequest_PrepareForJoinChannel) MarshalVT ¶
func (m *StreamMessageRequest_PrepareForJoinChannel) MarshalVT() (dAtA []byte, err error)
func (*StreamMessageRequest_PrepareForJoinChannel) ProtoMessage ¶
func (*StreamMessageRequest_PrepareForJoinChannel) ProtoMessage()
func (*StreamMessageRequest_PrepareForJoinChannel) ProtoReflect ¶
func (x *StreamMessageRequest_PrepareForJoinChannel) ProtoReflect() protoreflect.Message
func (*StreamMessageRequest_PrepareForJoinChannel) Reset ¶
func (x *StreamMessageRequest_PrepareForJoinChannel) Reset()
func (*StreamMessageRequest_PrepareForJoinChannel) SizeVT ¶
func (m *StreamMessageRequest_PrepareForJoinChannel) SizeVT() (n int)
func (*StreamMessageRequest_PrepareForJoinChannel) String ¶
func (x *StreamMessageRequest_PrepareForJoinChannel) String() string
func (*StreamMessageRequest_PrepareForJoinChannel) UnmarshalVT ¶
func (m *StreamMessageRequest_PrepareForJoinChannel) UnmarshalVT(dAtA []byte) error
type StreamMessageRequest_PrepareForJoinChannel_ ¶
type StreamMessageRequest_PrepareForJoinChannel_ struct { // Sent to prepare for joining channel. PrepareForJoinChannel *StreamMessageRequest_PrepareForJoinChannel `protobuf:"bytes,2,opt,name=prepare_for_join_channel,json=prepareForJoinChannel,proto3,oneof"` }
func (*StreamMessageRequest_PrepareForJoinChannel_) MarshalToSizedBufferVT ¶
func (m *StreamMessageRequest_PrepareForJoinChannel_) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*StreamMessageRequest_PrepareForJoinChannel_) MarshalToVT ¶
func (m *StreamMessageRequest_PrepareForJoinChannel_) MarshalToVT(dAtA []byte) (int, error)
func (*StreamMessageRequest_PrepareForJoinChannel_) SizeVT ¶
func (m *StreamMessageRequest_PrepareForJoinChannel_) SizeVT() (n int)
type StreamMessageRequest_ResumeConsumer ¶
type StreamMessageRequest_ResumeConsumer struct { // ID of the consumer to resume. ConsumerId string `protobuf:"bytes,1,opt,name=consumer_id,json=consumerId,proto3" json:"consumer_id,omitempty"` // contains filtered or unexported fields }
Message to resume a consumer.
func (*StreamMessageRequest_ResumeConsumer) Descriptor
deprecated
func (*StreamMessageRequest_ResumeConsumer) Descriptor() ([]byte, []int)
Deprecated: Use StreamMessageRequest_ResumeConsumer.ProtoReflect.Descriptor instead.
func (*StreamMessageRequest_ResumeConsumer) GetConsumerId ¶
func (x *StreamMessageRequest_ResumeConsumer) GetConsumerId() string
func (*StreamMessageRequest_ResumeConsumer) MarshalToSizedBufferVT ¶
func (m *StreamMessageRequest_ResumeConsumer) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*StreamMessageRequest_ResumeConsumer) MarshalToVT ¶
func (m *StreamMessageRequest_ResumeConsumer) MarshalToVT(dAtA []byte) (int, error)
func (*StreamMessageRequest_ResumeConsumer) MarshalVT ¶
func (m *StreamMessageRequest_ResumeConsumer) MarshalVT() (dAtA []byte, err error)
func (*StreamMessageRequest_ResumeConsumer) ProtoMessage ¶
func (*StreamMessageRequest_ResumeConsumer) ProtoMessage()
func (*StreamMessageRequest_ResumeConsumer) ProtoReflect ¶
func (x *StreamMessageRequest_ResumeConsumer) ProtoReflect() protoreflect.Message
func (*StreamMessageRequest_ResumeConsumer) Reset ¶
func (x *StreamMessageRequest_ResumeConsumer) Reset()
func (*StreamMessageRequest_ResumeConsumer) SizeVT ¶
func (m *StreamMessageRequest_ResumeConsumer) SizeVT() (n int)
func (*StreamMessageRequest_ResumeConsumer) String ¶
func (x *StreamMessageRequest_ResumeConsumer) String() string
func (*StreamMessageRequest_ResumeConsumer) UnmarshalVT ¶
func (m *StreamMessageRequest_ResumeConsumer) UnmarshalVT(dAtA []byte) error
type StreamMessageRequest_ResumeConsumer_ ¶
type StreamMessageRequest_ResumeConsumer_ struct { // Sent to resume a consumer. ResumeConsumer *StreamMessageRequest_ResumeConsumer `protobuf:"bytes,4,opt,name=resume_consumer,json=resumeConsumer,proto3,oneof"` }
func (*StreamMessageRequest_ResumeConsumer_) MarshalToSizedBufferVT ¶
func (m *StreamMessageRequest_ResumeConsumer_) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*StreamMessageRequest_ResumeConsumer_) MarshalToVT ¶
func (m *StreamMessageRequest_ResumeConsumer_) MarshalToVT(dAtA []byte) (int, error)
func (*StreamMessageRequest_ResumeConsumer_) SizeVT ¶
func (m *StreamMessageRequest_ResumeConsumer_) SizeVT() (n int)
type StreamMessageResponse ¶
type StreamMessageResponse struct { // Message for this response. // // Types that are assignable to Message: // *StreamMessageResponse_Initialized_ // *StreamMessageResponse_PreparedForJoinChannel_ // *StreamMessageResponse_JoinedChannel_ // *StreamMessageResponse_UserJoined_ // *StreamMessageResponse_UserLeft_ Message isStreamMessageResponse_Message `protobuf_oneof:"message"` // contains filtered or unexported fields }
Used in `StreamMessage` endpoint.
func (*StreamMessageResponse) Descriptor
deprecated
func (*StreamMessageResponse) Descriptor() ([]byte, []int)
Deprecated: Use StreamMessageResponse.ProtoReflect.Descriptor instead.
func (*StreamMessageResponse) GetInitialized ¶
func (x *StreamMessageResponse) GetInitialized() *StreamMessageResponse_Initialized
func (*StreamMessageResponse) GetJoinedChannel ¶
func (x *StreamMessageResponse) GetJoinedChannel() *StreamMessageResponse_JoinedChannel
func (*StreamMessageResponse) GetMessage ¶
func (m *StreamMessageResponse) GetMessage() isStreamMessageResponse_Message
func (*StreamMessageResponse) GetPreparedForJoinChannel ¶
func (x *StreamMessageResponse) GetPreparedForJoinChannel() *StreamMessageResponse_PreparedForJoinChannel
func (*StreamMessageResponse) GetUserJoined ¶
func (x *StreamMessageResponse) GetUserJoined() *StreamMessageResponse_UserJoined
func (*StreamMessageResponse) GetUserLeft ¶
func (x *StreamMessageResponse) GetUserLeft() *StreamMessageResponse_UserLeft
func (*StreamMessageResponse) MarshalToSizedBufferVT ¶
func (m *StreamMessageResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*StreamMessageResponse) MarshalToVT ¶
func (m *StreamMessageResponse) MarshalToVT(dAtA []byte) (int, error)
func (*StreamMessageResponse) MarshalVT ¶
func (m *StreamMessageResponse) MarshalVT() (dAtA []byte, err error)
func (*StreamMessageResponse) ProtoMessage ¶
func (*StreamMessageResponse) ProtoMessage()
func (*StreamMessageResponse) ProtoReflect ¶
func (x *StreamMessageResponse) ProtoReflect() protoreflect.Message
func (*StreamMessageResponse) Reset ¶
func (x *StreamMessageResponse) Reset()
func (*StreamMessageResponse) SizeVT ¶
func (m *StreamMessageResponse) SizeVT() (n int)
func (*StreamMessageResponse) String ¶
func (x *StreamMessageResponse) String() string
func (*StreamMessageResponse) UnmarshalVT ¶
func (m *StreamMessageResponse) UnmarshalVT(dAtA []byte) error
type StreamMessageResponse_Initialized ¶
type StreamMessageResponse_Initialized struct { // Server RTP capabilities in JSON. Corresponds to `RtpCapabilities` in mediasoup's TypeScript API. RtpCapabilities string `protobuf:"bytes,1,opt,name=rtp_capabilities,json=rtpCapabilities,proto3" json:"rtp_capabilities,omitempty"` // contains filtered or unexported fields }
Initialization data for client.
func (*StreamMessageResponse_Initialized) Descriptor
deprecated
func (*StreamMessageResponse_Initialized) Descriptor() ([]byte, []int)
Deprecated: Use StreamMessageResponse_Initialized.ProtoReflect.Descriptor instead.
func (*StreamMessageResponse_Initialized) GetRtpCapabilities ¶
func (x *StreamMessageResponse_Initialized) GetRtpCapabilities() string
func (*StreamMessageResponse_Initialized) MarshalToSizedBufferVT ¶
func (m *StreamMessageResponse_Initialized) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*StreamMessageResponse_Initialized) MarshalToVT ¶
func (m *StreamMessageResponse_Initialized) MarshalToVT(dAtA []byte) (int, error)
func (*StreamMessageResponse_Initialized) MarshalVT ¶
func (m *StreamMessageResponse_Initialized) MarshalVT() (dAtA []byte, err error)
func (*StreamMessageResponse_Initialized) ProtoMessage ¶
func (*StreamMessageResponse_Initialized) ProtoMessage()
func (*StreamMessageResponse_Initialized) ProtoReflect ¶
func (x *StreamMessageResponse_Initialized) ProtoReflect() protoreflect.Message
func (*StreamMessageResponse_Initialized) Reset ¶
func (x *StreamMessageResponse_Initialized) Reset()
func (*StreamMessageResponse_Initialized) SizeVT ¶
func (m *StreamMessageResponse_Initialized) SizeVT() (n int)
func (*StreamMessageResponse_Initialized) String ¶
func (x *StreamMessageResponse_Initialized) String() string
func (*StreamMessageResponse_Initialized) UnmarshalVT ¶
func (m *StreamMessageResponse_Initialized) UnmarshalVT(dAtA []byte) error
type StreamMessageResponse_Initialized_ ¶
type StreamMessageResponse_Initialized_ struct { // Sent when connection is started. Initialized *StreamMessageResponse_Initialized `protobuf:"bytes,1,opt,name=initialized,proto3,oneof"` }
func (*StreamMessageResponse_Initialized_) MarshalToSizedBufferVT ¶
func (m *StreamMessageResponse_Initialized_) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*StreamMessageResponse_Initialized_) MarshalToVT ¶
func (m *StreamMessageResponse_Initialized_) MarshalToVT(dAtA []byte) (int, error)
func (*StreamMessageResponse_Initialized_) SizeVT ¶
func (m *StreamMessageResponse_Initialized_) SizeVT() (n int)
type StreamMessageResponse_JoinedChannel ¶
type StreamMessageResponse_JoinedChannel struct { // Consumer options for users that were already in the room. OtherUsers []*UserConsumerOptions `protobuf:"bytes,1,rep,name=other_users,json=otherUsers,proto3" json:"other_users,omitempty"` // contains filtered or unexported fields }
Producer for voice created; consumer and producer transports are connected.
func (*StreamMessageResponse_JoinedChannel) Descriptor
deprecated
func (*StreamMessageResponse_JoinedChannel) Descriptor() ([]byte, []int)
Deprecated: Use StreamMessageResponse_JoinedChannel.ProtoReflect.Descriptor instead.
func (*StreamMessageResponse_JoinedChannel) GetOtherUsers ¶
func (x *StreamMessageResponse_JoinedChannel) GetOtherUsers() []*UserConsumerOptions
func (*StreamMessageResponse_JoinedChannel) MarshalToSizedBufferVT ¶
func (m *StreamMessageResponse_JoinedChannel) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*StreamMessageResponse_JoinedChannel) MarshalToVT ¶
func (m *StreamMessageResponse_JoinedChannel) MarshalToVT(dAtA []byte) (int, error)
func (*StreamMessageResponse_JoinedChannel) MarshalVT ¶
func (m *StreamMessageResponse_JoinedChannel) MarshalVT() (dAtA []byte, err error)
func (*StreamMessageResponse_JoinedChannel) ProtoMessage ¶
func (*StreamMessageResponse_JoinedChannel) ProtoMessage()
func (*StreamMessageResponse_JoinedChannel) ProtoReflect ¶
func (x *StreamMessageResponse_JoinedChannel) ProtoReflect() protoreflect.Message
func (*StreamMessageResponse_JoinedChannel) Reset ¶
func (x *StreamMessageResponse_JoinedChannel) Reset()
func (*StreamMessageResponse_JoinedChannel) SizeVT ¶
func (m *StreamMessageResponse_JoinedChannel) SizeVT() (n int)
func (*StreamMessageResponse_JoinedChannel) String ¶
func (x *StreamMessageResponse_JoinedChannel) String() string
func (*StreamMessageResponse_JoinedChannel) UnmarshalVT ¶
func (m *StreamMessageResponse_JoinedChannel) UnmarshalVT(dAtA []byte) error
type StreamMessageResponse_JoinedChannel_ ¶
type StreamMessageResponse_JoinedChannel_ struct { // Sent when joining a channel is successful. JoinedChannel *StreamMessageResponse_JoinedChannel `protobuf:"bytes,3,opt,name=joined_channel,json=joinedChannel,proto3,oneof"` }
func (*StreamMessageResponse_JoinedChannel_) MarshalToSizedBufferVT ¶
func (m *StreamMessageResponse_JoinedChannel_) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*StreamMessageResponse_JoinedChannel_) MarshalToVT ¶
func (m *StreamMessageResponse_JoinedChannel_) MarshalToVT(dAtA []byte) (int, error)
func (*StreamMessageResponse_JoinedChannel_) SizeVT ¶
func (m *StreamMessageResponse_JoinedChannel_) SizeVT() (n int)
type StreamMessageResponse_PreparedForJoinChannel ¶
type StreamMessageResponse_PreparedForJoinChannel struct { // Consumer transport options. ConsumerTransportOptions *TransportOptions `` /* 135-byte string literal not displayed */ // Producer transport options. ProducerTransportOptions *TransportOptions `` /* 135-byte string literal not displayed */ // contains filtered or unexported fields }
RTP capabilities validated.
func (*StreamMessageResponse_PreparedForJoinChannel) Descriptor
deprecated
func (*StreamMessageResponse_PreparedForJoinChannel) Descriptor() ([]byte, []int)
Deprecated: Use StreamMessageResponse_PreparedForJoinChannel.ProtoReflect.Descriptor instead.
func (*StreamMessageResponse_PreparedForJoinChannel) GetConsumerTransportOptions ¶
func (x *StreamMessageResponse_PreparedForJoinChannel) GetConsumerTransportOptions() *TransportOptions
func (*StreamMessageResponse_PreparedForJoinChannel) GetProducerTransportOptions ¶
func (x *StreamMessageResponse_PreparedForJoinChannel) GetProducerTransportOptions() *TransportOptions
func (*StreamMessageResponse_PreparedForJoinChannel) MarshalToSizedBufferVT ¶
func (m *StreamMessageResponse_PreparedForJoinChannel) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*StreamMessageResponse_PreparedForJoinChannel) MarshalToVT ¶
func (m *StreamMessageResponse_PreparedForJoinChannel) MarshalToVT(dAtA []byte) (int, error)
func (*StreamMessageResponse_PreparedForJoinChannel) MarshalVT ¶
func (m *StreamMessageResponse_PreparedForJoinChannel) MarshalVT() (dAtA []byte, err error)
func (*StreamMessageResponse_PreparedForJoinChannel) ProtoMessage ¶
func (*StreamMessageResponse_PreparedForJoinChannel) ProtoMessage()
func (*StreamMessageResponse_PreparedForJoinChannel) ProtoReflect ¶
func (x *StreamMessageResponse_PreparedForJoinChannel) ProtoReflect() protoreflect.Message
func (*StreamMessageResponse_PreparedForJoinChannel) Reset ¶
func (x *StreamMessageResponse_PreparedForJoinChannel) Reset()
func (*StreamMessageResponse_PreparedForJoinChannel) SizeVT ¶
func (m *StreamMessageResponse_PreparedForJoinChannel) SizeVT() (n int)
func (*StreamMessageResponse_PreparedForJoinChannel) String ¶
func (x *StreamMessageResponse_PreparedForJoinChannel) String() string
func (*StreamMessageResponse_PreparedForJoinChannel) UnmarshalVT ¶
func (m *StreamMessageResponse_PreparedForJoinChannel) UnmarshalVT(dAtA []byte) error
type StreamMessageResponse_PreparedForJoinChannel_ ¶
type StreamMessageResponse_PreparedForJoinChannel_ struct { // Sent when preparing to join a channel is successful. PreparedForJoinChannel *StreamMessageResponse_PreparedForJoinChannel `protobuf:"bytes,2,opt,name=prepared_for_join_channel,json=preparedForJoinChannel,proto3,oneof"` }
func (*StreamMessageResponse_PreparedForJoinChannel_) MarshalToSizedBufferVT ¶
func (m *StreamMessageResponse_PreparedForJoinChannel_) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*StreamMessageResponse_PreparedForJoinChannel_) MarshalToVT ¶
func (m *StreamMessageResponse_PreparedForJoinChannel_) MarshalToVT(dAtA []byte) (int, error)
func (*StreamMessageResponse_PreparedForJoinChannel_) SizeVT ¶
func (m *StreamMessageResponse_PreparedForJoinChannel_) SizeVT() (n int)
type StreamMessageResponse_UserJoined ¶
type StreamMessageResponse_UserJoined struct { // Consumer options for this user. Data *UserConsumerOptions `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"` // contains filtered or unexported fields }
Data for the user that joined the room and it's producer.
func (*StreamMessageResponse_UserJoined) Descriptor
deprecated
func (*StreamMessageResponse_UserJoined) Descriptor() ([]byte, []int)
Deprecated: Use StreamMessageResponse_UserJoined.ProtoReflect.Descriptor instead.
func (*StreamMessageResponse_UserJoined) GetData ¶
func (x *StreamMessageResponse_UserJoined) GetData() *UserConsumerOptions
func (*StreamMessageResponse_UserJoined) MarshalToSizedBufferVT ¶
func (m *StreamMessageResponse_UserJoined) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*StreamMessageResponse_UserJoined) MarshalToVT ¶
func (m *StreamMessageResponse_UserJoined) MarshalToVT(dAtA []byte) (int, error)
func (*StreamMessageResponse_UserJoined) MarshalVT ¶
func (m *StreamMessageResponse_UserJoined) MarshalVT() (dAtA []byte, err error)
func (*StreamMessageResponse_UserJoined) ProtoMessage ¶
func (*StreamMessageResponse_UserJoined) ProtoMessage()
func (*StreamMessageResponse_UserJoined) ProtoReflect ¶
func (x *StreamMessageResponse_UserJoined) ProtoReflect() protoreflect.Message
func (*StreamMessageResponse_UserJoined) Reset ¶
func (x *StreamMessageResponse_UserJoined) Reset()
func (*StreamMessageResponse_UserJoined) SizeVT ¶
func (m *StreamMessageResponse_UserJoined) SizeVT() (n int)
func (*StreamMessageResponse_UserJoined) String ¶
func (x *StreamMessageResponse_UserJoined) String() string
func (*StreamMessageResponse_UserJoined) UnmarshalVT ¶
func (m *StreamMessageResponse_UserJoined) UnmarshalVT(dAtA []byte) error
type StreamMessageResponse_UserJoined_ ¶
type StreamMessageResponse_UserJoined_ struct { // Sent when another user joins the channel. UserJoined *StreamMessageResponse_UserJoined `protobuf:"bytes,4,opt,name=user_joined,json=userJoined,proto3,oneof"` }
func (*StreamMessageResponse_UserJoined_) MarshalToSizedBufferVT ¶
func (m *StreamMessageResponse_UserJoined_) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*StreamMessageResponse_UserJoined_) MarshalToVT ¶
func (m *StreamMessageResponse_UserJoined_) MarshalToVT(dAtA []byte) (int, error)
func (*StreamMessageResponse_UserJoined_) SizeVT ¶
func (m *StreamMessageResponse_UserJoined_) SizeVT() (n int)
type StreamMessageResponse_UserLeft ¶
type StreamMessageResponse_UserLeft struct { // ID of the user that left. UserId uint64 `protobuf:"varint,1,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"` // contains filtered or unexported fields }
Data for the user that left the room and the producer.
func (*StreamMessageResponse_UserLeft) Descriptor
deprecated
func (*StreamMessageResponse_UserLeft) Descriptor() ([]byte, []int)
Deprecated: Use StreamMessageResponse_UserLeft.ProtoReflect.Descriptor instead.
func (*StreamMessageResponse_UserLeft) GetUserId ¶
func (x *StreamMessageResponse_UserLeft) GetUserId() uint64
func (*StreamMessageResponse_UserLeft) MarshalToSizedBufferVT ¶
func (m *StreamMessageResponse_UserLeft) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*StreamMessageResponse_UserLeft) MarshalToVT ¶
func (m *StreamMessageResponse_UserLeft) MarshalToVT(dAtA []byte) (int, error)
func (*StreamMessageResponse_UserLeft) MarshalVT ¶
func (m *StreamMessageResponse_UserLeft) MarshalVT() (dAtA []byte, err error)
func (*StreamMessageResponse_UserLeft) ProtoMessage ¶
func (*StreamMessageResponse_UserLeft) ProtoMessage()
func (*StreamMessageResponse_UserLeft) ProtoReflect ¶
func (x *StreamMessageResponse_UserLeft) ProtoReflect() protoreflect.Message
func (*StreamMessageResponse_UserLeft) Reset ¶
func (x *StreamMessageResponse_UserLeft) Reset()
func (*StreamMessageResponse_UserLeft) SizeVT ¶
func (m *StreamMessageResponse_UserLeft) SizeVT() (n int)
func (*StreamMessageResponse_UserLeft) String ¶
func (x *StreamMessageResponse_UserLeft) String() string
func (*StreamMessageResponse_UserLeft) UnmarshalVT ¶
func (m *StreamMessageResponse_UserLeft) UnmarshalVT(dAtA []byte) error
type StreamMessageResponse_UserLeft_ ¶
type StreamMessageResponse_UserLeft_ struct { // Sent when another user leaves the channel. UserLeft *StreamMessageResponse_UserLeft `protobuf:"bytes,5,opt,name=user_left,json=userLeft,proto3,oneof"` }
func (*StreamMessageResponse_UserLeft_) MarshalToSizedBufferVT ¶
func (m *StreamMessageResponse_UserLeft_) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*StreamMessageResponse_UserLeft_) MarshalToVT ¶
func (m *StreamMessageResponse_UserLeft_) MarshalToVT(dAtA []byte) (int, error)
func (*StreamMessageResponse_UserLeft_) SizeVT ¶
func (m *StreamMessageResponse_UserLeft_) SizeVT() (n int)
type TransportOptions ¶
type TransportOptions struct { // The transport ID. Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // DTLS paramaters in JSON. Corresponds to `DtlsParameters` in mediasoup's TypeScript API. DtlsParameters string `protobuf:"bytes,2,opt,name=dtls_parameters,json=dtlsParameters,proto3" json:"dtls_parameters,omitempty"` // ICE candidates in JSON. Corresponds to `IceCandidate` in mediasoup's TypeScript API. IceCandidates []string `protobuf:"bytes,3,rep,name=ice_candidates,json=iceCandidates,proto3" json:"ice_candidates,omitempty"` // ICE paramaters in JSON. Corresponds to `IceParameters` in mediasoup's TypeScript API. IceParameters string `protobuf:"bytes,4,opt,name=ice_parameters,json=iceParameters,proto3" json:"ice_parameters,omitempty"` // contains filtered or unexported fields }
Object containing all the necessary information about transport options required from the server to establish transport connection on the client.
This corresponds to https://mediasoup.org/documentation/v3/mediasoup-client/api/#TransportOptions on client: - `id` -> `id` - `ice_parameters` -> `iceParameters` - `dtls_parameters` -> `dtlsParameters` - `ice_candidates` -> `iceCandidates`
func (*TransportOptions) Descriptor
deprecated
func (*TransportOptions) Descriptor() ([]byte, []int)
Deprecated: Use TransportOptions.ProtoReflect.Descriptor instead.
func (*TransportOptions) GetDtlsParameters ¶
func (x *TransportOptions) GetDtlsParameters() string
func (*TransportOptions) GetIceCandidates ¶
func (x *TransportOptions) GetIceCandidates() []string
func (*TransportOptions) GetIceParameters ¶
func (x *TransportOptions) GetIceParameters() string
func (*TransportOptions) GetId ¶
func (x *TransportOptions) GetId() string
func (*TransportOptions) MarshalToSizedBufferVT ¶
func (m *TransportOptions) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*TransportOptions) MarshalToVT ¶
func (m *TransportOptions) MarshalToVT(dAtA []byte) (int, error)
func (*TransportOptions) MarshalVT ¶
func (m *TransportOptions) MarshalVT() (dAtA []byte, err error)
func (*TransportOptions) ProtoMessage ¶
func (*TransportOptions) ProtoMessage()
func (*TransportOptions) ProtoReflect ¶
func (x *TransportOptions) ProtoReflect() protoreflect.Message
func (*TransportOptions) Reset ¶
func (x *TransportOptions) Reset()
func (*TransportOptions) SizeVT ¶
func (m *TransportOptions) SizeVT() (n int)
func (*TransportOptions) String ¶
func (x *TransportOptions) String() string
func (*TransportOptions) UnmarshalVT ¶
func (m *TransportOptions) UnmarshalVT(dAtA []byte) error
type UserConsumerOptions ¶
type UserConsumerOptions struct { // User ID of the user. UserId uint64 `protobuf:"varint,1,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"` // Producer ID of the producer being consumed. ProducerId string `protobuf:"bytes,2,opt,name=producer_id,json=producerId,proto3" json:"producer_id,omitempty"` // Consumer ID for the user's producer consumer. ConsumerId string `protobuf:"bytes,3,opt,name=consumer_id,json=consumerId,proto3" json:"consumer_id,omitempty"` // RTP paramaters for the user's audio track. Corresponds to `RtpParameters` in mediasoup's TypeScript API. RtpParameters string `protobuf:"bytes,4,opt,name=rtp_parameters,json=rtpParameters,proto3" json:"rtp_parameters,omitempty"` // contains filtered or unexported fields }
Data containing all the necessary information to create a consumer for a user in a voice channel.
This corresponds to https://mediasoup.org/documentation/v3/mediasoup-client/api/#ConsumerOptions on client: - `consumer_id` -> `id` - `producer_id` -> `producerId` - `rtp_parameters` -> `rtpParameters` - and `kind` should be set to "audio".
func (*UserConsumerOptions) Descriptor
deprecated
func (*UserConsumerOptions) Descriptor() ([]byte, []int)
Deprecated: Use UserConsumerOptions.ProtoReflect.Descriptor instead.
func (*UserConsumerOptions) GetConsumerId ¶
func (x *UserConsumerOptions) GetConsumerId() string
func (*UserConsumerOptions) GetProducerId ¶
func (x *UserConsumerOptions) GetProducerId() string
func (*UserConsumerOptions) GetRtpParameters ¶
func (x *UserConsumerOptions) GetRtpParameters() string
func (*UserConsumerOptions) GetUserId ¶
func (x *UserConsumerOptions) GetUserId() uint64
func (*UserConsumerOptions) MarshalToSizedBufferVT ¶
func (m *UserConsumerOptions) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*UserConsumerOptions) MarshalToVT ¶
func (m *UserConsumerOptions) MarshalToVT(dAtA []byte) (int, error)
func (*UserConsumerOptions) MarshalVT ¶
func (m *UserConsumerOptions) MarshalVT() (dAtA []byte, err error)
func (*UserConsumerOptions) ProtoMessage ¶
func (*UserConsumerOptions) ProtoMessage()
func (*UserConsumerOptions) ProtoReflect ¶
func (x *UserConsumerOptions) ProtoReflect() protoreflect.Message
func (*UserConsumerOptions) Reset ¶
func (x *UserConsumerOptions) Reset()
func (*UserConsumerOptions) SizeVT ¶
func (m *UserConsumerOptions) SizeVT() (n int)
func (*UserConsumerOptions) String ¶
func (x *UserConsumerOptions) String() string
func (*UserConsumerOptions) UnmarshalVT ¶
func (m *UserConsumerOptions) UnmarshalVT(dAtA []byte) error
type VoiceService ¶
type VoiceService[T context.Context] interface { StreamMessage(T, chan *StreamMessageRequest, chan *StreamMessageResponse) error }
type VoiceServiceHandler ¶
type VoiceServiceHandler[T context.Context] struct { Impl VoiceService[T] }
func (*VoiceServiceHandler[T]) Routes ¶
func (h *VoiceServiceHandler[T]) Routes() map[string]goserver.UnaryMethodData[T]
func (*VoiceServiceHandler[T]) StreamRoutes ¶
func (h *VoiceServiceHandler[T]) StreamRoutes() map[string]goserver.StreamMethodData[T]