stream_api

package
v0.1.1 Latest Latest
Warning

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

 Go to latest Published: Mar 21, 2022 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

AcceptStreamRequest is the request type for AcceptStream.

func (*AcceptStreamRequest) Descriptor 

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

func (*AcceptStreamRequest) GetConfig 

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

func (*AcceptStreamRequest) GetData 

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

func (*AcceptStreamRequest) ProtoMessage 

func (*AcceptStreamRequest) ProtoMessage()

func (*AcceptStreamRequest) Reset 

func (m *AcceptStreamRequest) Reset()

func (*AcceptStreamRequest) String 

func (m *AcceptStreamRequest) String() string

func (*AcceptStreamRequest) XXX_DiscardUnknown 

func (m *AcceptStreamRequest) XXX_DiscardUnknown()

func (*AcceptStreamRequest) XXX_Marshal 

func (m *AcceptStreamRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AcceptStreamRequest) XXX_Merge 

func (m *AcceptStreamRequest) XXX_Merge(src proto.Message)

func (*AcceptStreamRequest) XXX_Size 

func (m *AcceptStreamRequest) XXX_Size() int

func (*AcceptStreamRequest) XXX_Unmarshal 

func (m *AcceptStreamRequest) XXX_Unmarshal(b []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"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

AcceptStreamResponse is the response type for AcceptStream.

func (*AcceptStreamResponse) Descriptor 

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

func (*AcceptStreamResponse) GetData 

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

func (*AcceptStreamResponse) ProtoMessage 

func (*AcceptStreamResponse) ProtoMessage()

func (*AcceptStreamResponse) Reset 

func (m *AcceptStreamResponse) Reset()

func (*AcceptStreamResponse) String 

func (m *AcceptStreamResponse) String() string

func (*AcceptStreamResponse) XXX_DiscardUnknown 

func (m *AcceptStreamResponse) XXX_DiscardUnknown()

func (*AcceptStreamResponse) XXX_Marshal 

func (m *AcceptStreamResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AcceptStreamResponse) XXX_Merge 

func (m *AcceptStreamResponse) XXX_Merge(src proto.Message)

func (*AcceptStreamResponse) XXX_Size 

func (m *AcceptStreamResponse) XXX_Size() int

func (*AcceptStreamResponse) XXX_Unmarshal 

func (m *AcceptStreamResponse) XXX_Unmarshal(b []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"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

DialStreamRequest is the request type for DialStream.

func (*DialStreamRequest) Descriptor 

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

func (*DialStreamRequest) GetConfig 

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

func (*DialStreamRequest) GetData 

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

func (*DialStreamRequest) ProtoMessage 

func (*DialStreamRequest) ProtoMessage()

func (*DialStreamRequest) Reset 

func (m *DialStreamRequest) Reset()

func (*DialStreamRequest) String 

func (m *DialStreamRequest) String() string

func (*DialStreamRequest) XXX_DiscardUnknown 

func (m *DialStreamRequest) XXX_DiscardUnknown()

func (*DialStreamRequest) XXX_Marshal 

func (m *DialStreamRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DialStreamRequest) XXX_Merge 

func (m *DialStreamRequest) XXX_Merge(src proto.Message)

func (*DialStreamRequest) XXX_Size 

func (m *DialStreamRequest) XXX_Size() int

func (*DialStreamRequest) XXX_Unmarshal 

func (m *DialStreamRequest) XXX_Unmarshal(b []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"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

DialStreamResponse is the response type for DialStream.

func (*DialStreamResponse) Descriptor 

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

func (*DialStreamResponse) GetData 

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

func (*DialStreamResponse) ProtoMessage 

func (*DialStreamResponse) ProtoMessage()

func (*DialStreamResponse) Reset 

func (m *DialStreamResponse) Reset()

func (*DialStreamResponse) String 

func (m *DialStreamResponse) String() string

func (*DialStreamResponse) XXX_DiscardUnknown 

func (m *DialStreamResponse) XXX_DiscardUnknown()

func (*DialStreamResponse) XXX_Marshal 

func (m *DialStreamResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DialStreamResponse) XXX_Merge 

func (m *DialStreamResponse) XXX_Merge(src proto.Message)

func (*DialStreamResponse) XXX_Size 

func (m *DialStreamResponse) XXX_Size() int

func (*DialStreamResponse) XXX_Unmarshal 

func (m *DialStreamResponse) XXX_Unmarshal(b []byte) error

type ForwardStreamsRequest 

type ForwardStreamsRequest struct {
	ForwardingConfig     *forwarding.Config `protobuf:"bytes,1,opt,name=forwarding_config,json=forwardingConfig,proto3" json:"forwarding_config,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

ForwardStreamsRequest is the request type for ForwardStreams.

func (*ForwardStreamsRequest) Descriptor 

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

func (*ForwardStreamsRequest) GetForwardingConfig 

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

func (*ForwardStreamsRequest) ProtoMessage 

func (*ForwardStreamsRequest) ProtoMessage()

func (*ForwardStreamsRequest) Reset 

func (m *ForwardStreamsRequest) Reset()

func (*ForwardStreamsRequest) String 

func (m *ForwardStreamsRequest) String() string

func (*ForwardStreamsRequest) XXX_DiscardUnknown 

func (m *ForwardStreamsRequest) XXX_DiscardUnknown()

func (*ForwardStreamsRequest) XXX_Marshal 

func (m *ForwardStreamsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ForwardStreamsRequest) XXX_Merge 

func (m *ForwardStreamsRequest) XXX_Merge(src proto.Message)

func (*ForwardStreamsRequest) XXX_Size 

func (m *ForwardStreamsRequest) XXX_Size() int

func (*ForwardStreamsRequest) XXX_Unmarshal 

func (m *ForwardStreamsRequest) XXX_Unmarshal(b []byte) error

type ForwardStreamsResponse 

type ForwardStreamsResponse struct {
	// ControllerStatus is the status of the forwarding controller.
	ControllerStatus     exec.ControllerStatus `` /* 148-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

ForwardStreamsResponse is the response type for ForwardStreams.

func (*ForwardStreamsResponse) Descriptor 

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

func (*ForwardStreamsResponse) GetControllerStatus 

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

func (*ForwardStreamsResponse) ProtoMessage 

func (*ForwardStreamsResponse) ProtoMessage()

func (*ForwardStreamsResponse) Reset 

func (m *ForwardStreamsResponse) Reset()

func (*ForwardStreamsResponse) String 

func (m *ForwardStreamsResponse) String() string

func (*ForwardStreamsResponse) XXX_DiscardUnknown 

func (m *ForwardStreamsResponse) XXX_DiscardUnknown()

func (*ForwardStreamsResponse) XXX_Marshal 

func (m *ForwardStreamsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ForwardStreamsResponse) XXX_Merge 

func (m *ForwardStreamsResponse) XXX_Merge(src proto.Message)

func (*ForwardStreamsResponse) XXX_Size 

func (m *ForwardStreamsResponse) XXX_Size() int

func (*ForwardStreamsResponse) XXX_Unmarshal 

func (m *ForwardStreamsResponse) XXX_Unmarshal(b []byte) error

type ListenStreamsRequest 

type ListenStreamsRequest struct {
	ListeningConfig      *listening.Config `protobuf:"bytes,1,opt,name=listening_config,json=listeningConfig,proto3" json:"listening_config,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

ListenStreamsRequest is the request type for ListenStreams.

func (*ListenStreamsRequest) Descriptor 

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

func (*ListenStreamsRequest) GetListeningConfig 

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

func (*ListenStreamsRequest) ProtoMessage 

func (*ListenStreamsRequest) ProtoMessage()

func (*ListenStreamsRequest) Reset 

func (m *ListenStreamsRequest) Reset()

func (*ListenStreamsRequest) String 

func (m *ListenStreamsRequest) String() string

func (*ListenStreamsRequest) XXX_DiscardUnknown 

func (m *ListenStreamsRequest) XXX_DiscardUnknown()

func (*ListenStreamsRequest) XXX_Marshal 

func (m *ListenStreamsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListenStreamsRequest) XXX_Merge 

func (m *ListenStreamsRequest) XXX_Merge(src proto.Message)

func (*ListenStreamsRequest) XXX_Size 

func (m *ListenStreamsRequest) XXX_Size() int

func (*ListenStreamsRequest) XXX_Unmarshal 

func (m *ListenStreamsRequest) XXX_Unmarshal(b []byte) error

type ListenStreamsResponse 

type ListenStreamsResponse struct {
	// ControllerStatus is the status of the forwarding controller.
	ControllerStatus     exec.ControllerStatus `` /* 148-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

ListenStreamsResponse is the response type for ListenStreams.

func (*ListenStreamsResponse) Descriptor 

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

func (*ListenStreamsResponse) GetControllerStatus 

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

func (*ListenStreamsResponse) ProtoMessage 

func (*ListenStreamsResponse) ProtoMessage()

func (*ListenStreamsResponse) Reset 

func (m *ListenStreamsResponse) Reset()

func (*ListenStreamsResponse) String 

func (m *ListenStreamsResponse) String() string

func (*ListenStreamsResponse) XXX_DiscardUnknown 

func (m *ListenStreamsResponse) XXX_DiscardUnknown()

func (*ListenStreamsResponse) XXX_Marshal 

func (m *ListenStreamsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListenStreamsResponse) XXX_Merge 

func (m *ListenStreamsResponse) XXX_Merge(src proto.Message)

func (*ListenStreamsResponse) XXX_Size 

func (m *ListenStreamsResponse) XXX_Size() int

func (*ListenStreamsResponse) XXX_Unmarshal 

func (m *ListenStreamsResponse) XXX_Unmarshal(b []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.