socketforward

type BindRequest struct {
	Sockets []*Socket `protobuf:"bytes,1,rep,name=sockets,proto3" json:"sockets,omitempty"`
	// contains filtered or unexported fields
}

type ConnectRequest struct {

	// ID of the vsock stream. The host must open a stream with this ID after
	// a successful ConnectResult so that the relay can start.
	StreamID string `protobuf:"bytes,1,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"`
	// Identifier of the socket forward entry. The host uses this to resolve the
	// target host socket path from its own configuration rather than trusting a
	// path supplied by the VM.
	ForwardID string `protobuf:"bytes,2,opt,name=forward_id,json=forwardId,proto3" json:"forward_id,omitempty"`
	// contains filtered or unexported fields
}

type ConnectResult struct {

	// ID of the vsock stream from the corresponding ConnectRequest.
	StreamID string `protobuf:"bytes,1,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"`
	// Non-empty if the host failed to dial the target socket. The VM closes
	// the pending connection when error is set.
	Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

type Socket struct {

	// Opaque identifier for this forward. Each side uses it to resolve the local
	// socket path from its own configuration.
	ForwardID string `protobuf:"bytes,1,opt,name=forward_id,json=forwardId,proto3" json:"forward_id,omitempty"`
	// Path of the UNIX listener socket in the VM's root filesystem (e.g.
	// /run/socketfwd/{forward_id}.sock). vminitd creates the socket here;
	// the shim has already rewritten the uds mount to a bind mount from
	// this path to the user-specified destination inside the container.
	SocketPath string `protobuf:"bytes,2,opt,name=socket_path,json=socketPath,proto3" json:"socket_path,omitempty"`
	// contains filtered or unexported fields
}

type TTRPCSocketForwardClient interface {
	Bind(context.Context, *BindRequest) (*emptypb.Empty, error)
	Accept(context.Context) (TTRPCSocketForward_AcceptClient, error)
}

type TTRPCSocketForwardService interface {
	Bind(context.Context, *BindRequest) (*emptypb.Empty, error)
	Accept(context.Context, TTRPCSocketForward_AcceptServer) error
}

type TTRPCSocketForward_AcceptClient interface {
	Send(*ConnectResult) error
	Recv() (*ConnectRequest, error)
	ttrpc.ClientStream
}

type TTRPCSocketForward_AcceptServer interface {
	Send(*ConnectRequest) error
	Recv() (*ConnectResult, error)
	ttrpc.StreamServer
}