proto

Documentation

Index

• Variables
• func DRPCRegisterPeerBroker(mux drpc.Mux, impl DRPCPeerBrokerServer) error
• type DRPCPeerBrokerClient
  • func NewDRPCPeerBrokerClient(cc drpc.Conn) DRPCPeerBrokerClient
• type DRPCPeerBrokerDescription
  • func (DRPCPeerBrokerDescription) Method(n int) (string, drpc.Encoding, drpc.Receiver, interface{}, bool)
  • func (DRPCPeerBrokerDescription) NumMethods() int
• type DRPCPeerBrokerServer
• type DRPCPeerBrokerUnimplementedServer
  • func (s *DRPCPeerBrokerUnimplementedServer) NegotiateConnection(DRPCPeerBroker_NegotiateConnectionStream) error
• type DRPCPeerBroker_NegotiateConnectionClient
• type DRPCPeerBroker_NegotiateConnectionStream
• type Exchange
  • func (*Exchange) Descriptor() ([]byte, []int)
  • func (x *Exchange) GetIceCandidate() string
  • func (m *Exchange) GetMessage() isExchange_Message
  • func (x *Exchange) GetSdp() *WebRTCSessionDescription
  • func (*Exchange) ProtoMessage()
  • func (x *Exchange) ProtoReflect() protoreflect.Message
  • func (x *Exchange) Reset()
  • func (x *Exchange) String() string
• type Exchange_IceCandidate
• type Exchange_Sdp
• type WebRTCSessionDescription
  • func (*WebRTCSessionDescription) Descriptor() ([]byte, []int)
  • func (x *WebRTCSessionDescription) GetSdp() string
  • func (x *WebRTCSessionDescription) GetSdpType() int32
  • func (*WebRTCSessionDescription) ProtoMessage()
  • func (x *WebRTCSessionDescription) ProtoReflect() protoreflect.Message
  • func (x *WebRTCSessionDescription) Reset()
  • func (x *WebRTCSessionDescription) String() string

Variables

var File_peerbroker_proto_peerbroker_proto protoreflect.FileDescriptor

Functions

func DRPCRegisterPeerBroker

func DRPCRegisterPeerBroker(mux drpc.Mux, impl DRPCPeerBrokerServer) error

Types

type DRPCPeerBrokerClient

type DRPCPeerBrokerClient interface {
	DRPCConn() drpc.Conn

	NegotiateConnection(ctx context.Context) (DRPCPeerBroker_NegotiateConnectionClient, error)
}

func NewDRPCPeerBrokerClient

func NewDRPCPeerBrokerClient(cc drpc.Conn) DRPCPeerBrokerClient

type DRPCPeerBrokerDescription

type DRPCPeerBrokerDescription struct{}

func (DRPCPeerBrokerDescription) Method

func (DRPCPeerBrokerDescription) Method(n int) (string, drpc.Encoding, drpc.Receiver, interface{}, bool)

func (DRPCPeerBrokerDescription) NumMethods

func (DRPCPeerBrokerDescription) NumMethods() int

type DRPCPeerBrokerServer

type DRPCPeerBrokerServer interface {
	NegotiateConnection(DRPCPeerBroker_NegotiateConnectionStream) error
}

type DRPCPeerBrokerUnimplementedServer

type DRPCPeerBrokerUnimplementedServer struct{}

func (*DRPCPeerBrokerUnimplementedServer) NegotiateConnection

func (s *DRPCPeerBrokerUnimplementedServer) NegotiateConnection(DRPCPeerBroker_NegotiateConnectionStream) error

type DRPCPeerBroker_NegotiateConnectionClient

type DRPCPeerBroker_NegotiateConnectionClient interface {
	drpc.Stream
	Send(*Exchange) error
	Recv() (*Exchange, error)
}

type DRPCPeerBroker_NegotiateConnectionStream

type DRPCPeerBroker_NegotiateConnectionStream interface {
	drpc.Stream
	Send(*Exchange) error
	Recv() (*Exchange, error)
}

type Exchange

type Exchange struct {

	// Types that are assignable to Message:
	//	*Exchange_Sdp
	//	*Exchange_IceCandidate
	Message isExchange_Message `protobuf_oneof:"message"`
	// contains filtered or unexported fields
}

func (*Exchange) Descriptor

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

Deprecated: Use Exchange.ProtoReflect.Descriptor instead.

func (*Exchange) GetIceCandidate

func (x *Exchange) GetIceCandidate() string

func (*Exchange) GetMessage

func (m *Exchange) GetMessage() isExchange_Message

func (*Exchange) GetSdp

func (x *Exchange) GetSdp() *WebRTCSessionDescription

func (*Exchange) ProtoMessage

func (*Exchange) ProtoMessage()

func (*Exchange) ProtoReflect

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

func (*Exchange) Reset

func (x *Exchange) Reset()

func (*Exchange) String

func (x *Exchange) String() string

type Exchange_IceCandidate

type Exchange_IceCandidate struct {
	IceCandidate string `protobuf:"bytes,2,opt,name=ice_candidate,json=iceCandidate,proto3,oneof"`
}

type Exchange_Sdp

type Exchange_Sdp struct {
	Sdp *WebRTCSessionDescription `protobuf:"bytes,1,opt,name=sdp,proto3,oneof"`
}

type WebRTCSessionDescription

type WebRTCSessionDescription struct {
	SdpType int32  `protobuf:"varint,1,opt,name=sdp_type,json=sdpType,proto3" json:"sdp_type,omitempty"`
	Sdp     string `protobuf:"bytes,2,opt,name=sdp,proto3" json:"sdp,omitempty"`
	// contains filtered or unexported fields
}

func (*WebRTCSessionDescription) Descriptor

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

Deprecated: Use WebRTCSessionDescription.ProtoReflect.Descriptor instead.

func (*WebRTCSessionDescription) GetSdp

func (x *WebRTCSessionDescription) GetSdp() string

func (*WebRTCSessionDescription) GetSdpType

func (x *WebRTCSessionDescription) GetSdpType() int32

func (*WebRTCSessionDescription) ProtoMessage

func (*WebRTCSessionDescription) ProtoMessage()

func (*WebRTCSessionDescription) ProtoReflect

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

func (*WebRTCSessionDescription) Reset

func (x *WebRTCSessionDescription) Reset()

func (*WebRTCSessionDescription) String

func (x *WebRTCSessionDescription) String() string