v1

Documentation

Index

• Variables
• func RegisterStreamingServer(s *grpc.Server, srv StreamingServer)
• type BytesMessage
  • func (*BytesMessage) Descriptor() ([]byte, []int)
  • func (x *BytesMessage) GetType() IOStream
  • func (x *BytesMessage) GetValue() []byte
  • func (*BytesMessage) ProtoMessage()
  • func (x *BytesMessage) ProtoReflect() protoreflect.Message
  • func (x *BytesMessage) Reset()
  • func (x *BytesMessage) String() string
• type ExitMessage
  • func (*ExitMessage) Descriptor() ([]byte, []int)
  • func (x *ExitMessage) GetStatus() uint32
  • func (*ExitMessage) ProtoMessage()
  • func (x *ExitMessage) ProtoReflect() protoreflect.Message
  • func (x *ExitMessage) Reset()
  • func (x *ExitMessage) String() string
• type IOStream
  • func (IOStream) Descriptor() protoreflect.EnumDescriptor
  • func (x IOStream) Enum() *IOStream
  • func (IOStream) EnumDescriptor() ([]byte, []int)
  • func (x IOStream) Number() protoreflect.EnumNumber
  • func (x IOStream) String() string
  • func (IOStream) Type() protoreflect.EnumType
• type ResizeMessage
  • func (*ResizeMessage) Descriptor() ([]byte, []int)
  • func (x *ResizeMessage) GetHeight() uint32
  • func (x *ResizeMessage) GetWidth() uint32
  • func (*ResizeMessage) ProtoMessage()
  • func (x *ResizeMessage) ProtoReflect() protoreflect.Message
  • func (x *ResizeMessage) Reset()
  • func (x *ResizeMessage) String() string
• type StreamingClient
  • func NewStreamingClient(cc grpc.ClientConnInterface) StreamingClient
• type StreamingServer
• type Streaming_NewStreamClient
• type Streaming_NewStreamServer
• type UnimplementedStreamingServer
  • func (*UnimplementedStreamingServer) NewStream(Streaming_NewStreamServer) error

Variables

var (
	IOStream_name = map[int32]string{
		0: "STDIN",
		1: "STDOUT",
		2: "STDERR",
	}
	IOStream_value = map[string]int32{
		"STDIN":  0,
		"STDOUT": 1,
		"STDERR": 2,
	}
)

Enum value maps for IOStream.

var File_cli_server_protos_streams_v1_streams_proto protoreflect.FileDescriptor

Functions

func RegisterStreamingServer

func RegisterStreamingServer(s *grpc.Server, srv StreamingServer)

Types

type BytesMessage

type BytesMessage struct {
	Type  IOStream `protobuf:"varint,1,opt,name=type,proto3,enum=com.docker.api.protos.streams.v1.IOStream" json:"type,omitempty"`
	Value []byte   `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*BytesMessage) Descriptor

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

Deprecated: Use BytesMessage.ProtoReflect.Descriptor instead.

func (*BytesMessage) GetType

func (x *BytesMessage) GetType() IOStream

func (*BytesMessage) GetValue

func (x *BytesMessage) GetValue() []byte

func (*BytesMessage) ProtoMessage

func (*BytesMessage) ProtoMessage()

func (*BytesMessage) ProtoReflect

func (x *BytesMessage) ProtoReflect() protoreflect.Message

func (*BytesMessage) Reset

func (x *BytesMessage) Reset()

func (*BytesMessage) String

func (x *BytesMessage) String() string

type ExitMessage

type ExitMessage struct {
	Status uint32 `protobuf:"varint,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*ExitMessage) Descriptor

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

Deprecated: Use ExitMessage.ProtoReflect.Descriptor instead.

func (*ExitMessage) GetStatus

func (x *ExitMessage) GetStatus() uint32

func (*ExitMessage) ProtoMessage

func (*ExitMessage) ProtoMessage()

func (*ExitMessage) ProtoReflect

func (x *ExitMessage) ProtoReflect() protoreflect.Message

func (*ExitMessage) Reset

func (x *ExitMessage) Reset()

func (*ExitMessage) String

func (x *ExitMessage) String() string

type IOStream

type IOStream int32

const (
	IOStream_STDIN  IOStream = 0
	IOStream_STDOUT IOStream = 1
	IOStream_STDERR IOStream = 2
)

func (IOStream) Descriptor

func (IOStream) Descriptor() protoreflect.EnumDescriptor

func (IOStream) Enum

func (x IOStream) Enum() *IOStream

func (IOStream) EnumDescriptor

func (IOStream) EnumDescriptor() ([]byte, []int)

Deprecated: Use IOStream.Descriptor instead.

func (IOStream) Number

func (x IOStream) Number() protoreflect.EnumNumber

func (IOStream) String

func (x IOStream) String() string

func (IOStream) Type

func (IOStream) Type() protoreflect.EnumType

type ResizeMessage

type ResizeMessage struct {
	Width  uint32 `protobuf:"varint,1,opt,name=width,proto3" json:"width,omitempty"`
	Height uint32 `protobuf:"varint,2,opt,name=height,proto3" json:"height,omitempty"`
	// contains filtered or unexported fields
}

func (*ResizeMessage) Descriptor

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

Deprecated: Use ResizeMessage.ProtoReflect.Descriptor instead.

func (*ResizeMessage) GetHeight

func (x *ResizeMessage) GetHeight() uint32

func (*ResizeMessage) GetWidth

func (x *ResizeMessage) GetWidth() uint32

func (*ResizeMessage) ProtoMessage

func (*ResizeMessage) ProtoMessage()

func (*ResizeMessage) ProtoReflect

func (x *ResizeMessage) ProtoReflect() protoreflect.Message

func (*ResizeMessage) Reset

func (x *ResizeMessage) Reset()

func (*ResizeMessage) String

func (x *ResizeMessage) String() string

type StreamingClient

type StreamingClient interface {
	NewStream(ctx context.Context, opts ...grpc.CallOption) (Streaming_NewStreamClient, error)
}

StreamingClient is the client API for Streaming service.

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

func NewStreamingClient

func NewStreamingClient(cc grpc.ClientConnInterface) StreamingClient

type StreamingServer

type StreamingServer interface {
	NewStream(Streaming_NewStreamServer) error
}

StreamingServer is the server API for Streaming service.

type Streaming_NewStreamClient

type Streaming_NewStreamClient interface {
	Send(*anypb.Any) error
	Recv() (*anypb.Any, error)
	grpc.ClientStream
}

type Streaming_NewStreamServer

type Streaming_NewStreamServer interface {
	Send(*anypb.Any) error
	Recv() (*anypb.Any, error)
	grpc.ServerStream
}

type UnimplementedStreamingServer

type UnimplementedStreamingServer struct {
}

UnimplementedStreamingServer can be embedded to have forward compatible implementations.

func (*UnimplementedStreamingServer) NewStream

func (*UnimplementedStreamingServer) NewStream(Streaming_NewStreamServer) error