voicev1

package
v0.0.0-...-a9cc36f Latest Latest
Warning

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

 Go to latest Published: Mar 11, 2022 License: AGPL-3.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLength        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflow          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroup = fmt.Errorf("proto: unexpected end of group")
)
View Source 
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]

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.