nebius.api.nebius.storage.v1alpha1.transfer_service_pb2_grpc.TransferService

class documentation

class TransferService(object): (source)

View In Hierarchy

TransferService provides functionality for creating and managing transfers that migrate data from other S3 providers or across different regions of Nebius Object Storage. Each transfer consists of consecutive iterations where the service lists objects in the source bucket and moves those that need to be transferred according to the specified overwrite strategy. After an iteration completes, the transfer will stop if its stop condition is met. Otherwise, it will wait for the defined inter-iteration interval before starting the next iteration.

Static Method Create Undocumented
Static Method Delete Undocumented
Static Method Get Undocumented
Static Method GetByName Undocumented
Static Method GetIterationHistory Undocumented
Static Method List Undocumented
Static Method Resume Undocumented
Static Method Stop Undocumented
Static Method Update Undocumented
@staticmethod
def Create(request, target, options=(), channel_credentials=None, call_credentials=None, insecure=False, compression=None, wait_for_ready=None, timeout=None, metadata=None): (source)

Undocumented

@staticmethod
def Delete(request, target, options=(), channel_credentials=None, call_credentials=None, insecure=False, compression=None, wait_for_ready=None, timeout=None, metadata=None): (source)

Undocumented

@staticmethod
def Get(request, target, options=(), channel_credentials=None, call_credentials=None, insecure=False, compression=None, wait_for_ready=None, timeout=None, metadata=None): (source)

Undocumented

@staticmethod
def GetByName(request, target, options=(), channel_credentials=None, call_credentials=None, insecure=False, compression=None, wait_for_ready=None, timeout=None, metadata=None): (source)

Undocumented

@staticmethod
def GetIterationHistory(request, target, options=(), channel_credentials=None, call_credentials=None, insecure=False, compression=None, wait_for_ready=None, timeout=None, metadata=None): (source)

Undocumented

@staticmethod
def List(request, target, options=(), channel_credentials=None, call_credentials=None, insecure=False, compression=None, wait_for_ready=None, timeout=None, metadata=None): (source)

Undocumented

@staticmethod
def Resume(request, target, options=(), channel_credentials=None, call_credentials=None, insecure=False, compression=None, wait_for_ready=None, timeout=None, metadata=None): (source)

Undocumented

@staticmethod
def Stop(request, target, options=(), channel_credentials=None, call_credentials=None, insecure=False, compression=None, wait_for_ready=None, timeout=None, metadata=None): (source)

Undocumented

@staticmethod
def Update(request, target, options=(), channel_credentials=None, call_credentials=None, insecure=False, compression=None, wait_for_ready=None, timeout=None, metadata=None): (source)

Undocumented