motrds

Documentation

Index

• type Config
• type MotrDatastore
  • func NewMotrDatastore(conf Config) (*MotrDatastore, error)
  • func (d *MotrDatastore) Batch(ctx context.Context) (ds.Batch, error)
  • func (d *MotrDatastore) Close() error
  • func (d *MotrDatastore) Delete(ctx context.Context, key ds.Key) (err error)
  • func (d *MotrDatastore) DiskUsage(ctx context.Context) (uint64, error)
  • func (d *MotrDatastore) Get(ctx context.Context, key ds.Key) ([]byte, error)
  • func (d *MotrDatastore) GetSize(ctx context.Context, key ds.Key) (size int, err error)
  • func (d *MotrDatastore) Has(ctx context.Context, key ds.Key) (bool, error)
  • func (d *MotrDatastore) Put(ctx context.Context, key ds.Key, value []byte) (err error)
  • func (d *MotrDatastore) Query(ctx context.Context, q query.Query) (query.Results, error)
  • func (d *MotrDatastore) Sync(ctx context.Context, prefix ds.Key) error

Types

type Config

type Config struct {
	LocalAddr       string
	HaxAddr         string
	ProfileFid      string
	LocalProcessFid string
	Idx             string
	LevelDBPath     string
	Threads         int
	Trace           bool
}

type MotrDatastore

type MotrDatastore struct {
	Config
	mio.Mkv
	Ldb  leveldb.DB
	Lock *sync.RWMutex
}

func NewMotrDatastore

func NewMotrDatastore(conf Config) (*MotrDatastore, error)

func (*MotrDatastore) Batch

func (d *MotrDatastore) Batch(ctx context.Context) (ds.Batch, error)

func (*MotrDatastore) Close

func (d *MotrDatastore) Close() error

func (*MotrDatastore) Delete

func (d *MotrDatastore) Delete(ctx context.Context, key ds.Key) (err error)

func (*MotrDatastore) DiskUsage

func (d *MotrDatastore) DiskUsage(ctx context.Context) (uint64, error)

DiskUsage returns the current disk size used by this levelDB. For in-mem datastores, it will return 0.

func (*MotrDatastore) Get

func (d *MotrDatastore) Get(ctx context.Context, key ds.Key) ([]byte, error)

func (*MotrDatastore) GetSize

func (d *MotrDatastore) GetSize(ctx context.Context, key ds.Key) (size int, err error)

func (*MotrDatastore) Has

func (d *MotrDatastore) Has(ctx context.Context, key ds.Key) (bool, error)

func (*MotrDatastore) Put

func (d *MotrDatastore) Put(ctx context.Context, key ds.Key, value []byte) (err error)

func (*MotrDatastore) Query

func (d *MotrDatastore) Query(ctx context.Context, q query.Query) (query.Results, error)

Query the LevelDB metadata store for Motr keys and retrieve objects from Motr when data is requested

func (*MotrDatastore) Sync

func (d *MotrDatastore) Sync(ctx context.Context, prefix ds.Key) error