storagetest

Dec 9, 2022

Changes in this version

type NonStorage

+ ID component.ID

type TestStorage

+ ID component.ID

Aug 31, 2022

Changes in this version

+ func CreatorID(ctx context.Context, client storage.Client) (config.ComponentID, error)

+ func NewNonStorageID(name string) config.ComponentID

+ func NewStorageID(name string) config.ComponentID

+ type NonStorage struct

+ func NewNonStorageExtension(name string) *NonStorage

+ func (ns *NonStorage) Shutdown(context.Context) error

+ func (ns *NonStorage) Start(context.Context, component.Host) error

type StorageHost

+ func (h *StorageHost) WithExtension(id config.ComponentID, ext component.Extension) *StorageHost

+ func (h *StorageHost) WithFileBackedStorageExtension(name, storageDir string) *StorageHost

+ func (h *StorageHost) WithInMemoryStorageExtension(name string) *StorageHost

+ func (h *StorageHost) WithNonStorageExtension(name string) *StorageHost

+ type TestClient struct

+ func NewFileBackedClient(kind component.Kind, id config.ComponentID, name string, storageDir string) *TestClient

+ func NewInMemoryClient(kind component.Kind, id config.ComponentID, name string) *TestClient

+ func (p *TestClient) Batch(_ context.Context, ops ...storage.Operation) error

+ func (p *TestClient) Close(_ context.Context) error

+ func (p *TestClient) Delete(_ context.Context, key string) error

+ func (p *TestClient) Get(_ context.Context, key string) ([]byte, error)

+ func (p *TestClient) Set(_ context.Context, key string, value []byte) error

+ type TestStorage struct

+ func NewFileBackedStorageExtension(name string, storageDir string) *TestStorage

+ func NewInMemoryStorageExtension(name string) *TestStorage

+ func (s *TestStorage) GetClient(ctx context.Context, kind component.Kind, ent config.ComponentID, name string) (storage.Client, error)

+ func (s *TestStorage) Shutdown(ctx context.Context) error

+ func (s *TestStorage) Start(context.Context, component.Host) error

May 18, 2021

Changes in this version

+ func NewTestExtension(t *testing.T, directory string) storage.Extension

+ type StorageHost struct

+ func NewStorageHost(t *testing.T, directory string, extensionNames ...string) StorageHost

+ func (h StorageHost) GetExtensions() map[config.ComponentID]component.Extension