| Package | Description |
|---|---|
| com.ceph.rados | |
| com.ceph.rados.exceptions | |
| com.ceph.radosstriper |
| Modifier and Type | Method and Description |
|---|---|
void |
IoCTX.aioFlush()
Block until all pending writes in an io context are safe.
|
void |
IoCTX.aioWrite(String oid,
Completion completion,
byte[] buf)
Asynchronously write to an object without an offset
|
void |
IoCTX.aioWrite(String oid,
Completion completion,
byte[] buf,
long offset)
Asynchronously write to an object
|
void |
IoCTX.aioWrite(String oid,
Completion completion,
String buf)
Asynchronously write to an object without an offset
|
void |
IoCTX.aioWrite(String oid,
Completion completion,
String buf,
long offset)
Asynchronously write to an object without an offset
|
void |
IoCTX.aioWriteFull(String oid,
Completion completion,
byte[] buf,
int len)
Asynchronously write an entire object
The object is filled with the provided data.
|
void |
IoCTX.append(String oid,
byte[] buf)
Append data to an object
|
void |
IoCTX.append(String oid,
byte[] buf,
int len) |
void |
IoCTX.append(String oid,
String buf)
Append data to an object
|
void |
IoCTX.clone(String dst,
long dst_off,
String src,
long src_off,
long len)
Efficiently copy a portion of one object to another
If the underlying filesystem on the OSD supports it, this will be a
copy-on-write clone.
|
String |
Rados.clusterFsid()
Get the cluster's fsid
|
RadosClusterInfo |
Rados.clusterStat()
Get the cluster stats
|
String |
Rados.confGet(String option)
Retrieve a RADOS configuration option's value
|
void |
Rados.confReadFile(File file)
Read a Ceph configuration file
|
void |
Rados.confSet(String option,
String value)
Set a RADOS configuration option
|
void |
Rados.connect()
Connect to the Ceph cluster
|
Rados.RadosCommandResult |
Rados.executeRadosMonCommand(String[] commands,
String in)
Executes commands in module: 'mon'
To list commands execute "get_command_descriptions"
|
Rados.RadosCommandResult |
Rados.executeRadosMonCommandTarget(String[] commands,
String target,
String in)
Executes commands in module: 'mon'
To list commands execute "get_command_descriptions"
|
Rados.RadosCommandResult |
Rados.executeRadosOsdCommand(String[] commands,
int osdId,
String in)
Executes commands in module: 'osd'
To list commands execute "get_command_descriptions"
|
long |
IoCTX.getAuid()
Get the associated auid owner of the current pool
|
String |
IoCTX.getExtendedAttribute(String oid,
String xattrName)
Get the value of an extended attribute on an object.
|
Map<String,String> |
IoCTX.getExtendedAttributes(String oid)
Get all extended attributes on an object.
|
long |
Rados.getInstanceId()
Get the global unique ID of the current connection
|
String |
IoCTX.getPoolName()
Get the pool name of the context
|
protected <T extends Number> |
RadosBase.handleReturnCode(Callable<T> callable,
String errorMsg,
Object... errorMsgArgs) |
IoCTX |
Rados.ioCtxCreate(String pool)
Create a IoCTX
|
String[] |
IoCTX.listObjects()
List all objects in a pool
|
ListCtx |
IoCTX.listObjectsPartial(int limit)
List all objects in a pool by piece.
|
int |
ListCtx.nextObjects()
List a subset of objects in a pool
|
int |
ListCtx.nextObjects(long skip)
List a subset of objects in a pool after skipping a set of ids
|
void |
ReadOp.operate(String oid,
int flags)
Executes operations added to the rados_read_op_t.
|
void |
Rados.poolCreate(String name)
Create a RADOS pool
|
void |
Rados.poolCreate(String name,
long auid)
Create a RADOS pool and set a auid
|
void |
Rados.poolCreate(String name,
long auid,
long crushrule)
Create a RADOS pool and set a auid and crushrule
|
void |
Rados.poolDelete(String name)
Delete a RADOS pool
|
String[] |
Rados.poolList()
List all the RADOS pools
|
long |
Rados.poolLookup(String name)
Get the ID of a RADOS pool
|
String |
Rados.poolReverseLookup(long id)
Get the name of a RADOS pool
|
RadosPoolInfo |
IoCTX.poolStat()
Stat the currently open pool
|
ReadOp.ReadResult |
ReadOp.queueRead(long offset,
long len)
Add a read operation to the rados_read_op_t via rados_read_op_read.
|
void |
ReadOp.ReadResult.raiseExceptionOnError(String errorMsg,
Object... errorMsgArgs)
Use this method if you do error handling with exceptions.
|
int |
IoCTX.read(String oid,
int length,
long offset,
byte[] buf)
Read data from an object
|
void |
IoCTX.remove(String oid)
Remove an object
|
void |
IoCTX.removeExtendedAttribute(String oid,
String xattrName)
Delete an extended attribute from an object.
|
void |
IoCTX.setAuid(long auid)
Set the associated auid owner of the current pool
|
void |
IoCTX.setExtendedAttribute(String oid,
String xattrName,
String val)
Set an extended attribute on an object.
|
void |
IoCTX.snapCreate(String snapname)
Create a snapshot
|
String |
IoCTX.snapGetName(long id)
Get the name of a snapshot by it's ID
|
long |
IoCTX.snapGetStamp(long id)
Get the timestamp of a snapshot
|
Long[] |
IoCTX.snapList()
List all snapshots
|
long |
IoCTX.snapLookup(String snapname)
Get the ID of a snapshot
|
void |
IoCTX.snapRemove(String snapname)
Remove a snapshot
|
RadosObjectInfo |
IoCTX.stat(String oid)
Stat an object
|
static void |
RadosBase.throwException(int errorCode,
String msg) |
void |
IoCTX.truncate(String oid,
long size)
Resize an object
|
void |
Completion.waitForComplete()
Block until the operation completes.
|
void |
Completion.waitForSafe()
Block until the operation is safe.
|
void |
IoCTX.write(String oid,
byte[] buf)
Write to an object without an offset
|
void |
IoCTX.write(String oid,
byte[] buf,
long offset)
Write to an object
|
void |
IoCTX.write(String oid,
String buf)
Write to an object without an offset
|
void |
IoCTX.write(String oid,
String buf,
long offset)
Write to an object without an offset
|
void |
IoCTX.writeFull(String oid,
byte[] buf,
int len)
Write an entire object
The object is filled with the provided data.
|
| Constructor and Description |
|---|
Completion(boolean notifyOnComplete,
boolean notifyOnSafe)
Constructs a completion to use with asynchronous operations.
|
| Modifier and Type | Class and Description |
|---|---|
class |
RadosAlreadyConnectedException
Thrown when an operation is being called which is not allowed
in a already connected state.
|
class |
RadosArgumentOutOfDomainException
Thrown when an argument is out of domain
|
class |
RadosInvalidArgumentException
Thrown when a invalid argument is being passed
|
class |
RadosNotFoundException
Thrown when not able to found given object
|
class |
RadosOperationInProgressException
Thrown when a operation is being called which is already in progress, e.g.
|
class |
RadosPermissionException
Thrown when an operation it not permitted
|
class |
RadosReadOnlyException
Thrown when only ready only operations are allowed
|
class |
RadosTimeoutException
Thrown when a timeout occurs
|
| Modifier and Type | Method and Description |
|---|---|
void |
IoCTXStriper.append(String oid,
byte[] buf)
Append data to an object
|
void |
IoCTXStriper.append(String oid,
byte[] buf,
int len) |
void |
IoCTXStriper.append(String oid,
String buf)
Append data to an object
|
String |
IoCTXStriper.getExtendedAttribute(String oid,
String xattrName)
Get the value of an extended attribute on an object.
|
IoCTXStriper |
RadosStriper.ioCtxCreateStriper(IoCTX ioCTX) |
int |
IoCTXStriper.read(String oid,
int length,
long offset,
byte[] buf)
Read data from an object
|
void |
IoCTXStriper.remove(String oid)
Remove an object
|
void |
IoCTXStriper.removeExtendedAttribute(String oid,
String xattrName)
Delete an extended attribute from an object.
|
void |
IoCTXStriper.setExtendedAttribute(String oid,
String xattrName,
String val)
Set an extended attribute on an object.
|
int |
IoCTXStriper.setStripeCount(int stripeCount)
Sets the object layout's stripe count of a rados striper for future objects.
|
int |
IoCTXStriper.setStripeObjectSize(int stripeObjectSize)
Sets the object layout's object_size of a rados striper for future objects.
|
int |
IoCTXStriper.setStripeUnit(int stripeUnit)
Sets the object layout's stripe unit of a rados striper for future objects.
|
RadosObjectInfo |
IoCTXStriper.stat(String oid)
Stat an object
|
void |
IoCTXStriper.truncate(String oid,
long size)
Resize an object
|
void |
IoCTXStriper.write(String oid,
byte[] buf)
Write to an object without an offset
|
void |
IoCTXStriper.write(String oid,
byte[] buf,
int length,
long offset)
Write to an object
|
void |
IoCTXStriper.write(String oid,
byte[] buf,
long offset)
Write to an object
|
void |
IoCTXStriper.write(String oid,
String buf)
Write to an object without an offset
|
void |
IoCTXStriper.write(String oid,
String buf,
long offset)
Write to an object without an offset
|
void |
IoCTXStriper.writeFull(String oid,
byte[] buf,
int len)
Write an entire object
The object is filled with the provided data.
|
Copyright © 2020. All rights reserved.