transfer

Documentation

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.