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
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

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

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

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

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

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

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

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

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