cephd

Documentation

Index

• Variables
• func GetCephdError(err int) error
• func New() *ceph
• func RadosVersion() (int, int, int)
• func RunCommand(command string, args []string) error
• func Version() string
• type IOContext
  • func (ioctx *IOContext) CreateImage(name string, size uint64, order int, args ...uint64) (image client.Image, err error)
  • func (ioctx *IOContext) Destroy()
  • func (ioctx *IOContext) GetImage(name string) client.Image
  • func (ioctx *IOContext) GetImageNames() (names []string, err error)
  • func (ioctx *IOContext) Pointer() uintptr
  • func (ioctx *IOContext) Read(oid string, data []byte, offset uint64) (int, error)
  • func (ioctx *IOContext) Write(oid string, data []byte, offset uint64) error
  • func (ioctx *IOContext) WriteFull(oid string, data []byte) error
• type Image
  • func (image *Image) Close() error
  • func (i *Image) Name() string
  • func (image *Image) Open(args ...interface{}) error
  • func (image *Image) Remove() error
  • func (image *Image) Stat() (info *client.ImageInfo, err error)

Variables

var RbdErrorImageNotOpen = errors.New("RBD image not open")

var RbdErrorNotFound = errors.New("RBD image not found")

Functions

func GetCephdError

func GetCephdError(err int) error

func New

func New() *ceph

func RadosVersion

func RadosVersion() (int, int, int)

Version returns the major, minor, and patch components of the version of the RADOS library linked against.

func RunCommand

func RunCommand(command string, args []string) error

run a command in libcephd

func Version

func Version() string

Version returns the version of Ceph

Types

type IOContext

type IOContext struct {
	// contains filtered or unexported fields
}

IOContext represents a context for performing I/O within a pool.

func (*IOContext) CreateImage

func (ioctx *IOContext) CreateImage(name string, size uint64, order int,
	args ...uint64) (image client.Image, err error)

int rbd_create(rados_ioctx_t io, const char *name, uint64_t size, int *order); int rbd_create2(rados_ioctx_t io, const char *name, uint64_t size,

uint64_t features, int *order);

int rbd_create3(rados_ioctx_t io, const char *name, uint64_t size,

uint64_t features, int *order,
uint64_t stripe_unit, uint64_t stripe_count);

func (*IOContext) Destroy

func (ioctx *IOContext) Destroy()

Destroy informs librados that the I/O context is no longer in use. Resources associated with the context may not be freed immediately, and the context should not be used again after calling this method.

func (*IOContext) GetImage

func (ioctx *IOContext) GetImage(name string) client.Image

func (*IOContext) GetImageNames

func (ioctx *IOContext) GetImageNames() (names []string, err error)

GetImageNames returns the list of current RBD images.

func (*IOContext) Pointer

func (ioctx *IOContext) Pointer() uintptr

Pointer returns a uintptr representation of the IOContext.

func (*IOContext) Read

func (ioctx *IOContext) Read(oid string, data []byte, offset uint64) (int, error)

Read reads up to len(data) bytes from the object with key oid starting at byte offset offset. It returns the number of bytes read and an error, if any.

func (*IOContext) Write

func (ioctx *IOContext) Write(oid string, data []byte, offset uint64) error

Write writes len(data) bytes to the object with key oid starting at byte offset offset. It returns an error, if any.

func (*IOContext) WriteFull

func (ioctx *IOContext) WriteFull(oid string, data []byte) error

WriteFull writes len(data) bytes to the object with key oid. The object is filled with the provided data. If the object exists, it is atomically truncated and then written. It returns an error, if any.

type Image

type Image struct {
	io.Reader
	io.Writer
	io.Seeker
	io.ReaderAt
	io.WriterAt
	// contains filtered or unexported fields
}

**************** librbd ***************************

func (*Image) Close

func (image *Image) Close() error

int rbd_close(rbd_image_t image);

func (*Image) Name

func (i *Image) Name() string

func (*Image) Open

func (image *Image) Open(args ...interface{}) error

int rbd_open(rados_ioctx_t io, const char *name, rbd_image_t *image, const char *snap_name); int rbd_open_read_only(rados_ioctx_t io, const char *name, rbd_image_t *image,

const char *snap_name);

func (*Image) Remove

func (image *Image) Remove() error

int rbd_remove(rados_ioctx_t io, const char *name); int rbd_remove_with_progress(rados_ioctx_t io, const char *name,

librbd_progress_fn_t cb, void *cbdata);

func (*Image) Stat

func (image *Image) Stat() (info *client.ImageInfo, err error)

int rbd_stat(rbd_image_t image, rbd_image_info_t *info, size_t infosize);