▽

Package streaming

Variables

var File_github_com_containerd_containerd_api_services_streaming_v1_streaming_proto protoreflect.FileDescriptor

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)

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",
}

func RegisterStreamingServer ¶

func RegisterStreamingServer(s grpc.ServiceRegistrar, srv StreamingServer)

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 ¶

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.

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

func NewStreamingClient ¶

func NewStreamingClient(cc grpc.ClientConnInterface) StreamingClient

type StreamingServer ¶

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

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

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 ¶

UnimplementedStreamingServer must be embedded to have forward compatible implementations.

type UnimplementedStreamingServer struct {
}

func (UnimplementedStreamingServer) Stream ¶

func (UnimplementedStreamingServer) Stream(Streaming_StreamServer) error

type UnsafeStreamingServer ¶

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.

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