streaming

Documentation

Index

• Variables
• func RegisterStreamingServer(s grpc.ServiceRegistrar, srv StreamingServer)
• type StreamInit
  • func (*StreamInit) Descriptor() ([]byte, []int)
  • func (x *StreamInit) GetID() string
  • func (*StreamInit) ProtoMessage()
  • func (x *StreamInit) ProtoReflect() protoreflect.Message
  • func (x *StreamInit) Reset()
  • func (x *StreamInit) String() string
• type StreamingClient
  • func NewStreamingClient(cc grpc.ClientConnInterface) StreamingClient
• type StreamingServer
• type Streaming_StreamClient
• type Streaming_StreamServer
• type UnimplementedStreamingServer
  • func (UnimplementedStreamingServer) Stream(Streaming_StreamServer) error
• type UnsafeStreamingServer

Variables

var File_github_com_containerd_containerd_api_services_streaming_v1_streaming_proto protoreflect.FileDescriptor

var Streaming_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "containerd.services.streaming.v1.Streaming",
	HandlerType: (*StreamingServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Stream",
			Handler:       _Streaming_Stream_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "github.com/containerd/containerd/api/services/streaming/v1/streaming.proto",
}

Streaming_ServiceDesc is the grpc.ServiceDesc for Streaming service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterStreamingServer

func RegisterStreamingServer(s grpc.ServiceRegistrar, srv StreamingServer)

Types

type StreamInit

type StreamInit struct {
	ID string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamInit) Descriptor

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

Deprecated: Use StreamInit.ProtoReflect.Descriptor instead.

func (*StreamInit) GetID

func (x *StreamInit) GetID() string

func (*StreamInit) ProtoMessage

func (*StreamInit) ProtoMessage()

func (*StreamInit) ProtoReflect

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

func (*StreamInit) Reset

func (x *StreamInit) Reset()

func (*StreamInit) String

func (x *StreamInit) String() string

type StreamingClient

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

StreamingClient is the client API for Streaming service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewStreamingClient

func NewStreamingClient(cc grpc.ClientConnInterface) StreamingClient

type StreamingServer

type StreamingServer interface {
	Stream(Streaming_StreamServer) error
	// contains filtered or unexported methods
}

StreamingServer is the server API for Streaming service. All implementations must embed UnimplementedStreamingServer for forward compatibility

type Streaming_StreamClient

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

type Streaming_StreamServer

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

type UnimplementedStreamingServer

type UnimplementedStreamingServer struct {
}

UnimplementedStreamingServer must be embedded to have forward compatible implementations.

func (UnimplementedStreamingServer) Stream

func (UnimplementedStreamingServer) Stream(Streaming_StreamServer) error

type UnsafeStreamingServer

type UnsafeStreamingServer interface {
	// contains filtered or unexported methods
}

UnsafeStreamingServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to StreamingServer will result in compilation errors.