stream_api

package
v0.12.5 Latest Latest
Warning

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

Go to latest
Published: Apr 1, 2023 License: Apache-2.0 Imports: 20 Imported by: 0

Documentation

Index

Constants

View Source
const SRPCStreamServiceServiceID = "stream.api.StreamService"

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_github_com_aperturerobotics_bifrost_stream_api_api_proto protoreflect.FileDescriptor

Functions

func DRPCRegisterStreamService

func DRPCRegisterStreamService(mux drpc.Mux, impl DRPCStreamServiceServer) error

func NewAcceptServerRPC

func NewAcceptServerRPC(
	serv SRPCStreamService_AcceptStreamStream,
) stream_api_rpc.RPC

NewAcceptServerRPC constructs a new AcceptServerRPC.

func NewAcceptStreamClientRPC

func NewAcceptStreamClientRPC(
	client SRPCStreamService_AcceptStreamClient,
) stream_api_rpc.RPC

NewAcceptStreamClientRPC builds a new AcceptStreamClient.

func NewDialServerRPC

func NewDialServerRPC(
	serv SRPCStreamService_DialStreamStream,
) stream_api_rpc.RPC

NewDialServerRPC builds a new DialServerRPC.

func NewDialStreamClientRPC

func NewDialStreamClientRPC(
	client SRPCStreamService_DialStreamClient,
) stream_api_rpc.RPC

NewDialStreamClientRPC builds a new DialStreamClientRPC.

func NewSRPCStreamServiceHandler added in v0.7.2

func NewSRPCStreamServiceHandler(impl SRPCStreamServiceServer, serviceID string) srpc.Handler

NewSRPCStreamServiceHandler constructs a new RPC handler. serviceID: if empty, uses default: stream.api.StreamService

func SRPCRegisterStreamService added in v0.3.0

func SRPCRegisterStreamService(mux srpc.Mux, impl SRPCStreamServiceServer) error

SRPCRegisterStreamService registers the implementation with the mux. Uses the default serviceID: stream.api.StreamService

Types

type AcceptServerRPC

type AcceptServerRPC struct {
	SRPCStreamService_AcceptStreamStream
}

AcceptServerRPC fulfills rpc accept streams on the server.

func (*AcceptServerRPC) Recv

func (r *AcceptServerRPC) Recv() (*stream_api_rpc.Data, error)

Recv receives a packet.

func (*AcceptServerRPC) Send

func (r *AcceptServerRPC) Send(resp *stream_api_rpc.Data) error

Send sends a packet.

type AcceptStreamClientRPC

type AcceptStreamClientRPC struct {
	SRPCStreamService_AcceptStreamClient
}

AcceptStreamClientRPC fulfills the RPC on the client side.

func (*AcceptStreamClientRPC) Recv

Recv receives a packet.

func (*AcceptStreamClientRPC) Send

Send sends a packet.

type AcceptStreamRequest

type AcceptStreamRequest struct {

	// Config is the configuration for the accept.
	// The first packet will contain this value.
	Config *accept.Config `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"`
	// Data is a data packet.
	Data *rpc.Data `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

AcceptStreamRequest is the request type for AcceptStream.

func (*AcceptStreamRequest) CloneGenericVT added in v0.8.3

func (m *AcceptStreamRequest) CloneGenericVT() proto.Message

func (*AcceptStreamRequest) CloneVT added in v0.8.3

func (*AcceptStreamRequest) Descriptor deprecated

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

Deprecated: Use AcceptStreamRequest.ProtoReflect.Descriptor instead.

func (*AcceptStreamRequest) EqualVT added in v0.3.0

func (this *AcceptStreamRequest) EqualVT(that *AcceptStreamRequest) bool

func (*AcceptStreamRequest) GetConfig

func (x *AcceptStreamRequest) GetConfig() *accept.Config

func (*AcceptStreamRequest) GetData

func (x *AcceptStreamRequest) GetData() *rpc.Data

func (*AcceptStreamRequest) MarshalToSizedBufferVT added in v0.2.0

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

func (*AcceptStreamRequest) MarshalToVT added in v0.2.0

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

func (*AcceptStreamRequest) MarshalVT added in v0.2.0

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

func (*AcceptStreamRequest) ProtoMessage

func (*AcceptStreamRequest) ProtoMessage()

func (*AcceptStreamRequest) ProtoReflect added in v0.2.0

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

func (*AcceptStreamRequest) Reset

func (x *AcceptStreamRequest) Reset()

func (*AcceptStreamRequest) SizeVT added in v0.2.0

func (m *AcceptStreamRequest) SizeVT() (n int)

func (*AcceptStreamRequest) String

func (x *AcceptStreamRequest) String() string

func (*AcceptStreamRequest) UnmarshalVT added in v0.2.0

func (m *AcceptStreamRequest) UnmarshalVT(dAtA []byte) error

type AcceptStreamResponse

type AcceptStreamResponse struct {

	// Data is a data packet.
	Data *rpc.Data `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

AcceptStreamResponse is the response type for AcceptStream.

func (*AcceptStreamResponse) CloneGenericVT added in v0.8.3

func (m *AcceptStreamResponse) CloneGenericVT() proto.Message

func (*AcceptStreamResponse) CloneVT added in v0.8.3

func (*AcceptStreamResponse) Descriptor deprecated

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

Deprecated: Use AcceptStreamResponse.ProtoReflect.Descriptor instead.

func (*AcceptStreamResponse) EqualVT added in v0.3.0

func (this *AcceptStreamResponse) EqualVT(that *AcceptStreamResponse) bool

func (*AcceptStreamResponse) GetData

func (x *AcceptStreamResponse) GetData() *rpc.Data

func (*AcceptStreamResponse) MarshalToSizedBufferVT added in v0.2.0

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

func (*AcceptStreamResponse) MarshalToVT added in v0.2.0

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

func (*AcceptStreamResponse) MarshalVT added in v0.2.0

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

func (*AcceptStreamResponse) ProtoMessage

func (*AcceptStreamResponse) ProtoMessage()

func (*AcceptStreamResponse) ProtoReflect added in v0.2.0

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

func (*AcceptStreamResponse) Reset

func (x *AcceptStreamResponse) Reset()

func (*AcceptStreamResponse) SizeVT added in v0.2.0

func (m *AcceptStreamResponse) SizeVT() (n int)

func (*AcceptStreamResponse) String

func (x *AcceptStreamResponse) String() string

func (*AcceptStreamResponse) UnmarshalVT added in v0.2.0

func (m *AcceptStreamResponse) UnmarshalVT(dAtA []byte) error

type DRPCStreamServiceDescription

type DRPCStreamServiceDescription struct{}

func (DRPCStreamServiceDescription) Method

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

func (DRPCStreamServiceDescription) NumMethods

func (DRPCStreamServiceDescription) NumMethods() int

type DRPCStreamServiceUnimplementedServer

type DRPCStreamServiceUnimplementedServer struct{}

func (*DRPCStreamServiceUnimplementedServer) AcceptStream

func (*DRPCStreamServiceUnimplementedServer) DialStream

func (*DRPCStreamServiceUnimplementedServer) ForwardStreams

func (*DRPCStreamServiceUnimplementedServer) ListenStreams

type DRPCStreamService_AcceptStreamClient

type DRPCStreamService_AcceptStreamClient interface {
	drpc.Stream
	Send(*AcceptStreamRequest) error
	Recv() (*AcceptStreamResponse, error)
}

type DRPCStreamService_AcceptStreamStream

type DRPCStreamService_AcceptStreamStream interface {
	drpc.Stream
	Send(*AcceptStreamResponse) error
	Recv() (*AcceptStreamRequest, error)
}

type DRPCStreamService_DialStreamClient

type DRPCStreamService_DialStreamClient interface {
	drpc.Stream
	Send(*DialStreamRequest) error
	Recv() (*DialStreamResponse, error)
}

type DRPCStreamService_DialStreamStream

type DRPCStreamService_DialStreamStream interface {
	drpc.Stream
	Send(*DialStreamResponse) error
	Recv() (*DialStreamRequest, error)
}

type DRPCStreamService_ForwardStreamsClient

type DRPCStreamService_ForwardStreamsClient interface {
	drpc.Stream
	Recv() (*ForwardStreamsResponse, error)
}

type DRPCStreamService_ForwardStreamsStream

type DRPCStreamService_ForwardStreamsStream interface {
	drpc.Stream
	Send(*ForwardStreamsResponse) error
}

type DRPCStreamService_ListenStreamsClient

type DRPCStreamService_ListenStreamsClient interface {
	drpc.Stream
	Recv() (*ListenStreamsResponse, error)
}

type DRPCStreamService_ListenStreamsStream

type DRPCStreamService_ListenStreamsStream interface {
	drpc.Stream
	Send(*ListenStreamsResponse) error
}

type DialServerRPC

type DialServerRPC struct {
	SRPCStreamService_DialStreamStream
}

DialServerRPC fulfills the RPC on the server side.

func (*DialServerRPC) Recv

func (r *DialServerRPC) Recv() (*stream_api_rpc.Data, error)

Recv receives a packet.

func (*DialServerRPC) Send

func (r *DialServerRPC) Send(resp *stream_api_rpc.Data) error

Send sends a packet.

type DialStreamClientRPC

type DialStreamClientRPC struct {
	SRPCStreamService_DialStreamClient
}

DialStreamClientRPC fulfills stream RPC on the client side.

func (*DialStreamClientRPC) Recv

Recv receives a packet.

func (*DialStreamClientRPC) Send

Send sends a packet.

type DialStreamRequest

type DialStreamRequest struct {

	// Config is the configuration for the dial.
	// The first packet will contain this value.
	Config *dial.Config `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"`
	// Data is a data packet.
	Data *rpc.Data `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

DialStreamRequest is the request type for DialStream.

func (*DialStreamRequest) CloneGenericVT added in v0.8.3

func (m *DialStreamRequest) CloneGenericVT() proto.Message

func (*DialStreamRequest) CloneVT added in v0.8.3

func (m *DialStreamRequest) CloneVT() *DialStreamRequest

func (*DialStreamRequest) Descriptor deprecated

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

Deprecated: Use DialStreamRequest.ProtoReflect.Descriptor instead.

func (*DialStreamRequest) EqualVT added in v0.3.0

func (this *DialStreamRequest) EqualVT(that *DialStreamRequest) bool

func (*DialStreamRequest) GetConfig

func (x *DialStreamRequest) GetConfig() *dial.Config

func (*DialStreamRequest) GetData

func (x *DialStreamRequest) GetData() *rpc.Data

func (*DialStreamRequest) MarshalToSizedBufferVT added in v0.2.0

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

func (*DialStreamRequest) MarshalToVT added in v0.2.0

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

func (*DialStreamRequest) MarshalVT added in v0.2.0

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

func (*DialStreamRequest) ProtoMessage

func (*DialStreamRequest) ProtoMessage()

func (*DialStreamRequest) ProtoReflect added in v0.2.0

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

func (*DialStreamRequest) Reset

func (x *DialStreamRequest) Reset()

func (*DialStreamRequest) SizeVT added in v0.2.0

func (m *DialStreamRequest) SizeVT() (n int)

func (*DialStreamRequest) String

func (x *DialStreamRequest) String() string

func (*DialStreamRequest) UnmarshalVT added in v0.2.0

func (m *DialStreamRequest) UnmarshalVT(dAtA []byte) error

type DialStreamResponse

type DialStreamResponse struct {

	// Data is a data packet.
	Data *rpc.Data `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

DialStreamResponse is the response type for DialStream.

func (*DialStreamResponse) CloneGenericVT added in v0.8.3

func (m *DialStreamResponse) CloneGenericVT() proto.Message

func (*DialStreamResponse) CloneVT added in v0.8.3

func (m *DialStreamResponse) CloneVT() *DialStreamResponse

func (*DialStreamResponse) Descriptor deprecated

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

Deprecated: Use DialStreamResponse.ProtoReflect.Descriptor instead.

func (*DialStreamResponse) EqualVT added in v0.3.0

func (this *DialStreamResponse) EqualVT(that *DialStreamResponse) bool

func (*DialStreamResponse) GetData

func (x *DialStreamResponse) GetData() *rpc.Data

func (*DialStreamResponse) MarshalToSizedBufferVT added in v0.2.0

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

func (*DialStreamResponse) MarshalToVT added in v0.2.0

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

func (*DialStreamResponse) MarshalVT added in v0.2.0

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

func (*DialStreamResponse) ProtoMessage

func (*DialStreamResponse) ProtoMessage()

func (*DialStreamResponse) ProtoReflect added in v0.2.0

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

func (*DialStreamResponse) Reset

func (x *DialStreamResponse) Reset()

func (*DialStreamResponse) SizeVT added in v0.2.0

func (m *DialStreamResponse) SizeVT() (n int)

func (*DialStreamResponse) String

func (x *DialStreamResponse) String() string

func (*DialStreamResponse) UnmarshalVT added in v0.2.0

func (m *DialStreamResponse) UnmarshalVT(dAtA []byte) error

type ForwardStreamsRequest

type ForwardStreamsRequest struct {
	ForwardingConfig *forwarding.Config `protobuf:"bytes,1,opt,name=forwarding_config,json=forwardingConfig,proto3" json:"forwarding_config,omitempty"`
	// contains filtered or unexported fields
}

ForwardStreamsRequest is the request type for ForwardStreams.

func (*ForwardStreamsRequest) CloneGenericVT added in v0.8.3

func (m *ForwardStreamsRequest) CloneGenericVT() proto.Message

func (*ForwardStreamsRequest) CloneVT added in v0.8.3

func (*ForwardStreamsRequest) Descriptor deprecated

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

Deprecated: Use ForwardStreamsRequest.ProtoReflect.Descriptor instead.

func (*ForwardStreamsRequest) EqualVT added in v0.3.0

func (this *ForwardStreamsRequest) EqualVT(that *ForwardStreamsRequest) bool

func (*ForwardStreamsRequest) GetForwardingConfig

func (x *ForwardStreamsRequest) GetForwardingConfig() *forwarding.Config

func (*ForwardStreamsRequest) MarshalToSizedBufferVT added in v0.2.0

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

func (*ForwardStreamsRequest) MarshalToVT added in v0.2.0

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

func (*ForwardStreamsRequest) MarshalVT added in v0.2.0

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

func (*ForwardStreamsRequest) ProtoMessage

func (*ForwardStreamsRequest) ProtoMessage()

func (*ForwardStreamsRequest) ProtoReflect added in v0.2.0

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

func (*ForwardStreamsRequest) Reset

func (x *ForwardStreamsRequest) Reset()

func (*ForwardStreamsRequest) SizeVT added in v0.2.0

func (m *ForwardStreamsRequest) SizeVT() (n int)

func (*ForwardStreamsRequest) String

func (x *ForwardStreamsRequest) String() string

func (*ForwardStreamsRequest) UnmarshalVT added in v0.2.0

func (m *ForwardStreamsRequest) UnmarshalVT(dAtA []byte) error

type ForwardStreamsResponse

type ForwardStreamsResponse struct {

	// ControllerStatus is the status of the forwarding controller.
	ControllerStatus exec.ControllerStatus `` /* 148-byte string literal not displayed */
	// contains filtered or unexported fields
}

ForwardStreamsResponse is the response type for ForwardStreams.

func (*ForwardStreamsResponse) CloneGenericVT added in v0.8.3

func (m *ForwardStreamsResponse) CloneGenericVT() proto.Message

func (*ForwardStreamsResponse) CloneVT added in v0.8.3

func (*ForwardStreamsResponse) Descriptor deprecated

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

Deprecated: Use ForwardStreamsResponse.ProtoReflect.Descriptor instead.

func (*ForwardStreamsResponse) EqualVT added in v0.3.0

func (this *ForwardStreamsResponse) EqualVT(that *ForwardStreamsResponse) bool

func (*ForwardStreamsResponse) GetControllerStatus

func (x *ForwardStreamsResponse) GetControllerStatus() exec.ControllerStatus

func (*ForwardStreamsResponse) MarshalToSizedBufferVT added in v0.2.0

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

func (*ForwardStreamsResponse) MarshalToVT added in v0.2.0

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

func (*ForwardStreamsResponse) MarshalVT added in v0.2.0

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

func (*ForwardStreamsResponse) ProtoMessage

func (*ForwardStreamsResponse) ProtoMessage()

func (*ForwardStreamsResponse) ProtoReflect added in v0.2.0

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

func (*ForwardStreamsResponse) Reset

func (x *ForwardStreamsResponse) Reset()

func (*ForwardStreamsResponse) SizeVT added in v0.2.0

func (m *ForwardStreamsResponse) SizeVT() (n int)

func (*ForwardStreamsResponse) String

func (x *ForwardStreamsResponse) String() string

func (*ForwardStreamsResponse) UnmarshalVT added in v0.2.0

func (m *ForwardStreamsResponse) UnmarshalVT(dAtA []byte) error

type ListenStreamsRequest

type ListenStreamsRequest struct {
	ListeningConfig *listening.Config `protobuf:"bytes,1,opt,name=listening_config,json=listeningConfig,proto3" json:"listening_config,omitempty"`
	// contains filtered or unexported fields
}

ListenStreamsRequest is the request type for ListenStreams.

func (*ListenStreamsRequest) CloneGenericVT added in v0.8.3

func (m *ListenStreamsRequest) CloneGenericVT() proto.Message

func (*ListenStreamsRequest) CloneVT added in v0.8.3

func (*ListenStreamsRequest) Descriptor deprecated

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

Deprecated: Use ListenStreamsRequest.ProtoReflect.Descriptor instead.

func (*ListenStreamsRequest) EqualVT added in v0.3.0

func (this *ListenStreamsRequest) EqualVT(that *ListenStreamsRequest) bool

func (*ListenStreamsRequest) GetListeningConfig

func (x *ListenStreamsRequest) GetListeningConfig() *listening.Config

func (*ListenStreamsRequest) MarshalToSizedBufferVT added in v0.2.0

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

func (*ListenStreamsRequest) MarshalToVT added in v0.2.0

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

func (*ListenStreamsRequest) MarshalVT added in v0.2.0

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

func (*ListenStreamsRequest) ProtoMessage

func (*ListenStreamsRequest) ProtoMessage()

func (*ListenStreamsRequest) ProtoReflect added in v0.2.0

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

func (*ListenStreamsRequest) Reset

func (x *ListenStreamsRequest) Reset()

func (*ListenStreamsRequest) SizeVT added in v0.2.0

func (m *ListenStreamsRequest) SizeVT() (n int)

func (*ListenStreamsRequest) String

func (x *ListenStreamsRequest) String() string

func (*ListenStreamsRequest) UnmarshalVT added in v0.2.0

func (m *ListenStreamsRequest) UnmarshalVT(dAtA []byte) error

type ListenStreamsResponse

type ListenStreamsResponse struct {

	// ControllerStatus is the status of the forwarding controller.
	ControllerStatus exec.ControllerStatus `` /* 148-byte string literal not displayed */
	// contains filtered or unexported fields
}

ListenStreamsResponse is the response type for ListenStreams.

func (*ListenStreamsResponse) CloneGenericVT added in v0.8.3

func (m *ListenStreamsResponse) CloneGenericVT() proto.Message

func (*ListenStreamsResponse) CloneVT added in v0.8.3

func (*ListenStreamsResponse) Descriptor deprecated

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

Deprecated: Use ListenStreamsResponse.ProtoReflect.Descriptor instead.

func (*ListenStreamsResponse) EqualVT added in v0.3.0

func (this *ListenStreamsResponse) EqualVT(that *ListenStreamsResponse) bool

func (*ListenStreamsResponse) GetControllerStatus

func (x *ListenStreamsResponse) GetControllerStatus() exec.ControllerStatus

func (*ListenStreamsResponse) MarshalToSizedBufferVT added in v0.2.0

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

func (*ListenStreamsResponse) MarshalToVT added in v0.2.0

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

func (*ListenStreamsResponse) MarshalVT added in v0.2.0

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

func (*ListenStreamsResponse) ProtoMessage

func (*ListenStreamsResponse) ProtoMessage()

func (*ListenStreamsResponse) ProtoReflect added in v0.2.0

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

func (*ListenStreamsResponse) Reset

func (x *ListenStreamsResponse) Reset()

func (*ListenStreamsResponse) SizeVT added in v0.2.0

func (m *ListenStreamsResponse) SizeVT() (n int)

func (*ListenStreamsResponse) String

func (x *ListenStreamsResponse) String() string

func (*ListenStreamsResponse) UnmarshalVT added in v0.2.0

func (m *ListenStreamsResponse) UnmarshalVT(dAtA []byte) error

type SRPCStreamServiceClient added in v0.3.0

func NewSRPCStreamServiceClient added in v0.3.0

func NewSRPCStreamServiceClient(cc srpc.Client) SRPCStreamServiceClient

func NewSRPCStreamServiceClientWithServiceID added in v0.7.2

func NewSRPCStreamServiceClientWithServiceID(cc srpc.Client, serviceID string) SRPCStreamServiceClient

type SRPCStreamServiceHandler added in v0.3.0

type SRPCStreamServiceHandler struct {
	// contains filtered or unexported fields
}

func (SRPCStreamServiceHandler) GetMethodIDs added in v0.3.0

func (SRPCStreamServiceHandler) GetMethodIDs() []string

func (*SRPCStreamServiceHandler) GetServiceID added in v0.3.0

func (d *SRPCStreamServiceHandler) GetServiceID() string

func (*SRPCStreamServiceHandler) InvokeMethod added in v0.3.0

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

func (SRPCStreamServiceHandler) InvokeMethod_AcceptStream added in v0.3.0

func (SRPCStreamServiceHandler) InvokeMethod_AcceptStream(impl SRPCStreamServiceServer, strm srpc.Stream) error

func (SRPCStreamServiceHandler) InvokeMethod_DialStream added in v0.3.0

func (SRPCStreamServiceHandler) InvokeMethod_DialStream(impl SRPCStreamServiceServer, strm srpc.Stream) error

func (SRPCStreamServiceHandler) InvokeMethod_ForwardStreams added in v0.3.0

func (SRPCStreamServiceHandler) InvokeMethod_ForwardStreams(impl SRPCStreamServiceServer, strm srpc.Stream) error

func (SRPCStreamServiceHandler) InvokeMethod_ListenStreams added in v0.3.0

func (SRPCStreamServiceHandler) InvokeMethod_ListenStreams(impl SRPCStreamServiceServer, strm srpc.Stream) error

type SRPCStreamServiceUnimplementedServer added in v0.3.0

type SRPCStreamServiceUnimplementedServer struct{}

func (*SRPCStreamServiceUnimplementedServer) AcceptStream added in v0.3.0

func (*SRPCStreamServiceUnimplementedServer) DialStream added in v0.3.0

func (*SRPCStreamServiceUnimplementedServer) ForwardStreams added in v0.3.0

func (*SRPCStreamServiceUnimplementedServer) ListenStreams added in v0.3.0

type SRPCStreamService_AcceptStreamClient added in v0.3.0

type SRPCStreamService_AcceptStreamClient interface {
	srpc.Stream
	Send(*AcceptStreamRequest) error
	Recv() (*AcceptStreamResponse, error)
	RecvTo(*AcceptStreamResponse) error
}

type SRPCStreamService_AcceptStreamStream added in v0.3.0

type SRPCStreamService_AcceptStreamStream interface {
	srpc.Stream
	Send(*AcceptStreamResponse) error
	SendAndClose(*AcceptStreamResponse) error
	Recv() (*AcceptStreamRequest, error)
}

type SRPCStreamService_DialStreamClient added in v0.3.0

type SRPCStreamService_DialStreamClient interface {
	srpc.Stream
	Send(*DialStreamRequest) error
	Recv() (*DialStreamResponse, error)
	RecvTo(*DialStreamResponse) error
}

type SRPCStreamService_DialStreamStream added in v0.3.0

type SRPCStreamService_DialStreamStream interface {
	srpc.Stream
	Send(*DialStreamResponse) error
	SendAndClose(*DialStreamResponse) error
	Recv() (*DialStreamRequest, error)
}

type SRPCStreamService_ForwardStreamsClient added in v0.3.0

type SRPCStreamService_ForwardStreamsClient interface {
	srpc.Stream
	Recv() (*ForwardStreamsResponse, error)
	RecvTo(*ForwardStreamsResponse) error
}

type SRPCStreamService_ForwardStreamsStream added in v0.3.0

type SRPCStreamService_ForwardStreamsStream interface {
	srpc.Stream
	Send(*ForwardStreamsResponse) error
	SendAndClose(*ForwardStreamsResponse) error
}

type SRPCStreamService_ListenStreamsClient added in v0.3.0

type SRPCStreamService_ListenStreamsClient interface {
	srpc.Stream
	Recv() (*ListenStreamsResponse, error)
	RecvTo(*ListenStreamsResponse) error
}

type SRPCStreamService_ListenStreamsStream added in v0.3.0

type SRPCStreamService_ListenStreamsStream interface {
	srpc.Stream
	Send(*ListenStreamsResponse) error
	SendAndClose(*ListenStreamsResponse) error
}

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL