wrapper

Documentation

Index

• type Config
• type StorageProvider
  • func New(config Config) *StorageProvider
  • func (s *StorageProvider) Close() (err error)
  • func (s *StorageProvider) GetOpenStores() []storage.Store
  • func (s *StorageProvider) GetStoreConfig(name string) (storage.StoreConfiguration, error)
  • func (s *StorageProvider) ID() string
  • func (s *StorageProvider) Init() (err error)
  • func (s *StorageProvider) Key() string
  • func (s *StorageProvider) OpenStore(name string) (storage.Store, error)
  • func (s *StorageProvider) SetStoreConfig(name string, config storage.StoreConfiguration) error
• type Store

Types

type Config

type Config struct {
	Key       string
	FileName  string
	FilePath  string
	BucketIDs []string
}

type StorageProvider

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

func New

func New(config Config) *StorageProvider

func (*StorageProvider) Close

func (s *StorageProvider) Close() (err error)

func (*StorageProvider) GetOpenStores

func (s *StorageProvider) GetOpenStores() []storage.Store

func (*StorageProvider) GetStoreConfig

func (s *StorageProvider) GetStoreConfig(name string) (storage.StoreConfiguration, error)

func (*StorageProvider) ID

func (s *StorageProvider) ID() string

func (*StorageProvider) Init

func (s *StorageProvider) Init() (err error)

func (*StorageProvider) Key

func (s *StorageProvider) Key() string

func (*StorageProvider) OpenStore

func (s *StorageProvider) OpenStore(name string) (storage.Store, error)

Used by AFGO through StorageProvider interface

func (*StorageProvider) SetStoreConfig

func (s *StorageProvider) SetStoreConfig(name string, config storage.StoreConfiguration) error

AFGO StorageProvider placeholder implementations

type Store

type Store interface {
	storage.Store
	GetAll(transform db.Filter) ([][]byte, error)
}