package streaming

import "github.com/containerd/containerd/api/services/streaming/v1"

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.

Source Files ¶

doc.go streaming.pb.go streaming_grpc.pb.go