stream_api

package
v0.30.5 Latest Latest
Warning

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

Go to latest
Published: Apr 24, 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

Recv receives a packet.

func (*AcceptStreamClientRPC) Send

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 (*AcceptStreamRequest) CloneVT added in v0.8.3

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 (*AcceptStreamResponse) CloneVT added in v0.8.3

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

Recv receives a packet.

func (*DialStreamClientRPC) Send

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 (*ForwardStreamsRequest) CloneVT added in v0.8.3

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 (*ForwardStreamsResponse) CloneVT added in v0.8.3

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 (*ListenStreamsRequest) CloneVT added in v0.8.3

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 (*ListenStreamsResponse) CloneVT added in v0.8.3

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

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

type SRPCStreamServiceUnimplementedServer struct{}

func (*SRPCStreamServiceUnimplementedServer) AcceptStream added in v0.3.0

func (*SRPCStreamServiceUnimplementedServer) DialStream added in v0.3.0

func (*SRPCStreamServiceUnimplementedServer) ForwardStreams added in v0.3.0

func (*SRPCStreamServiceUnimplementedServer) ListenStreams added in v0.3.0

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
}

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL