stdio

package

v0.10.1 Latest Latest Go to latest Published: Nov 20, 2025 License: Apache-2.0 Imports: 14 Imported by: 0

Details

This section is empty.

View Source

var ErrUnexpectedMapType = errors.New("unexpected map type for stdio streaming server")

This section is empty.

type ClientInputStream struct {
	// contains filtered or unexported fields
}

func NewClientInputStream(client api.InputStreamingPluginClient, streamID string, stdin io.Reader) (ClientInputStream, error)

func (s ClientInputStream) Close()

func (s ClientInputStream) Copy() error

type ClientOutputStream struct {
	// contains filtered or unexported fields
}

func NewClientOutputStream(client api.OutputStreamingPluginClient, streamID string, stdout, stderr io.Writer) (ClientOutputStream, error)

func (s ClientOutputStream) Copy() error

type InputStreamingPluginServer struct {
	api.UnsafeInputStreamingPluginServer
	// contains filtered or unexported fields
}

func (s *InputStreamingPluginServer) NewServerInputStream(streamID string) (ServerInputStream, error)

func (s *InputStreamingPluginServer) Reset()

func (s *InputStreamingPluginServer) StreamInput(srv api.InputStreamingPlugin_StreamInputServer) error

type InputStreamingServerInstance struct {
	// contains filtered or unexported fields
}

func (s *InputStreamingServerInstance) Close()

type OutputStreamingPluginServer struct {
	api.UnsafeOutputStreamingPluginServer
	// contains filtered or unexported fields
}

func (s *OutputStreamingPluginServer) NewServerOutputStream(streamID string) (ServerOutputStream, error)

func (s *OutputStreamingPluginServer) Reset()

func (s *OutputStreamingPluginServer) StreamOutput(request *api.StreamOutputRequest, srv api.OutputStreamingPlugin_StreamOutputServer) error

type OutputStreamingServerInstance struct {
	// contains filtered or unexported fields
}

type ServerInputStream struct {
	Stdin io.Reader
	// contains filtered or unexported fields
}

func (s ServerInputStream) Close()

func (s ServerInputStream) Copy() error

type ServerOutputStream struct {
	Stdout io.WriteCloser

	Stderr io.WriteCloser
	// contains filtered or unexported fields
}

func (s ServerOutputStream) Close()

func (s ServerOutputStream) Copy() error