storetest

Documentation

Overview

Package storetest provides the utility functions of config store for testing. Shouldn't be imported outside of the test.

Index

• func SetupStoreForTest(data ...string) (store.Store, error)
• type Memstore
  • func NewMemstore() *Memstore
  • func (m *Memstore) Delete(k store.Key)
  • func (m *Memstore) Get(key store.Key) (*store.BackEndResource, error)
  • func (m *Memstore) Init(kinds []string) error
  • func (m *Memstore) List() map[store.Key]*store.BackEndResource
  • func (m *Memstore) Put(r *store.BackEndResource)
  • func (m *Memstore) Stop()
  • func (m *Memstore) WaitForSynced(time.Duration) error
  • func (m *Memstore) Watch() (<-chan store.BackendEvent, error)

Functions

func SetupStoreForTest

func SetupStoreForTest(data ...string) (store.Store, error)

SetupStoreForTest creates an on-memory store backend, initializes its data with the specified specs, and returns a new store with the backend. Note that this store can't change, Watch does not emit any events.

Types

type Memstore

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

Memstore is an on-memory store backend. Used only for testing.

func NewMemstore

func NewMemstore() *Memstore

NewMemstore creates a new Memstore instance.

func (*Memstore) Delete

func (m *Memstore) Delete(k store.Key)

Delete removes a resource for the specified key from the memstore.

func (*Memstore) Get

func (m *Memstore) Get(key store.Key) (*store.BackEndResource, error)

Get implements store.Backend interface.

func (*Memstore) Init

func (m *Memstore) Init(kinds []string) error

Init implements store.Backend interface.

func (*Memstore) List

func (m *Memstore) List() map[store.Key]*store.BackEndResource

List implements store.Backend interface.

func (*Memstore) Put

func (m *Memstore) Put(r *store.BackEndResource)

Put adds a new resource to the memstore.

func (*Memstore) Stop

func (m *Memstore) Stop()

Stop implements store.Backend interface.

func (*Memstore) WaitForSynced

func (m *Memstore) WaitForSynced(time.Duration) error

WaitForSynced implements store.Backend interface

func (*Memstore) Watch

func (m *Memstore) Watch() (<-chan store.BackendEvent, error)

Watch implements store.Backend interface.