stream_grpc

type AcceptServerRPC struct {
	StreamService_AcceptStreamServer
}

type AcceptStreamClientRPC struct {
	StreamService_AcceptStreamClient
}

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:"-"`
}

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:"-"`
}

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

type DRPCStreamServiceDescription struct{}

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

type DRPCStreamServiceUnimplementedServer struct{}

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

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

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

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

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

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

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

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

type DialServerRPC struct {
	StreamService_DialStreamServer
}

type DialStreamClientRPC struct {
	StreamService_DialStreamClient
}

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:"-"`
}

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:"-"`
}

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:"-"`
}

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:"-"`
}

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:"-"`
}

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:"-"`
}

type StreamServiceClient interface {
	// ForwardStreams forwards streams to the target multiaddress.
	// Handles HandleMountedStream directives by contacting the target.
	ForwardStreams(ctx context.Context, in *ForwardStreamsRequest, opts ...grpc.CallOption) (StreamService_ForwardStreamsClient, error)
	// ListenStreams listens for connections to the multiaddress.
	// Forwards the connections to a remote peer with a protocol ID.
	ListenStreams(ctx context.Context, in *ListenStreamsRequest, opts ...grpc.CallOption) (StreamService_ListenStreamsClient, error)
	// AcceptStream accepts an incoming stream.
	// Stream data is sent over the request / response streams.
	AcceptStream(ctx context.Context, opts ...grpc.CallOption) (StreamService_AcceptStreamClient, error)
	// DialStream dials a outgoing stream.
	// Stream data is sent over the request / response streams.
	DialStream(ctx context.Context, opts ...grpc.CallOption) (StreamService_DialStreamClient, error)
}

type StreamServiceServer interface {
	// ForwardStreams forwards streams to the target multiaddress.
	// Handles HandleMountedStream directives by contacting the target.
	ForwardStreams(*ForwardStreamsRequest, StreamService_ForwardStreamsServer) error
	// ListenStreams listens for connections to the multiaddress.
	// Forwards the connections to a remote peer with a protocol ID.
	ListenStreams(*ListenStreamsRequest, StreamService_ListenStreamsServer) error
	// AcceptStream accepts an incoming stream.
	// Stream data is sent over the request / response streams.
	AcceptStream(StreamService_AcceptStreamServer) error
	// DialStream dials a outgoing stream.
	// Stream data is sent over the request / response streams.
	DialStream(StreamService_DialStreamServer) error
}

type StreamService_AcceptStreamClient interface {
	Send(*AcceptStreamRequest) error
	Recv() (*AcceptStreamResponse, error)
	grpc.ClientStream
}

type StreamService_AcceptStreamServer interface {
	Send(*AcceptStreamResponse) error
	Recv() (*AcceptStreamRequest, error)
	grpc.ServerStream
}

type StreamService_DialStreamClient interface {
	Send(*DialStreamRequest) error
	Recv() (*DialStreamResponse, error)
	grpc.ClientStream
}

type StreamService_DialStreamServer interface {
	Send(*DialStreamResponse) error
	Recv() (*DialStreamRequest, error)
	grpc.ServerStream
}

type StreamService_ForwardStreamsClient interface {
	Recv() (*ForwardStreamsResponse, error)
	grpc.ClientStream
}

type StreamService_ForwardStreamsServer interface {
	Send(*ForwardStreamsResponse) error
	grpc.ServerStream
}

type StreamService_ListenStreamsClient interface {
	Recv() (*ListenStreamsResponse, error)
	grpc.ClientStream
}

type StreamService_ListenStreamsServer interface {
	Send(*ListenStreamsResponse) error
	grpc.ServerStream
}

type UnimplementedStreamServiceServer struct {
}