stream_api

package
v0.2.2 Latest Latest
Warning

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

 Go to latest Published: Jun 9, 2022 License: Apache-2.0 Imports: 19 Imported by: 0

Documentation

Index

Constants

This section is empty.

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 DRPCStreamService_AcceptStreamStream,
) stream_api_rpc.RPC

NewAcceptServerRPC constructs a new AcceptServerRPC.

func NewAcceptStreamClientRPC 

func NewAcceptStreamClientRPC(
	client DRPCStreamService_AcceptStreamClient,
) stream_api_rpc.RPC

NewAcceptStreamClientRPC builds a new AcceptStreamClient.

func NewDialServerRPC 

func NewDialServerRPC(
	serv DRPCStreamService_DialStreamStream,
) stream_api_rpc.RPC

NewDialServerRPC builds a new DialServerRPC.

func NewDialStreamClientRPC 

func NewDialStreamClientRPC(
	client DRPCStreamService_DialStreamClient,
) stream_api_rpc.RPC

NewDialStreamClientRPC builds a new DialStreamClientRPC.

Types

type AcceptServerRPC 

type AcceptServerRPC struct {
	DRPCStreamService_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 {
	DRPCStreamService_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) 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) 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 {
	DRPCStreamService_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 {
	DRPCStreamService_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) 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) 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) 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) 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) 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) 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

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.