storage

Documentation

Index

• func NewStoragePlugin() ds.Datastore
• type StoragePlugin
• type StorePlugin
  • func (s *StorePlugin) Close() error
  • func (s *StorePlugin) Delete(ctx context.Context, key ds.Key) error
  • func (s *StorePlugin) Get(ctx context.Context, key ds.Key) (value []byte, err error)
  • func (s *StorePlugin) GetSize(ctx context.Context, key ds.Key) (size int, err error)
  • func (s *StorePlugin) Has(ctx context.Context, key ds.Key) (exists bool, err error)
  • func (s *StorePlugin) Put(ctx context.Context, key ds.Key, value []byte) error
  • func (s *StorePlugin) Query(ctx context.Context, q query.Query) (query.Results, error)
  • func (s *StorePlugin) Sync(ctx context.Context, prefix ds.Key) error

Functions

func NewStoragePlugin

func NewStoragePlugin() ds.Datastore

Types

type StoragePlugin

type StoragePlugin interface {
	store.Storage
	store.StorageOptions
	store.Query
	store.Iterator
}

type StorePlugin

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

func (*StorePlugin) Close

func (s *StorePlugin) Close() error

func (*StorePlugin) Delete

func (s *StorePlugin) Delete(ctx context.Context, key ds.Key) error

func (*StorePlugin) Get

func (s *StorePlugin) Get(ctx context.Context, key ds.Key) (value []byte, err error)

func (*StorePlugin) GetSize

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

func (*StorePlugin) Has

func (s *StorePlugin) Has(ctx context.Context, key ds.Key) (exists bool, err error)

func (*StorePlugin) Put

func (s *StorePlugin) Put(ctx context.Context, key ds.Key, value []byte) error

func (*StorePlugin) Query

func (s *StorePlugin) Query(ctx context.Context, q query.Query) (query.Results, error)

func (*StorePlugin) Sync

func (s *StorePlugin) Sync(ctx context.Context, prefix ds.Key) error