pipe

package

v0.19.3 Latest Latest Go to latest Published: Oct 23, 2025 License: Apache-2.0 Imports: 14 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/dagger/dagger

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
func RegisterPipeServer(s *grpc.Server, srv PipeServer)
type Data
type PipeAttachable
- func NewPipeAttachable(rootCtx context.Context, stdin io.Reader, stdout io.Writer) PipeAttachable
- func (p PipeAttachable) IO(srv Pipe_IOServer) error
- func (p PipeAttachable) Register(srv *grpc.Server)
type PipeClient
- func NewPipeClient(cc *grpc.ClientConn) PipeClient
type PipeIO
type PipeServer
type Pipe_IOClient
type Pipe_IOServer
type UnimplementedPipeServer
- func (*UnimplementedPipeServer) IO(srv Pipe_IOServer) error

Constants ¶

This section is empty.

Variables ¶

View Source

var (
	ErrInvalidLengthPipe        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowPipe          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupPipe = fmt.Errorf("proto: unexpected end of group")
)

Functions ¶

func RegisterPipeServer ¶

func RegisterPipeServer(s *grpc.Server, srv PipeServer)

Types ¶

type Data ¶

type Data struct {
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
}

func (*Data) Descriptor ¶

func (*Data) Descriptor() ([]byte, []int)

func (*Data) Equal ¶

func (this *Data) Equal(that interface{}) bool

func (*Data) GetData ¶

func (m *Data) GetData() []byte

func (*Data) GoString ¶

func (this *Data) GoString() string

func (*Data) Marshal ¶

func (m *Data) Marshal() (dAtA []byte, err error)

func (*Data) MarshalTo ¶

func (m *Data) MarshalTo(dAtA []byte) (int, error)

func (*Data) MarshalToSizedBuffer ¶

func (m *Data) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Data) ProtoMessage ¶

func (*Data) ProtoMessage()

func (*Data) Reset ¶

func (m *Data) Reset()

func (*Data) Size ¶

func (m *Data) Size() (n int)

func (*Data) String ¶

func (this *Data) String() string

func (*Data) Unmarshal ¶

func (m *Data) Unmarshal(dAtA []byte) error

func (*Data) XXX_DiscardUnknown ¶

func (m *Data) XXX_DiscardUnknown()

func (*Data) XXX_Marshal ¶

func (m *Data) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Data) XXX_Merge ¶

func (m *Data) XXX_Merge(src proto.Message)

func (*Data) XXX_Size ¶

func (m *Data) XXX_Size() int

func (*Data) XXX_Unmarshal ¶

func (m *Data) XXX_Unmarshal(b []byte) error

type PipeAttachable ¶

type PipeAttachable struct {
	UnimplementedPipeServer
	// contains filtered or unexported fields
}

PipeAttachable implements the PipeServer interface generated by protoc.

func NewPipeAttachable ¶

func NewPipeAttachable(rootCtx context.Context, stdin io.Reader, stdout io.Writer) PipeAttachable

func (PipeAttachable) IO ¶

func (p PipeAttachable) IO(srv Pipe_IOServer) error

func (PipeAttachable) Register ¶

func (p PipeAttachable) Register(srv *grpc.Server)

type PipeClient ¶

type PipeClient interface {
	IO(ctx context.Context, opts ...grpc.CallOption) (Pipe_IOClient, error)
}

PipeClient is the client API for Pipe service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewPipeClient ¶

func NewPipeClient(cc *grpc.ClientConn) PipeClient

type PipeIO ¶

type PipeIO struct {
	GRPC interface {
		Send(*Data) error
		Recv() (*Data, error)
	}
	// contains filtered or unexported fields
}

PipeIO transforms a Pipe_IOServer or a Pipe_IOClient into an io.ReadWriter

func (*PipeIO) Close ¶

func (pio *PipeIO) Close() error

func (*PipeIO) Read ¶

func (pio *PipeIO) Read(p []byte) (n int, err error)

func (*PipeIO) Write ¶

func (pio *PipeIO) Write(p []byte) (n int, err error)

type PipeServer ¶

type PipeServer interface {
	IO(Pipe_IOServer) error
}

PipeServer is the server API for Pipe service.

type Pipe_IOClient ¶

type Pipe_IOClient interface {
	Send(*Data) error
	Recv() (*Data, error)
	grpc.ClientStream
}

type Pipe_IOServer ¶

type Pipe_IOServer interface {
	Send(*Data) error
	Recv() (*Data, error)
	grpc.ServerStream
}

type UnimplementedPipeServer ¶

type UnimplementedPipeServer struct {
}

UnimplementedPipeServer can be embedded to have forward compatible implementations.

func (*UnimplementedPipeServer) IO ¶

func (*UnimplementedPipeServer) IO(srv Pipe_IOServer) error

Source Files ¶

View all Source files

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