stream_api

package
v0.7.3 Latest Latest
Warning

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

 Go to latest Published: Oct 14, 2022 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 

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

Recv receives a packet.

func (*AcceptStreamClientRPC) Send 

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

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) 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) 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 DRPCStreamServiceClient 

type DRPCStreamServiceClient interface {
	DRPCConn() drpc.Conn

	ForwardStreams(ctx context.Context, in *ForwardStreamsRequest) (DRPCStreamService_ForwardStreamsClient, error)
	ListenStreams(ctx context.Context, in *ListenStreamsRequest) (DRPCStreamService_ListenStreamsClient, error)
	AcceptStream(ctx context.Context) (DRPCStreamService_AcceptStreamClient, error)
	DialStream(ctx context.Context) (DRPCStreamService_DialStreamClient, error)
}

func NewDRPCStreamServiceClient 

func NewDRPCStreamServiceClient(cc drpc.Conn) DRPCStreamServiceClient

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 DRPCStreamServiceServer 

type DRPCStreamServiceServer interface {
	ForwardStreams(*ForwardStreamsRequest, DRPCStreamService_ForwardStreamsStream) error
	ListenStreams(*ListenStreamsRequest, DRPCStreamService_ListenStreamsStream) error
	AcceptStream(DRPCStreamService_AcceptStreamStream) error
	DialStream(DRPCStreamService_DialStreamStream) error
}

type DRPCStreamServiceUnimplementedServer 

type DRPCStreamServiceUnimplementedServer struct{}

func (*DRPCStreamServiceUnimplementedServer) AcceptStream 

func (s *DRPCStreamServiceUnimplementedServer) AcceptStream(DRPCStreamService_AcceptStreamStream) error

func (*DRPCStreamServiceUnimplementedServer) DialStream 

func (s *DRPCStreamServiceUnimplementedServer) DialStream(DRPCStreamService_DialStreamStream) error

func (*DRPCStreamServiceUnimplementedServer) ForwardStreams 

func (s *DRPCStreamServiceUnimplementedServer) ForwardStreams(*ForwardStreamsRequest, DRPCStreamService_ForwardStreamsStream) error

func (*DRPCStreamServiceUnimplementedServer) ListenStreams 

func (s *DRPCStreamServiceUnimplementedServer) ListenStreams(*ListenStreamsRequest, DRPCStreamService_ListenStreamsStream) error

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 

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

Recv receives a packet.

func (*DialStreamClientRPC) Send 

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

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) 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) 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) 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) 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) 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) 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 

type SRPCStreamServiceClient interface {
	SRPCClient() srpc.Client

	ForwardStreams(ctx context.Context, in *ForwardStreamsRequest) (SRPCStreamService_ForwardStreamsClient, error)
	ListenStreams(ctx context.Context, in *ListenStreamsRequest) (SRPCStreamService_ListenStreamsClient, error)
	AcceptStream(ctx context.Context) (SRPCStreamService_AcceptStreamClient, error)
	DialStream(ctx context.Context) (SRPCStreamService_DialStreamClient, error)
}

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 SRPCStreamServiceServer added in v0.3.0 

type SRPCStreamServiceServer interface {
	ForwardStreams(*ForwardStreamsRequest, SRPCStreamService_ForwardStreamsStream) error
	ListenStreams(*ListenStreamsRequest, SRPCStreamService_ListenStreamsStream) error
	AcceptStream(SRPCStreamService_AcceptStreamStream) error
	DialStream(SRPCStreamService_DialStreamStream) error
}

type SRPCStreamServiceUnimplementedServer added in v0.3.0 

type SRPCStreamServiceUnimplementedServer struct{}

func (*SRPCStreamServiceUnimplementedServer) AcceptStream added in v0.3.0 

func (s *SRPCStreamServiceUnimplementedServer) AcceptStream(SRPCStreamService_AcceptStreamStream) error

func (*SRPCStreamServiceUnimplementedServer) DialStream added in v0.3.0 

func (s *SRPCStreamServiceUnimplementedServer) DialStream(SRPCStreamService_DialStreamStream) error

func (*SRPCStreamServiceUnimplementedServer) ForwardStreams added in v0.3.0 

func (s *SRPCStreamServiceUnimplementedServer) ForwardStreams(*ForwardStreamsRequest, SRPCStreamService_ForwardStreamsStream) error

func (*SRPCStreamServiceUnimplementedServer) ListenStreams added in v0.3.0 

func (s *SRPCStreamServiceUnimplementedServer) ListenStreams(*ListenStreamsRequest, SRPCStreamService_ListenStreamsStream) error

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
	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
	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
}

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
}

Source Files

View all Source files

Directories

Path Synopsis

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.