pcstoretest

Documentation

Index

• type FakePCStore
  • func NewFake() *FakePCStore
  • func (p *FakePCStore) Create(podID types.PodID, availabilityZone fields.AvailabilityZone, ...) (fields.PodCluster, error)
  • func (p *FakePCStore) Delete(id fields.ID) error
  • func (p *FakePCStore) FindWhereLabeled(podID types.PodID, availabilityZone fields.AvailabilityZone, ...) ([]fields.PodCluster, error)
  • func (p *FakePCStore) Get(id fields.ID) (fields.PodCluster, error)
  • func (p *FakePCStore) List() ([]fields.PodCluster, error)
  • func (p *FakePCStore) LockForSync(id fields.ID, syncerType pcstore.ConcreteSyncerType, session pcstore.Session) (consul.Unlocker, error)
  • func (p *FakePCStore) MutatePC(id fields.ID, mutator func(fields.PodCluster) (fields.PodCluster, error)) (fields.PodCluster, error)
  • func (p *FakePCStore) SetMetricsRegistry(_ pcstore.MetricsRegistry)
  • func (p *FakePCStore) Watch(quit <-chan struct{}) <-chan pcstore.WatchedPodClusters
  • func (p *FakePCStore) WatchAndSync(concrete pcstore.ConcreteSyncer, quit <-chan struct{}) error
  • func (p *FakePCStore) WatchPodCluster(id fields.ID, quit <-chan struct{}) <-chan pcstore.WatchedPodCluster

Types

type FakePCStore

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

Implementation of the pcstore.Store interface that can be used for unit testing

func NewFake

func NewFake() *FakePCStore

func (*FakePCStore) Create

func (p *FakePCStore) Create(
	podID types.PodID,
	availabilityZone fields.AvailabilityZone,
	clusterName fields.ClusterName,
	podSelector klabels.Selector,
	annotations fields.Annotations,
	strategy rc_fields.Strategy,
	minHealthPercentage fields.MinHealthPercentage,
	_ pcstore.Session,
) (fields.PodCluster, error)

func (*FakePCStore) Delete

func (p *FakePCStore) Delete(id fields.ID) error

func (*FakePCStore) FindWhereLabeled

func (p *FakePCStore) FindWhereLabeled(
	podID types.PodID,
	availabilityZone fields.AvailabilityZone,
	clusterName fields.ClusterName,
) ([]fields.PodCluster, error)

func (*FakePCStore) Get

func (p *FakePCStore) Get(id fields.ID) (fields.PodCluster, error)

func (*FakePCStore) List

func (p *FakePCStore) List() ([]fields.PodCluster, error)

func (*FakePCStore) LockForSync

func (p *FakePCStore) LockForSync(id fields.ID, syncerType pcstore.ConcreteSyncerType, session pcstore.Session) (consul.Unlocker, error)

func (*FakePCStore) MutatePC

func (p *FakePCStore) MutatePC(
	id fields.ID,
	mutator func(fields.PodCluster) (fields.PodCluster, error),
) (fields.PodCluster, error)

func (*FakePCStore) SetMetricsRegistry

func (p *FakePCStore) SetMetricsRegistry(_ pcstore.MetricsRegistry)

func (*FakePCStore) Watch

func (p *FakePCStore) Watch(quit <-chan struct{}) <-chan pcstore.WatchedPodClusters

func (*FakePCStore) WatchAndSync

func (p *FakePCStore) WatchAndSync(concrete pcstore.ConcreteSyncer, quit <-chan struct{}) error

func (*FakePCStore) WatchPodCluster

func (p *FakePCStore) WatchPodCluster(id fields.ID, quit <-chan struct{}) <-chan pcstore.WatchedPodCluster