wrapper

Documentation

Index

• type ProviderWrapper
  • func NewProvider(p storage.Provider, dbType string) *ProviderWrapper
  • func (prov *ProviderWrapper) Close() error
  • func (prov *ProviderWrapper) GetOpenStores() []storage.Store
  • func (prov *ProviderWrapper) GetStoreConfig(name string) (storage.StoreConfiguration, error)
  • func (prov *ProviderWrapper) OpenStore(name string) (storage.Store, error)
  • func (prov *ProviderWrapper) SetStoreConfig(name string, config storage.StoreConfiguration) error
• type StoreWrapper
  • func NewStore(s storage.Store, dbType string) *StoreWrapper
  • func (store *StoreWrapper) Batch(operations []storage.Operation) error
  • func (store *StoreWrapper) Close() error
  • func (store *StoreWrapper) Delete(key string) error
  • func (store *StoreWrapper) Flush() error
  • func (store *StoreWrapper) Get(key string) ([]byte, error)
  • func (store *StoreWrapper) GetBulk(keys ...string) ([][]byte, error)
  • func (store *StoreWrapper) GetTags(key string) ([]storage.Tag, error)
  • func (store *StoreWrapper) Put(key string, value []byte, tags ...storage.Tag) error
  • func (store *StoreWrapper) Query(expression string, options ...storage.QueryOption) (storage.Iterator, error)

Types

type ProviderWrapper

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

ProviderWrapper wrap aries provider.

func NewProvider

func NewProvider(p storage.Provider, dbType string) *ProviderWrapper

NewProvider return new store provider wrapper.

func (*ProviderWrapper) Close

func (prov *ProviderWrapper) Close() error

Close provider.

func (*ProviderWrapper) GetOpenStores

func (prov *ProviderWrapper) GetOpenStores() []storage.Store

GetOpenStores get stores.

func (*ProviderWrapper) GetStoreConfig

func (prov *ProviderWrapper) GetStoreConfig(name string) (storage.StoreConfiguration, error)

GetStoreConfig get store config.

func (*ProviderWrapper) OpenStore

func (prov *ProviderWrapper) OpenStore(name string) (storage.Store, error)

OpenStore open store.

func (*ProviderWrapper) SetStoreConfig

func (prov *ProviderWrapper) SetStoreConfig(name string, config storage.StoreConfiguration) error

SetStoreConfig set store config.

type StoreWrapper

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

StoreWrapper wrap aries store.

func NewStore

func NewStore(s storage.Store, dbType string) *StoreWrapper

NewStore return new store wrapper.

func (*StoreWrapper) Batch

func (store *StoreWrapper) Batch(operations []storage.Operation) error

Batch data.

func (*StoreWrapper) Close

func (store *StoreWrapper) Close() error

Close store.

func (*StoreWrapper) Delete

func (store *StoreWrapper) Delete(key string) error

Delete data.

func (*StoreWrapper) Flush

func (store *StoreWrapper) Flush() error

Flush data.

func (*StoreWrapper) Get

func (store *StoreWrapper) Get(key string) ([]byte, error)

Get data.

func (*StoreWrapper) GetBulk

func (store *StoreWrapper) GetBulk(keys ...string) ([][]byte, error)

GetBulk get bulk.

func (*StoreWrapper) GetTags

func (store *StoreWrapper) GetTags(key string) ([]storage.Tag, error)

GetTags get tags.

func (*StoreWrapper) Put

func (store *StoreWrapper) Put(key string, value []byte, tags ...storage.Tag) error

Put data.

func (*StoreWrapper) Query

func (store *StoreWrapper) Query(expression string, options ...storage.QueryOption) (storage.Iterator, error)

Query from db.