Versions in this module Expand all Collapse all v0 v0.11.0 Nov 20, 2025 v0.10.1 Nov 20, 2025 Changes in this version + var ErrUnexpectedMapType = errors.New("unexpected map type for stdio streaming server") + type ClientInputStream struct + func NewClientInputStream(client api.InputStreamingPluginClient, streamID string, stdin io.Reader) (ClientInputStream, error) + func (s ClientInputStream) Close() + func (s ClientInputStream) Copy() error + type ClientOutputStream struct + func NewClientOutputStream(client api.OutputStreamingPluginClient, streamID string, ...) (ClientOutputStream, error) + func (s ClientOutputStream) Copy() error + type InputStreamingPluginServer struct + func (s *InputStreamingPluginServer) NewServerInputStream(streamID string) (ServerInputStream, error) + func (s *InputStreamingPluginServer) Reset() + func (s *InputStreamingPluginServer) StreamInput(srv api.InputStreamingPlugin_StreamInputServer) error + type InputStreamingServerInstance struct + func (s *InputStreamingServerInstance) Close() + type OutputStreamingPluginServer struct + func (s *OutputStreamingPluginServer) NewServerOutputStream(streamID string) (ServerOutputStream, error) + func (s *OutputStreamingPluginServer) Reset() + func (s *OutputStreamingPluginServer) StreamOutput(request *api.StreamOutputRequest, ...) error + type OutputStreamingServerInstance struct + type ServerInputStream struct + Stdin io.Reader + func (s ServerInputStream) Close() + func (s ServerInputStream) Copy() error + type ServerOutputStream struct + Stderr io.WriteCloser + Stdout io.WriteCloser + func (s ServerOutputStream) Close() + func (s ServerOutputStream) Copy() error
Go to main page