stream_api

package
v0.40.2 Latest Latest
Warning

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

 Go to latest Published: Dec 18, 2024 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

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

Variables

This section is empty.

Functions

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) CloneMessageVT added in v0.15.6 

func (m *AcceptStreamRequest) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*AcceptStreamRequest) CloneVT added in v0.8.3 

func (m *AcceptStreamRequest) CloneVT() *AcceptStreamRequest

func (*AcceptStreamRequest) EqualMessageVT added in v0.15.6 

func (this *AcceptStreamRequest) EqualMessageVT(thatMsg any) bool

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) MarshalJSON added in v0.29.0 

func (x *AcceptStreamRequest) MarshalJSON() ([]byte, error)

MarshalJSON marshals the AcceptStreamRequest to JSON.

func (*AcceptStreamRequest) MarshalProtoJSON added in v0.29.0 

func (x *AcceptStreamRequest) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the AcceptStreamRequest message to JSON.

func (*AcceptStreamRequest) MarshalProtoText added in v0.29.2 

func (x *AcceptStreamRequest) MarshalProtoText() string

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) 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) UnmarshalJSON added in v0.29.0 

func (x *AcceptStreamRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the AcceptStreamRequest from JSON.

func (*AcceptStreamRequest) UnmarshalProtoJSON added in v0.29.0 

func (x *AcceptStreamRequest) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the AcceptStreamRequest message from JSON.

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) CloneMessageVT added in v0.15.6 

func (m *AcceptStreamResponse) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*AcceptStreamResponse) CloneVT added in v0.8.3 

func (m *AcceptStreamResponse) CloneVT() *AcceptStreamResponse

func (*AcceptStreamResponse) EqualMessageVT added in v0.15.6 

func (this *AcceptStreamResponse) EqualMessageVT(thatMsg any) bool

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) MarshalJSON added in v0.29.0 

func (x *AcceptStreamResponse) MarshalJSON() ([]byte, error)

MarshalJSON marshals the AcceptStreamResponse to JSON.

func (*AcceptStreamResponse) MarshalProtoJSON added in v0.29.0 

func (x *AcceptStreamResponse) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the AcceptStreamResponse message to JSON.

func (*AcceptStreamResponse) MarshalProtoText added in v0.29.2 

func (x *AcceptStreamResponse) MarshalProtoText() string

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) 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) UnmarshalJSON added in v0.29.0 

func (x *AcceptStreamResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the AcceptStreamResponse from JSON.

func (*AcceptStreamResponse) UnmarshalProtoJSON added in v0.29.0 

func (x *AcceptStreamResponse) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the AcceptStreamResponse message from JSON.

func (*AcceptStreamResponse) UnmarshalVT added in v0.2.0 

func (m *AcceptStreamResponse) UnmarshalVT(dAtA []byte) 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) CloneMessageVT added in v0.15.6 

func (m *DialStreamRequest) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*DialStreamRequest) CloneVT added in v0.8.3 

func (m *DialStreamRequest) CloneVT() *DialStreamRequest

func (*DialStreamRequest) EqualMessageVT added in v0.15.6 

func (this *DialStreamRequest) EqualMessageVT(thatMsg any) bool

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) MarshalJSON added in v0.29.0 

func (x *DialStreamRequest) MarshalJSON() ([]byte, error)

MarshalJSON marshals the DialStreamRequest to JSON.

func (*DialStreamRequest) MarshalProtoJSON added in v0.29.0 

func (x *DialStreamRequest) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the DialStreamRequest message to JSON.

func (*DialStreamRequest) MarshalProtoText added in v0.29.2 

func (x *DialStreamRequest) MarshalProtoText() string

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) 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) UnmarshalJSON added in v0.29.0 

func (x *DialStreamRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the DialStreamRequest from JSON.

func (*DialStreamRequest) UnmarshalProtoJSON added in v0.29.0 

func (x *DialStreamRequest) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the DialStreamRequest message from JSON.

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) CloneMessageVT added in v0.15.6 

func (m *DialStreamResponse) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*DialStreamResponse) CloneVT added in v0.8.3 

func (m *DialStreamResponse) CloneVT() *DialStreamResponse

func (*DialStreamResponse) EqualMessageVT added in v0.15.6 

func (this *DialStreamResponse) EqualMessageVT(thatMsg any) bool

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) MarshalJSON added in v0.29.0 

func (x *DialStreamResponse) MarshalJSON() ([]byte, error)

MarshalJSON marshals the DialStreamResponse to JSON.

func (*DialStreamResponse) MarshalProtoJSON added in v0.29.0 

func (x *DialStreamResponse) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the DialStreamResponse message to JSON.

func (*DialStreamResponse) MarshalProtoText added in v0.29.2 

func (x *DialStreamResponse) MarshalProtoText() string

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) 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) UnmarshalJSON added in v0.29.0 

func (x *DialStreamResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the DialStreamResponse from JSON.

func (*DialStreamResponse) UnmarshalProtoJSON added in v0.29.0 

func (x *DialStreamResponse) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the DialStreamResponse message from JSON.

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:"forwardingConfig,omitempty"`
	// contains filtered or unexported fields
}

ForwardStreamsRequest is the request type for ForwardStreams.

func (*ForwardStreamsRequest) CloneMessageVT added in v0.15.6 

func (m *ForwardStreamsRequest) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*ForwardStreamsRequest) CloneVT added in v0.8.3 

func (m *ForwardStreamsRequest) CloneVT() *ForwardStreamsRequest

func (*ForwardStreamsRequest) EqualMessageVT added in v0.15.6 

func (this *ForwardStreamsRequest) EqualMessageVT(thatMsg any) bool

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) MarshalJSON added in v0.29.0 

func (x *ForwardStreamsRequest) MarshalJSON() ([]byte, error)

MarshalJSON marshals the ForwardStreamsRequest to JSON.

func (*ForwardStreamsRequest) MarshalProtoJSON added in v0.29.0 

func (x *ForwardStreamsRequest) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the ForwardStreamsRequest message to JSON.

func (*ForwardStreamsRequest) MarshalProtoText added in v0.29.2 

func (x *ForwardStreamsRequest) MarshalProtoText() string

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) 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) UnmarshalJSON added in v0.29.0 

func (x *ForwardStreamsRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the ForwardStreamsRequest from JSON.

func (*ForwardStreamsRequest) UnmarshalProtoJSON added in v0.29.0 

func (x *ForwardStreamsRequest) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the ForwardStreamsRequest message from JSON.

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 `protobuf:"varint,1,opt,name=controller_status,json=controllerStatus,proto3" json:"controllerStatus,omitempty"`
	// contains filtered or unexported fields
}

ForwardStreamsResponse is the response type for ForwardStreams.

func (*ForwardStreamsResponse) CloneMessageVT added in v0.15.6 

func (m *ForwardStreamsResponse) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*ForwardStreamsResponse) CloneVT added in v0.8.3 

func (m *ForwardStreamsResponse) CloneVT() *ForwardStreamsResponse

func (*ForwardStreamsResponse) EqualMessageVT added in v0.15.6 

func (this *ForwardStreamsResponse) EqualMessageVT(thatMsg any) bool

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) MarshalJSON added in v0.29.0 

func (x *ForwardStreamsResponse) MarshalJSON() ([]byte, error)

MarshalJSON marshals the ForwardStreamsResponse to JSON.

func (*ForwardStreamsResponse) MarshalProtoJSON added in v0.29.0 

func (x *ForwardStreamsResponse) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the ForwardStreamsResponse message to JSON.

func (*ForwardStreamsResponse) MarshalProtoText added in v0.29.2 

func (x *ForwardStreamsResponse) MarshalProtoText() string

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) 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) UnmarshalJSON added in v0.29.0 

func (x *ForwardStreamsResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the ForwardStreamsResponse from JSON.

func (*ForwardStreamsResponse) UnmarshalProtoJSON added in v0.29.0 

func (x *ForwardStreamsResponse) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the ForwardStreamsResponse message from JSON.

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:"listeningConfig,omitempty"`
	// contains filtered or unexported fields
}

ListenStreamsRequest is the request type for ListenStreams.

func (*ListenStreamsRequest) CloneMessageVT added in v0.15.6 

func (m *ListenStreamsRequest) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*ListenStreamsRequest) CloneVT added in v0.8.3 

func (m *ListenStreamsRequest) CloneVT() *ListenStreamsRequest

func (*ListenStreamsRequest) EqualMessageVT added in v0.15.6 

func (this *ListenStreamsRequest) EqualMessageVT(thatMsg any) bool

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) MarshalJSON added in v0.29.0 

func (x *ListenStreamsRequest) MarshalJSON() ([]byte, error)

MarshalJSON marshals the ListenStreamsRequest to JSON.

func (*ListenStreamsRequest) MarshalProtoJSON added in v0.29.0 

func (x *ListenStreamsRequest) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the ListenStreamsRequest message to JSON.

func (*ListenStreamsRequest) MarshalProtoText added in v0.29.2 

func (x *ListenStreamsRequest) MarshalProtoText() string

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) 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) UnmarshalJSON added in v0.29.0 

func (x *ListenStreamsRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the ListenStreamsRequest from JSON.

func (*ListenStreamsRequest) UnmarshalProtoJSON added in v0.29.0 

func (x *ListenStreamsRequest) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the ListenStreamsRequest message from JSON.

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 `protobuf:"varint,1,opt,name=controller_status,json=controllerStatus,proto3" json:"controllerStatus,omitempty"`
	// contains filtered or unexported fields
}

ListenStreamsResponse is the response type for ListenStreams.

func (*ListenStreamsResponse) CloneMessageVT added in v0.15.6 

func (m *ListenStreamsResponse) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*ListenStreamsResponse) CloneVT added in v0.8.3 

func (m *ListenStreamsResponse) CloneVT() *ListenStreamsResponse

func (*ListenStreamsResponse) EqualMessageVT added in v0.15.6 

func (this *ListenStreamsResponse) EqualMessageVT(thatMsg any) bool

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) MarshalJSON added in v0.29.0 

func (x *ListenStreamsResponse) MarshalJSON() ([]byte, error)

MarshalJSON marshals the ListenStreamsResponse to JSON.

func (*ListenStreamsResponse) MarshalProtoJSON added in v0.29.0 

func (x *ListenStreamsResponse) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the ListenStreamsResponse message to JSON.

func (*ListenStreamsResponse) MarshalProtoText added in v0.29.2 

func (x *ListenStreamsResponse) MarshalProtoText() string

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) 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) UnmarshalJSON added in v0.29.0 

func (x *ListenStreamsResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the ListenStreamsResponse from JSON.

func (*ListenStreamsResponse) UnmarshalProtoJSON added in v0.29.0 

func (x *ListenStreamsResponse) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the ListenStreamsResponse message from JSON.

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 returns the underlying SRPC client.
	SRPCClient() srpc.Client

	// ForwardStreams forwards streams to the target multiaddress.
	// Handles HandleMountedStream directives by contacting the target.
	ForwardStreams(ctx context.Context, in *ForwardStreamsRequest) (SRPCStreamService_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) (SRPCStreamService_ListenStreamsClient, error)
	// AcceptStream accepts an incoming stream.
	// Stream data is sent over the request / response streams.
	AcceptStream(ctx context.Context) (SRPCStreamService_AcceptStreamClient, error)
	// DialStream dials a outgoing stream.
	// Stream data is sent over the request / response streams.
	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 forwards streams to the target multiaddress.
	// Handles HandleMountedStream directives by contacting the target.
	ForwardStreams(*ForwardStreamsRequest, SRPCStreamService_ForwardStreamsStream) error
	// ListenStreams listens for connections to the multiaddress.
	// Forwards the connections to a remote peer with a protocol ID.
	ListenStreams(*ListenStreamsRequest, SRPCStreamService_ListenStreamsStream) error
	// AcceptStream accepts an incoming stream.
	// Stream data is sent over the request / response streams.
	AcceptStream(SRPCStreamService_AcceptStreamStream) error
	// DialStream dials a outgoing stream.
	// Stream data is sent over the request / response streams.
	DialStream(SRPCStreamService_DialStreamStream) 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
	SendAndClose(*AcceptStreamResponse) error
	Recv() (*AcceptStreamRequest, error)
	RecvTo(*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)
	RecvTo(*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
}

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.