package transfer

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

Index ¶

• Variables
• func RegisterTransferServer(s grpc.ServiceRegistrar, srv TransferServer)
• type TransferClient
• func NewTransferClient(cc grpc.ClientConnInterface) TransferClient
• type TransferOptions
• func (*TransferOptions) Descriptor() ([]byte, []int)
• func (x *TransferOptions) GetProgressStream() string
• func (*TransferOptions) ProtoMessage()
• func (x *TransferOptions) ProtoReflect() protoreflect.Message
• func (x *TransferOptions) Reset()
• func (x *TransferOptions) String() string
• type TransferRequest
• func (*TransferRequest) Descriptor() ([]byte, []int)
• func (x *TransferRequest) GetDestination() *anypb.Any
• func (x *TransferRequest) GetOptions() *TransferOptions
• func (x *TransferRequest) GetSource() *anypb.Any
• func (*TransferRequest) ProtoMessage()
• func (x *TransferRequest) ProtoReflect() protoreflect.Message
• func (x *TransferRequest) Reset()
• func (x *TransferRequest) String() string
• type TransferServer
• type UnimplementedTransferServer
• func (UnimplementedTransferServer) Transfer(context.Context, *TransferRequest) (*emptypb.Empty, error)
• type UnsafeTransferServer

Variables ¶

var File_github_com_containerd_containerd_api_services_transfer_v1_transfer_proto protoreflect.FileDescriptor

var Transfer_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "containerd.services.transfer.v1.Transfer",
	HandlerType: (*TransferServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Transfer",
			Handler:    _Transfer_Transfer_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "github.com/containerd/containerd/api/services/transfer/v1/transfer.proto",
}

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

Functions ¶

func RegisterTransferServer ¶

func RegisterTransferServer(s grpc.ServiceRegistrar, srv TransferServer)

Types ¶

type TransferClient ¶

type TransferClient interface {
	Transfer(ctx context.Context, in *TransferRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

TransferClient is the client API for Transfer 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 NewTransferClient ¶

func NewTransferClient(cc grpc.ClientConnInterface) TransferClient

type TransferOptions ¶

type TransferOptions struct {
	ProgressStream string `protobuf:"bytes,1,opt,name=progress_stream,json=progressStream,proto3" json:"progress_stream,omitempty"` // Progress min interval
	// contains filtered or unexported fields
}

func (*TransferOptions) Descriptor ¶

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

Deprecated: Use TransferOptions.ProtoReflect.Descriptor instead.

func (*TransferOptions) GetProgressStream ¶

func (x *TransferOptions) GetProgressStream() string

func (*TransferOptions) ProtoMessage ¶

func (*TransferOptions) ProtoMessage()

func (*TransferOptions) ProtoReflect ¶

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

func (*TransferOptions) Reset ¶

func (x *TransferOptions) Reset()

func (*TransferOptions) String ¶

func (x *TransferOptions) String() string

type TransferRequest ¶

type TransferRequest struct {
	Source      *anypb.Any       `protobuf:"bytes,1,opt,name=source,proto3" json:"source,omitempty"`
	Destination *anypb.Any       `protobuf:"bytes,2,opt,name=destination,proto3" json:"destination,omitempty"`
	Options     *TransferOptions `protobuf:"bytes,3,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

func (*TransferRequest) Descriptor ¶

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

Deprecated: Use TransferRequest.ProtoReflect.Descriptor instead.

func (*TransferRequest) GetDestination ¶

func (x *TransferRequest) GetDestination() *anypb.Any

func (*TransferRequest) GetOptions ¶

func (x *TransferRequest) GetOptions() *TransferOptions

func (*TransferRequest) GetSource ¶

func (x *TransferRequest) GetSource() *anypb.Any

func (*TransferRequest) ProtoMessage ¶

func (*TransferRequest) ProtoMessage()

func (*TransferRequest) ProtoReflect ¶

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

func (*TransferRequest) Reset ¶

func (x *TransferRequest) Reset()

func (*TransferRequest) String ¶

func (x *TransferRequest) String() string

type TransferServer ¶

type TransferServer interface {
	Transfer(context.Context, *TransferRequest) (*emptypb.Empty, error)
	// contains filtered or unexported methods
}

TransferServer is the server API for Transfer service. All implementations must embed UnimplementedTransferServer for forward compatibility

type UnimplementedTransferServer ¶

type UnimplementedTransferServer struct {
}

UnimplementedTransferServer must be embedded to have forward compatible implementations.

func (UnimplementedTransferServer) Transfer ¶

func (UnimplementedTransferServer) Transfer(context.Context, *TransferRequest) (*emptypb.Empty, error)

type UnsafeTransferServer ¶

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

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

Source Files ¶

doc.go transfer.pb.go transfer_grpc.pb.go