signaling_rpc

Jun 5, 2024

Changes in this version

type SessionMsg

+ func NewSessionMsg(privKey crypto.PrivKey, hashType hash.HashType, msg []byte, seqno uint64) (*SessionMsg, error)

+ func (m *SessionMsg) ExtractAndVerify() (crypto.PubKey, peer.ID, error)

May 3, 2024

Changes in this version

type ListenResponse_ClearPeer

+ func (m *ListenResponse_ClearPeer) CloneOneofVT() isListenResponse_Body

type ListenResponse_SetPeer

+ func (m *ListenResponse_SetPeer) CloneOneofVT() isListenResponse_Body

type SessionRequest_AckMsg

+ func (m *SessionRequest_AckMsg) CloneOneofVT() isSessionRequest_Body

type SessionRequest_ClearMsg

+ func (m *SessionRequest_ClearMsg) CloneOneofVT() isSessionRequest_Body

type SessionRequest_Init

+ func (m *SessionRequest_Init) CloneOneofVT() isSessionRequest_Body

type SessionRequest_SendMsg

+ func (m *SessionRequest_SendMsg) CloneOneofVT() isSessionRequest_Body

type SessionResponse_AckMsg

+ func (m *SessionResponse_AckMsg) CloneOneofVT() isSessionResponse_Body

type SessionResponse_ClearMsg

+ func (m *SessionResponse_ClearMsg) CloneOneofVT() isSessionResponse_Body

type SessionResponse_Closed

+ func (m *SessionResponse_Closed) CloneOneofVT() isSessionResponse_Body

type SessionResponse_Opened

+ func (m *SessionResponse_Opened) CloneOneofVT() isSessionResponse_Body

type SessionResponse_RecvMsg

+ func (m *SessionResponse_RecvMsg) CloneOneofVT() isSessionResponse_Body

Apr 22, 2024

Changes in this version

type ListenRequest

+ func (x *ListenRequest) MarshalProtoText() string

type ListenResponse

+ func (x *ListenResponse) MarshalProtoText() string

type SessionInit

+ func (x *SessionInit) MarshalProtoText() string

type SessionMsg

+ func (x *SessionMsg) MarshalProtoText() string

type SessionRequest

+ func (x *SessionRequest) MarshalProtoText() string

type SessionResponse

+ func (x *SessionResponse) MarshalProtoText() string

Apr 22, 2024

Changes in this version

type ListenRequest

+ func (x *ListenRequest) MarshalJSON() ([]byte, error)

+ func (x *ListenRequest) MarshalProtoJSON(s *json.MarshalState)

+ func (x *ListenRequest) UnmarshalJSON(b []byte) error

+ func (x *ListenRequest) UnmarshalProtoJSON(s *json.UnmarshalState)

type ListenResponse

+ func (x *ListenResponse) MarshalJSON() ([]byte, error)

+ func (x *ListenResponse) MarshalProtoJSON(s *json.MarshalState)

+ func (x *ListenResponse) UnmarshalJSON(b []byte) error

+ func (x *ListenResponse) UnmarshalProtoJSON(s *json.UnmarshalState)

type SessionInit

+ func (x *SessionInit) MarshalJSON() ([]byte, error)

+ func (x *SessionInit) MarshalProtoJSON(s *json.MarshalState)

+ func (x *SessionInit) UnmarshalJSON(b []byte) error

+ func (x *SessionInit) UnmarshalProtoJSON(s *json.UnmarshalState)

type SessionMsg

+ func (x *SessionMsg) MarshalJSON() ([]byte, error)

+ func (x *SessionMsg) MarshalProtoJSON(s *json.MarshalState)

+ func (x *SessionMsg) UnmarshalJSON(b []byte) error

+ func (x *SessionMsg) UnmarshalProtoJSON(s *json.UnmarshalState)

type SessionRequest

+ func (x *SessionRequest) MarshalJSON() ([]byte, error)

+ func (x *SessionRequest) MarshalProtoJSON(s *json.MarshalState)

+ func (x *SessionRequest) UnmarshalJSON(b []byte) error

+ func (x *SessionRequest) UnmarshalProtoJSON(s *json.UnmarshalState)

type SessionResponse

+ func (x *SessionResponse) MarshalJSON() ([]byte, error)

+ func (x *SessionResponse) MarshalProtoJSON(s *json.MarshalState)

+ func (x *SessionResponse) UnmarshalJSON(b []byte) error

+ func (x *SessionResponse) UnmarshalProtoJSON(s *json.UnmarshalState)

Mar 9, 2024

Changes in this version

type SRPCSignaling_SessionStream

+ RecvTo func(*SessionRequest) error

Jan 25, 2024

Changes in this version

+ const SRPCSignalingServiceID

+ var ErrIntOverflow = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLength = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrUnexpectedEndOfGroup = fmt.Errorf("proto: unexpected end of group")

+ var ErrUnexpectedSessionMsg = errors.New("signaling: unexpected session message")

+ var ErrUserpedListen = errors.New("signaling: listen can only be called once per peer")

+ var ErrUserpedSession = errors.New("signaling: session can only be called once per peer")

+ var File_github_com_aperturerobotics_bifrost_signaling_rpc_signaling_proto protoreflect.FileDescriptor

+ var ProtocolID = protocol.ID("bifrost/signaling")

+ func DRPCRegisterSignaling(mux drpc.Mux, impl DRPCSignalingServer) error

+ func NewSRPCSignalingHandler(impl SRPCSignalingServer, serviceID string) srpc.Handler

+ func SRPCRegisterSignaling(mux srpc.Mux, impl SRPCSignalingServer) error

+ type DRPCSignalingClient interface

+ DRPCConn func() drpc.Conn

+ Listen func(ctx context.Context, in *ListenRequest) (DRPCSignaling_ListenClient, error)

+ Session func(ctx context.Context) (DRPCSignaling_SessionClient, error)

+ func NewDRPCSignalingClient(cc drpc.Conn) DRPCSignalingClient

+ type DRPCSignalingDescription struct

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

+ func (DRPCSignalingDescription) NumMethods() int

+ type DRPCSignalingServer interface

+ Listen func(*ListenRequest, DRPCSignaling_ListenStream) error

+ Session func(DRPCSignaling_SessionStream) error

+ type DRPCSignalingUnimplementedServer struct

+ func (s *DRPCSignalingUnimplementedServer) Listen(*ListenRequest, DRPCSignaling_ListenStream) error

+ func (s *DRPCSignalingUnimplementedServer) Session(DRPCSignaling_SessionStream) error

+ type DRPCSignaling_ListenClient interface

+ Recv func() (*ListenResponse, error)

+ type DRPCSignaling_ListenStream interface

+ Send func(*ListenResponse) error

+ type DRPCSignaling_SessionClient interface

+ Recv func() (*SessionResponse, error)

+ Send func(*SessionRequest) error

+ type DRPCSignaling_SessionStream interface

+ Recv func() (*SessionRequest, error)

+ Send func(*SessionResponse) error

+ type ListenRequest struct

+ func (*ListenRequest) Descriptor() ([]byte, []int)

+ func (*ListenRequest) ProtoMessage()

+ func (m *ListenRequest) CloneMessageVT() proto.Message

+ func (m *ListenRequest) CloneVT() *ListenRequest

+ func (m *ListenRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *ListenRequest) MarshalToVT(dAtA []byte) (int, error)

+ func (m *ListenRequest) MarshalVT() (dAtA []byte, err error)

+ func (m *ListenRequest) SizeVT() (n int)

+ func (m *ListenRequest) UnmarshalVT(dAtA []byte) error

+ func (r *ListenRequest) Validate() error

+ func (this *ListenRequest) EqualMessageVT(thatMsg proto.Message) bool

+ func (this *ListenRequest) EqualVT(that *ListenRequest) bool

+ func (x *ListenRequest) ProtoReflect() protoreflect.Message

+ func (x *ListenRequest) Reset()

+ func (x *ListenRequest) String() string

+ type ListenResponse struct

+ Body isListenResponse_Body

+ func (*ListenResponse) Descriptor() ([]byte, []int)

+ func (*ListenResponse) ProtoMessage()

+ func (m *ListenResponse) CloneMessageVT() proto.Message

+ func (m *ListenResponse) CloneVT() *ListenResponse

+ func (m *ListenResponse) GetBody() isListenResponse_Body

+ func (m *ListenResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *ListenResponse) MarshalToVT(dAtA []byte) (int, error)

+ func (m *ListenResponse) MarshalVT() (dAtA []byte, err error)

+ func (m *ListenResponse) SizeVT() (n int)

+ func (m *ListenResponse) UnmarshalVT(dAtA []byte) error

+ func (this *ListenResponse) EqualMessageVT(thatMsg proto.Message) bool

+ func (this *ListenResponse) EqualVT(that *ListenResponse) bool

+ func (x *ListenResponse) GetClearPeer() string

+ func (x *ListenResponse) GetSetPeer() string

+ func (x *ListenResponse) ProtoReflect() protoreflect.Message

+ func (x *ListenResponse) Reset()

+ func (x *ListenResponse) String() string

+ type ListenResponse_ClearPeer struct

+ ClearPeer string

+ func (m *ListenResponse_ClearPeer) CloneVT() isListenResponse_Body

+ func (m *ListenResponse_ClearPeer) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *ListenResponse_ClearPeer) MarshalToVT(dAtA []byte) (int, error)

+ func (m *ListenResponse_ClearPeer) SizeVT() (n int)

+ func (this *ListenResponse_ClearPeer) EqualVT(thatIface isListenResponse_Body) bool

+ type ListenResponse_SetPeer struct

+ SetPeer string

+ func (m *ListenResponse_SetPeer) CloneVT() isListenResponse_Body

+ func (m *ListenResponse_SetPeer) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *ListenResponse_SetPeer) MarshalToVT(dAtA []byte) (int, error)

+ func (m *ListenResponse_SetPeer) SizeVT() (n int)

+ func (this *ListenResponse_SetPeer) EqualVT(thatIface isListenResponse_Body) bool

+ type SRPCSignalingClient interface

+ Listen func(ctx context.Context, in *ListenRequest) (SRPCSignaling_ListenClient, error)

+ SRPCClient func() srpc.Client

+ Session func(ctx context.Context) (SRPCSignaling_SessionClient, error)

+ func NewSRPCSignalingClient(cc srpc.Client) SRPCSignalingClient

+ func NewSRPCSignalingClientWithServiceID(cc srpc.Client, serviceID string) SRPCSignalingClient

+ type SRPCSignalingHandler struct

+ func (SRPCSignalingHandler) GetMethodIDs() []string

+ func (SRPCSignalingHandler) InvokeMethod_Listen(impl SRPCSignalingServer, strm srpc.Stream) error

+ func (SRPCSignalingHandler) InvokeMethod_Session(impl SRPCSignalingServer, strm srpc.Stream) error

+ func (d *SRPCSignalingHandler) GetServiceID() string

+ func (d *SRPCSignalingHandler) InvokeMethod(serviceID, methodID string, strm srpc.Stream) (bool, error)

+ type SRPCSignalingServer interface

+ Listen func(*ListenRequest, SRPCSignaling_ListenStream) error

+ Session func(SRPCSignaling_SessionStream) error

+ type SRPCSignalingUnimplementedServer struct

+ func (s *SRPCSignalingUnimplementedServer) Listen(*ListenRequest, SRPCSignaling_ListenStream) error

+ func (s *SRPCSignalingUnimplementedServer) Session(SRPCSignaling_SessionStream) error

+ type SRPCSignaling_ListenClient interface

+ Recv func() (*ListenResponse, error)

+ RecvTo func(*ListenResponse) error

+ type SRPCSignaling_ListenStream interface

+ Send func(*ListenResponse) error

+ SendAndClose func(*ListenResponse) error

+ type SRPCSignaling_SessionClient interface

+ Recv func() (*SessionResponse, error)

+ RecvTo func(*SessionResponse) error

+ Send func(*SessionRequest) error

+ type SRPCSignaling_SessionStream interface

+ Recv func() (*SessionRequest, error)

+ Send func(*SessionResponse) error

+ SendAndClose func(*SessionResponse) error

+ type SessionInit struct

+ PeerId string

+ func (*SessionInit) Descriptor() ([]byte, []int)

+ func (*SessionInit) ProtoMessage()

+ func (i *SessionInit) Validate() error

+ func (m *SessionInit) CloneMessageVT() proto.Message

+ func (m *SessionInit) CloneVT() *SessionInit

+ func (m *SessionInit) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *SessionInit) MarshalToVT(dAtA []byte) (int, error)

+ func (m *SessionInit) MarshalVT() (dAtA []byte, err error)

+ func (m *SessionInit) SizeVT() (n int)

+ func (m *SessionInit) UnmarshalVT(dAtA []byte) error

+ func (s *SessionInit) ParsePeerID() (peer.ID, error)

+ func (this *SessionInit) EqualMessageVT(thatMsg proto.Message) bool

+ func (this *SessionInit) EqualVT(that *SessionInit) bool

+ func (x *SessionInit) GetPeerId() string

+ func (x *SessionInit) ProtoReflect() protoreflect.Message

+ func (x *SessionInit) Reset()

+ func (x *SessionInit) String() string

+ type SessionMsg struct

+ Seqno uint64

+ SignedMsg *peer.SignedMsg

+ func (*SessionMsg) Descriptor() ([]byte, []int)

+ func (*SessionMsg) ProtoMessage()

+ func (m *SessionMsg) CloneMessageVT() proto.Message

+ func (m *SessionMsg) CloneVT() *SessionMsg

+ func (m *SessionMsg) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *SessionMsg) MarshalToVT(dAtA []byte) (int, error)

+ func (m *SessionMsg) MarshalVT() (dAtA []byte, err error)

+ func (m *SessionMsg) SizeVT() (n int)

+ func (m *SessionMsg) UnmarshalVT(dAtA []byte) error

+ func (m *SessionMsg) Validate() error

+ func (this *SessionMsg) EqualMessageVT(thatMsg proto.Message) bool

+ func (this *SessionMsg) EqualVT(that *SessionMsg) bool

+ func (x *SessionMsg) GetSeqno() uint64

+ func (x *SessionMsg) GetSignedMsg() *peer.SignedMsg

+ func (x *SessionMsg) ProtoReflect() protoreflect.Message

+ func (x *SessionMsg) Reset()

+ func (x *SessionMsg) String() string

+ type SessionRequest struct

+ Body isSessionRequest_Body

+ SessionSeqno uint64

+ func (*SessionRequest) Descriptor() ([]byte, []int)

+ func (*SessionRequest) ProtoMessage()

+ func (m *SessionRequest) CloneMessageVT() proto.Message

+ func (m *SessionRequest) CloneVT() *SessionRequest

+ func (m *SessionRequest) GetBody() isSessionRequest_Body

+ func (m *SessionRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *SessionRequest) MarshalToVT(dAtA []byte) (int, error)

+ func (m *SessionRequest) MarshalVT() (dAtA []byte, err error)

+ func (m *SessionRequest) SizeVT() (n int)

+ func (m *SessionRequest) UnmarshalVT(dAtA []byte) error

+ func (r *SessionRequest) Validate() error

+ func (this *SessionRequest) EqualMessageVT(thatMsg proto.Message) bool

+ func (this *SessionRequest) EqualVT(that *SessionRequest) bool

+ func (x *SessionRequest) GetAckMsg() uint64

+ func (x *SessionRequest) GetClearMsg() uint64

+ func (x *SessionRequest) GetInit() *SessionInit

+ func (x *SessionRequest) GetSendMsg() *SessionMsg

+ func (x *SessionRequest) GetSessionSeqno() uint64

+ func (x *SessionRequest) ProtoReflect() protoreflect.Message

+ func (x *SessionRequest) Reset()

+ func (x *SessionRequest) String() string

+ type SessionRequest_AckMsg struct

+ AckMsg uint64

+ func (m *SessionRequest_AckMsg) CloneVT() isSessionRequest_Body

+ func (m *SessionRequest_AckMsg) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *SessionRequest_AckMsg) MarshalToVT(dAtA []byte) (int, error)

+ func (m *SessionRequest_AckMsg) SizeVT() (n int)

+ func (this *SessionRequest_AckMsg) EqualVT(thatIface isSessionRequest_Body) bool

+ type SessionRequest_ClearMsg struct

+ ClearMsg uint64

+ func (m *SessionRequest_ClearMsg) CloneVT() isSessionRequest_Body

+ func (m *SessionRequest_ClearMsg) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *SessionRequest_ClearMsg) MarshalToVT(dAtA []byte) (int, error)

+ func (m *SessionRequest_ClearMsg) SizeVT() (n int)

+ func (this *SessionRequest_ClearMsg) EqualVT(thatIface isSessionRequest_Body) bool

+ type SessionRequest_Init struct

+ Init *SessionInit

+ func (m *SessionRequest_Init) CloneVT() isSessionRequest_Body

+ func (m *SessionRequest_Init) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *SessionRequest_Init) MarshalToVT(dAtA []byte) (int, error)

+ func (m *SessionRequest_Init) SizeVT() (n int)

+ func (this *SessionRequest_Init) EqualVT(thatIface isSessionRequest_Body) bool

+ type SessionRequest_SendMsg struct

+ SendMsg *SessionMsg

+ func (m *SessionRequest_SendMsg) CloneVT() isSessionRequest_Body

+ func (m *SessionRequest_SendMsg) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *SessionRequest_SendMsg) MarshalToVT(dAtA []byte) (int, error)

+ func (m *SessionRequest_SendMsg) SizeVT() (n int)

+ func (this *SessionRequest_SendMsg) EqualVT(thatIface isSessionRequest_Body) bool

+ type SessionResponse struct

+ Body isSessionResponse_Body

+ func (*SessionResponse) Descriptor() ([]byte, []int)

+ func (*SessionResponse) ProtoMessage()

+ func (m *SessionResponse) CloneMessageVT() proto.Message

+ func (m *SessionResponse) CloneVT() *SessionResponse

+ func (m *SessionResponse) GetBody() isSessionResponse_Body

+ func (m *SessionResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *SessionResponse) MarshalToVT(dAtA []byte) (int, error)

+ func (m *SessionResponse) MarshalVT() (dAtA []byte, err error)

+ func (m *SessionResponse) SizeVT() (n int)

+ func (m *SessionResponse) UnmarshalVT(dAtA []byte) error

+ func (r *SessionResponse) Validate() error

+ func (this *SessionResponse) EqualMessageVT(thatMsg proto.Message) bool

+ func (this *SessionResponse) EqualVT(that *SessionResponse) bool

+ func (x *SessionResponse) GetAckMsg() uint64

+ func (x *SessionResponse) GetClearMsg() uint64

+ func (x *SessionResponse) GetClosed() bool

+ func (x *SessionResponse) GetOpened() uint64

+ func (x *SessionResponse) GetRecvMsg() *SessionMsg

+ func (x *SessionResponse) ProtoReflect() protoreflect.Message

+ func (x *SessionResponse) Reset()

+ func (x *SessionResponse) String() string

+ type SessionResponse_AckMsg struct

+ AckMsg uint64

+ func (m *SessionResponse_AckMsg) CloneVT() isSessionResponse_Body

+ func (m *SessionResponse_AckMsg) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *SessionResponse_AckMsg) MarshalToVT(dAtA []byte) (int, error)

+ func (m *SessionResponse_AckMsg) SizeVT() (n int)

+ func (this *SessionResponse_AckMsg) EqualVT(thatIface isSessionResponse_Body) bool

+ type SessionResponse_ClearMsg struct

+ ClearMsg uint64

+ func (m *SessionResponse_ClearMsg) CloneVT() isSessionResponse_Body

+ func (m *SessionResponse_ClearMsg) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *SessionResponse_ClearMsg) MarshalToVT(dAtA []byte) (int, error)

+ func (m *SessionResponse_ClearMsg) SizeVT() (n int)

+ func (this *SessionResponse_ClearMsg) EqualVT(thatIface isSessionResponse_Body) bool

+ type SessionResponse_Closed struct

+ Closed bool

+ func (m *SessionResponse_Closed) CloneVT() isSessionResponse_Body

+ func (m *SessionResponse_Closed) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *SessionResponse_Closed) MarshalToVT(dAtA []byte) (int, error)

+ func (m *SessionResponse_Closed) SizeVT() (n int)

+ func (this *SessionResponse_Closed) EqualVT(thatIface isSessionResponse_Body) bool

+ type SessionResponse_Opened struct

+ Opened uint64

+ func (m *SessionResponse_Opened) CloneVT() isSessionResponse_Body

+ func (m *SessionResponse_Opened) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *SessionResponse_Opened) MarshalToVT(dAtA []byte) (int, error)

+ func (m *SessionResponse_Opened) SizeVT() (n int)

+ func (this *SessionResponse_Opened) EqualVT(thatIface isSessionResponse_Body) bool

+ type SessionResponse_RecvMsg struct

+ RecvMsg *SessionMsg

+ func (m *SessionResponse_RecvMsg) CloneVT() isSessionResponse_Body

+ func (m *SessionResponse_RecvMsg) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *SessionResponse_RecvMsg) MarshalToVT(dAtA []byte) (int, error)

+ func (m *SessionResponse_RecvMsg) SizeVT() (n int)

+ func (this *SessionResponse_RecvMsg) EqualVT(thatIface isSessionResponse_Body) bool