signaling

package
v0.0.0-...-61b8474 Latest Latest
Warning

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

 Go to latest Published: Aug 15, 2024 License: MIT Imports: 10 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	Signaling_Publish_FullMethodName   = "/punchline.signaling.Signaling/Publish"
	Signaling_Subscribe_FullMethodName = "/punchline.signaling.Signaling/Subscribe"
)

Variables

View Source 
var (
	ErrInvalidLengthSignaling        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowSignaling          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupSignaling = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var CandidateType_name = map[int32]string{
	0: "UNSPECIFIED_CANDIDATE_TYPE",
	1: "HOST",
	2: "SERVER_REFLEXIVE",
	3: "PEER_REFLEXIVE",
	4: "RELAY",
}
View Source 
var CandidateType_value = map[string]int32{
	"UNSPECIFIED_CANDIDATE_TYPE": 0,
	"HOST":                       1,
	"SERVER_REFLEXIVE":           2,
	"PEER_REFLEXIVE":             3,
	"RELAY":                      4,
}
View Source 
var ConnectionState_name = map[int32]string{
	0: "NEW",
	1: "CHECKING",
	2: "CONNECTED",
	3: "COMPLETED",
	4: "FAILED",
	5: "DISCONNECTED",
	6: "CLOSED",
}
View Source 
var ConnectionState_value = map[string]int32{
	"NEW":          0,
	"CHECKING":     1,
	"CONNECTED":    2,
	"COMPLETED":    3,
	"FAILED":       4,
	"DISCONNECTED": 5,
	"CLOSED":       6,
}
View Source 
var NetworkType_name = map[int32]string{
	0: "UNSPECIFIED_NETWORK_TYPE",
	1: "UDP4",
	2: "UDP6",
	3: "TCP4",
	4: "TCP6",
}
View Source 
var NetworkType_value = map[string]int32{
	"UNSPECIFIED_NETWORK_TYPE": 0,
	"UDP4":                     1,
	"UDP6":                     2,
	"TCP4":                     3,
	"TCP6":                     4,
}
View Source 
var RelayProtocol_name = map[int32]string{
	0: "UNSPECIFIED_RELAY_PROTOCOL",
	1: "UDP",
	2: "TCP",
	3: "TLS",
	4: "DTLS",
}
View Source 
var RelayProtocol_value = map[string]int32{
	"UNSPECIFIED_RELAY_PROTOCOL": 0,
	"UDP":                        1,
	"TCP":                        2,
	"TLS":                        3,
	"DTLS":                       4,
}
View Source 
var Signaling_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "punchline.signaling.Signaling",
	HandlerType: (*SignalingServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Publish",
			Handler:    _Signaling_Publish_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Subscribe",
			Handler:       _Signaling_Subscribe_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "api/signaling/v1/signaling.proto",
}

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

View Source 
var TCPType_name = map[int32]string{
	0: "UNSPECIFIED_TCP_TYPE",
	1: "ACTIVE",
	2: "PASSIVE",
	3: "SIMULTANEOUS_OPEN",
}
View Source 
var TCPType_value = map[string]int32{
	"UNSPECIFIED_TCP_TYPE": 0,
	"ACTIVE":               1,
	"PASSIVE":              2,
	"SIMULTANEOUS_OPEN":    3,
}

Functions

func RegisterSignalingServer 

func RegisterSignalingServer(s grpc.ServiceRegistrar, srv SignalingServer)

Types

type Candidate 

type Candidate struct {
	// The type of candidate
	Type        CandidateType `protobuf:"varint,1,opt,name=type,proto3,enum=punchline.signaling.CandidateType" json:"type,omitempty"`
	NetworkType NetworkType   `` /* 132-byte string literal not displayed */
	TcpType     TCPType       `protobuf:"varint,3,opt,name=tcp_type,json=tcpType,proto3,enum=punchline.signaling.TCPType" json:"tcp_type,omitempty"`
	// An identifier that is equivalent for two candidates that are of the same type, share the same base, and come from the same STUN server.
	Foundation string `protobuf:"bytes,4,opt,name=foundation,proto3" json:"foundation,omitempty"`
	// A positive integer between 1 and 256 that identifies the specific component of the media stream for which this is a candidate.
	Component int32 `protobuf:"varint,5,opt,name=component,proto3" json:"component,omitempty"`
	// A positive integer between 1 and (2**31 - 1).
	Priority int32 `protobuf:"varint,6,opt,name=priority,proto3" json:"priority,omitempty"`
	// The IP address of the candidate.
	Address string `protobuf:"bytes,7,opt,name=address,proto3" json:"address,omitempty"`
	// The port of the candidate.
	Port int32 `protobuf:"varint,8,opt,name=port,proto3" json:"port,omitempty"`
	// The related address conveys transport addresses related to the candidate, useful for diagnostics and other purposes.
	RelatedAddress *RelatedAddress `protobuf:"bytes,9,opt,name=related_address,json=relatedAddress,proto3" json:"related_address,omitempty"`
	// The protocol used between the endpoint and the relay server.
	RelayProtocol RelayProtocol `` /* 141-byte string literal not displayed */
}

An ICE Candidate contains a transport address for a candidate that can be used for connectivity checks. See: https://datatracker.ietf.org/doc/html/rfc8839#section-5.1

func NewCandidate 

func NewCandidate(ic ice.Candidate) *Candidate

func (*Candidate) Descriptor 

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

func (*Candidate) GetAddress 

func (m *Candidate) GetAddress() string

func (*Candidate) GetComponent 

func (m *Candidate) GetComponent() int32

func (*Candidate) GetFoundation 

func (m *Candidate) GetFoundation() string

func (*Candidate) GetNetworkType 

func (m *Candidate) GetNetworkType() NetworkType

func (*Candidate) GetPort 

func (m *Candidate) GetPort() int32

func (*Candidate) GetPriority 

func (m *Candidate) GetPriority() int32

func (*Candidate) GetRelatedAddress 

func (m *Candidate) GetRelatedAddress() *RelatedAddress

func (*Candidate) GetRelayProtocol 

func (m *Candidate) GetRelayProtocol() RelayProtocol

func (*Candidate) GetTcpType 

func (m *Candidate) GetTcpType() TCPType

func (*Candidate) GetType 

func (m *Candidate) GetType() CandidateType

func (*Candidate) ICECandidate 

func (c *Candidate) ICECandidate() (ice.Candidate, error)

func (*Candidate) Marshal 

func (m *Candidate) Marshal() (dAtA []byte, err error)

func (*Candidate) MarshalTo 

func (m *Candidate) MarshalTo(dAtA []byte) (int, error)

func (*Candidate) MarshalToSizedBuffer 

func (m *Candidate) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Candidate) ProtoMessage 

func (*Candidate) ProtoMessage()

func (*Candidate) Reset 

func (m *Candidate) Reset()

func (*Candidate) Size 

func (m *Candidate) Size() (n int)

func (*Candidate) String 

func (m *Candidate) String() string

func (*Candidate) Unmarshal 

func (m *Candidate) Unmarshal(dAtA []byte) error

func (*Candidate) XXX_DiscardUnknown 

func (m *Candidate) XXX_DiscardUnknown()

func (*Candidate) XXX_Marshal 

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

func (*Candidate) XXX_Merge 

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

func (*Candidate) XXX_Size 

func (m *Candidate) XXX_Size() int

func (*Candidate) XXX_Unmarshal 

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

type CandidateType 

type CandidateType int32

ICE Candidate types See: https://datatracker.ietf.org/doc/html/rfc8445#section-5.1.1 

const (
	CandidateType_UNSPECIFIED_CANDIDATE_TYPE CandidateType = 0
	CandidateType_HOST                       CandidateType = 1
	CandidateType_SERVER_REFLEXIVE           CandidateType = 2
	CandidateType_PEER_REFLEXIVE             CandidateType = 3
	CandidateType_RELAY                      CandidateType = 4
)

func (CandidateType) EnumDescriptor 

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

func (CandidateType) String 

func (x CandidateType) String() string

type ConnectionState 

type ConnectionState int32

ICE Connection state from pion/ice/ice.go 

const (
	ConnectionState_NEW          ConnectionState = 0
	ConnectionState_CHECKING     ConnectionState = 1
	ConnectionState_CONNECTED    ConnectionState = 2
	ConnectionState_COMPLETED    ConnectionState = 3
	ConnectionState_FAILED       ConnectionState = 4
	ConnectionState_DISCONNECTED ConnectionState = 5
	ConnectionState_CLOSED       ConnectionState = 6
)

func NewConnectionState 

func NewConnectionState(cs ice.ConnectionState) ConnectionState

func (ConnectionState) EnumDescriptor 

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

func (ConnectionState) String 

func (x ConnectionState) String() string

type Credentials 

type Credentials struct {
	// ICE username fragment
	Ufrag string `protobuf:"bytes,1,opt,name=ufrag,proto3" json:"ufrag,omitempty"`
	// ICE password
	Pwd string `protobuf:"bytes,2,opt,name=pwd,proto3" json:"pwd,omitempty"`
	// Flag to indicate that the sending peer requests the credentials of the receiving peer
	NeedCreds bool `protobuf:"varint,3,opt,name=need_creds,json=needCreds,proto3" json:"need_creds,omitempty"`
}

func (*Credentials) Descriptor 

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

func (*Credentials) GetNeedCreds 

func (m *Credentials) GetNeedCreds() bool

func (*Credentials) GetPwd 

func (m *Credentials) GetPwd() string

func (*Credentials) GetUfrag 

func (m *Credentials) GetUfrag() string

func (*Credentials) Marshal 

func (m *Credentials) Marshal() (dAtA []byte, err error)

func (*Credentials) MarshalTo 

func (m *Credentials) MarshalTo(dAtA []byte) (int, error)

func (*Credentials) MarshalToSizedBuffer 

func (m *Credentials) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Credentials) ProtoMessage 

func (*Credentials) ProtoMessage()

func (*Credentials) Reset 

func (m *Credentials) Reset()

func (*Credentials) Size 

func (m *Credentials) Size() (n int)

func (*Credentials) String 

func (m *Credentials) String() string

func (*Credentials) Unmarshal 

func (m *Credentials) Unmarshal(dAtA []byte) error

func (*Credentials) XXX_DiscardUnknown 

func (m *Credentials) XXX_DiscardUnknown()

func (*Credentials) XXX_Marshal 

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

func (*Credentials) XXX_Merge 

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

func (*Credentials) XXX_Size 

func (m *Credentials) XXX_Size() int

func (*Credentials) XXX_Unmarshal 

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

type Message 

type Message struct {
	Topic       string       `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	Data        []byte       `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	Candidate   *Candidate   `protobuf:"bytes,3,opt,name=candidate,proto3" json:"candidate,omitempty"`
	Credentials *Credentials `protobuf:"bytes,4,opt,name=credentials,proto3" json:"credentials,omitempty"`
}

func (*Message) Descriptor 

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

func (*Message) GetCandidate 

func (m *Message) GetCandidate() *Candidate

func (*Message) GetCredentials 

func (m *Message) GetCredentials() *Credentials

func (*Message) GetData 

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

func (*Message) GetTopic 

func (m *Message) GetTopic() string

func (*Message) Marshal 

func (m *Message) Marshal() (dAtA []byte, err error)

func (*Message) MarshalTo 

func (m *Message) MarshalTo(dAtA []byte) (int, error)

func (*Message) MarshalToSizedBuffer 

func (m *Message) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Message) ProtoMessage 

func (*Message) ProtoMessage()

func (*Message) Reset 

func (m *Message) Reset()

func (*Message) Size 

func (m *Message) Size() (n int)

func (*Message) String 

func (m *Message) String() string

func (*Message) Unmarshal 

func (m *Message) Unmarshal(dAtA []byte) error

func (*Message) XXX_DiscardUnknown 

func (m *Message) XXX_DiscardUnknown()

func (*Message) XXX_Marshal 

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

func (*Message) XXX_Merge 

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

func (*Message) XXX_Size 

func (m *Message) XXX_Size() int

func (*Message) XXX_Unmarshal 

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

type NetworkType 

type NetworkType int32
const (
	NetworkType_UNSPECIFIED_NETWORK_TYPE NetworkType = 0
	NetworkType_UDP4                     NetworkType = 1
	NetworkType_UDP6                     NetworkType = 2
	NetworkType_TCP4                     NetworkType = 3
	NetworkType_TCP6                     NetworkType = 4
)

func (NetworkType) EnumDescriptor 

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

func (NetworkType) String 

func (x NetworkType) String() string

type PublishRequest 

type PublishRequest struct {
	Topic       string       `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	Hostname    string       `protobuf:"bytes,2,opt,name=hostname,proto3" json:"hostname,omitempty"`
	Data        []byte       `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	Candidate   *Candidate   `protobuf:"bytes,4,opt,name=candidate,proto3" json:"candidate,omitempty"`
	Credentials *Credentials `protobuf:"bytes,5,opt,name=credentials,proto3" json:"credentials,omitempty"`
}

func (*PublishRequest) Descriptor 

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

func (*PublishRequest) GetCandidate 

func (m *PublishRequest) GetCandidate() *Candidate

func (*PublishRequest) GetCredentials 

func (m *PublishRequest) GetCredentials() *Credentials

func (*PublishRequest) GetData 

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

func (*PublishRequest) GetHostname 

func (m *PublishRequest) GetHostname() string

func (*PublishRequest) GetTopic 

func (m *PublishRequest) GetTopic() string

func (*PublishRequest) Marshal 

func (m *PublishRequest) Marshal() (dAtA []byte, err error)

func (*PublishRequest) MarshalTo 

func (m *PublishRequest) MarshalTo(dAtA []byte) (int, error)

func (*PublishRequest) MarshalToSizedBuffer 

func (m *PublishRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PublishRequest) ProtoMessage 

func (*PublishRequest) ProtoMessage()

func (*PublishRequest) Reset 

func (m *PublishRequest) Reset()

func (*PublishRequest) Size 

func (m *PublishRequest) Size() (n int)

func (*PublishRequest) String 

func (m *PublishRequest) String() string

func (*PublishRequest) Unmarshal 

func (m *PublishRequest) Unmarshal(dAtA []byte) error

func (*PublishRequest) XXX_DiscardUnknown 

func (m *PublishRequest) XXX_DiscardUnknown()

func (*PublishRequest) XXX_Marshal 

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

func (*PublishRequest) XXX_Merge 

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

func (*PublishRequest) XXX_Size 

func (m *PublishRequest) XXX_Size() int

func (*PublishRequest) XXX_Unmarshal 

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

type PublishResponse 

type PublishResponse struct {
}

func (*PublishResponse) Descriptor 

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

func (*PublishResponse) Marshal 

func (m *PublishResponse) Marshal() (dAtA []byte, err error)

func (*PublishResponse) MarshalTo 

func (m *PublishResponse) MarshalTo(dAtA []byte) (int, error)

func (*PublishResponse) MarshalToSizedBuffer 

func (m *PublishResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PublishResponse) ProtoMessage 

func (*PublishResponse) ProtoMessage()

func (*PublishResponse) Reset 

func (m *PublishResponse) Reset()

func (*PublishResponse) Size 

func (m *PublishResponse) Size() (n int)

func (*PublishResponse) String 

func (m *PublishResponse) String() string

func (*PublishResponse) Unmarshal 

func (m *PublishResponse) Unmarshal(dAtA []byte) error

func (*PublishResponse) XXX_DiscardUnknown 

func (m *PublishResponse) XXX_DiscardUnknown()

func (*PublishResponse) XXX_Marshal 

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

func (*PublishResponse) XXX_Merge 

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

func (*PublishResponse) XXX_Size 

func (m *PublishResponse) XXX_Size() int

func (*PublishResponse) XXX_Unmarshal 

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

type RelatedAddress 

type RelatedAddress struct {
	Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	Port    int32  `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"`
}

The Related Address conveys transport addresses related to the candidate, useful for diagnostics and other purposes. See: https://datatracker.ietf.org/doc/html/rfc8839#section-5.1

func (*RelatedAddress) Descriptor 

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

func (*RelatedAddress) GetAddress 

func (m *RelatedAddress) GetAddress() string

func (*RelatedAddress) GetPort 

func (m *RelatedAddress) GetPort() int32

func (*RelatedAddress) Marshal 

func (m *RelatedAddress) Marshal() (dAtA []byte, err error)

func (*RelatedAddress) MarshalTo 

func (m *RelatedAddress) MarshalTo(dAtA []byte) (int, error)

func (*RelatedAddress) MarshalToSizedBuffer 

func (m *RelatedAddress) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RelatedAddress) ProtoMessage 

func (*RelatedAddress) ProtoMessage()

func (*RelatedAddress) Reset 

func (m *RelatedAddress) Reset()

func (*RelatedAddress) Size 

func (m *RelatedAddress) Size() (n int)

func (*RelatedAddress) String 

func (m *RelatedAddress) String() string

func (*RelatedAddress) Unmarshal 

func (m *RelatedAddress) Unmarshal(dAtA []byte) error

func (*RelatedAddress) XXX_DiscardUnknown 

func (m *RelatedAddress) XXX_DiscardUnknown()

func (*RelatedAddress) XXX_Marshal 

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

func (*RelatedAddress) XXX_Merge 

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

func (*RelatedAddress) XXX_Size 

func (m *RelatedAddress) XXX_Size() int

func (*RelatedAddress) XXX_Unmarshal 

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

type RelayProtocol 

type RelayProtocol int32
const (
	RelayProtocol_UNSPECIFIED_RELAY_PROTOCOL RelayProtocol = 0
	RelayProtocol_UDP                        RelayProtocol = 1
	RelayProtocol_TCP                        RelayProtocol = 2
	RelayProtocol_TLS                        RelayProtocol = 3
	RelayProtocol_DTLS                       RelayProtocol = 4
)

func NewProtocol 

func NewProtocol(rp string) RelayProtocol

func (RelayProtocol) EnumDescriptor 

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

func (RelayProtocol) String 

func (x RelayProtocol) String() string

func (RelayProtocol) ToString 

func (p RelayProtocol) ToString() string

type SignalingClient 

type SignalingClient interface {
	Publish(ctx context.Context, in *PublishRequest, opts ...grpc.CallOption) (*PublishResponse, error)
	Subscribe(ctx context.Context, in *SubscribeRequest, opts ...grpc.CallOption) (Signaling_SubscribeClient, error)
}

SignalingClient is the client API for Signaling 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 NewSignalingClient 

func NewSignalingClient(cc grpc.ClientConnInterface) SignalingClient

type SignalingServer 

type SignalingServer interface {
	Publish(context.Context, *PublishRequest) (*PublishResponse, error)
	Subscribe(*SubscribeRequest, Signaling_SubscribeServer) error
}

SignalingServer is the server API for Signaling service. All implementations should embed UnimplementedSignalingServer for forward compatibility

type Signaling_SubscribeClient 

type Signaling_SubscribeClient interface {
	Recv() (*Message, error)
	grpc.ClientStream
}

type Signaling_SubscribeServer 

type Signaling_SubscribeServer interface {
	Send(*Message) error
	grpc.ServerStream
}

type SubscribeRequest 

type SubscribeRequest struct {
	Topic    string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	Hostname string `protobuf:"bytes,2,opt,name=hostname,proto3" json:"hostname,omitempty"`
}

func (*SubscribeRequest) Descriptor 

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

func (*SubscribeRequest) GetHostname 

func (m *SubscribeRequest) GetHostname() string

func (*SubscribeRequest) GetTopic 

func (m *SubscribeRequest) GetTopic() string

func (*SubscribeRequest) Marshal 

func (m *SubscribeRequest) Marshal() (dAtA []byte, err error)

func (*SubscribeRequest) MarshalTo 

func (m *SubscribeRequest) MarshalTo(dAtA []byte) (int, error)

func (*SubscribeRequest) MarshalToSizedBuffer 

func (m *SubscribeRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SubscribeRequest) ProtoMessage 

func (*SubscribeRequest) ProtoMessage()

func (*SubscribeRequest) Reset 

func (m *SubscribeRequest) Reset()

func (*SubscribeRequest) Size 

func (m *SubscribeRequest) Size() (n int)

func (*SubscribeRequest) String 

func (m *SubscribeRequest) String() string

func (*SubscribeRequest) Unmarshal 

func (m *SubscribeRequest) Unmarshal(dAtA []byte) error

func (*SubscribeRequest) XXX_DiscardUnknown 

func (m *SubscribeRequest) XXX_DiscardUnknown()

func (*SubscribeRequest) XXX_Marshal 

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

func (*SubscribeRequest) XXX_Merge 

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

func (*SubscribeRequest) XXX_Size 

func (m *SubscribeRequest) XXX_Size() int

func (*SubscribeRequest) XXX_Unmarshal 

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

type TCPType 

type TCPType int32

Type of TCP candidate See: https://datatracker.ietf.org/doc/html/rfc6544 

const (
	TCPType_UNSPECIFIED_TCP_TYPE TCPType = 0
	// ACTIVE 主动发起连接
	TCPType_ACTIVE TCPType = 1
	// PASSIVE 监听传入连接
	TCPType_PASSIVE TCPType = 2
	// SIMULTANEOUS_OPEN 同时打开，允许双方同时发起连接
	TCPType_SIMULTANEOUS_OPEN TCPType = 3
)

func (TCPType) EnumDescriptor 

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

func (TCPType) String 

func (x TCPType) String() string

type UnimplementedSignalingServer 

type UnimplementedSignalingServer struct {
}

UnimplementedSignalingServer should be embedded to have forward compatible implementations.

func (UnimplementedSignalingServer) Publish 

func (UnimplementedSignalingServer) Publish(context.Context, *PublishRequest) (*PublishResponse, error)

func (UnimplementedSignalingServer) Subscribe 

func (UnimplementedSignalingServer) Subscribe(*SubscribeRequest, Signaling_SubscribeServer) error

type UnsafeSignalingServer 

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

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

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.