mocks

Documentation

Index

• type KVMock
  • func NewKVMock() *KVMock[instance.State]
  • func (kv *KVMock[T]) Add(count int)
  • func (kv *KVMock[T]) Delete(k string)
  • func (kv *KVMock[T]) Get(k string) (v instance.State, ok bool)
  • func (kv *KVMock[T]) Put(k string, v T, expiresAfter time.Duration) error
  • func (kv *KVMock[T]) Wait()
• type ProviderMock
  • func NewProviderMock() *ProviderMock
  • func NewProviderMockWithStoppedInstancesEvents(stoppedInstances []string) *ProviderMock
  • func (provider *ProviderMock) Add(count int)
  • func (provider *ProviderMock) GetGroups(ctx context.Context) (map[string][]string, error)
  • func (provider *ProviderMock) GetState(ctx context.Context, name string) (instance.State, error)
  • func (provider *ProviderMock) NotifyInstanceStopped(ctx context.Context, instance chan<- string)
  • func (provider *ProviderMock) Wait()

Types

type KVMock

type KVMock[T any] struct {
	tinykv.KV[T]
	mock.Mock
	// contains filtered or unexported fields
}

func NewKVMock

func NewKVMock() *KVMock[instance.State]

func (*KVMock[T]) Add

func (kv *KVMock[T]) Add(count int)

func (*KVMock[T]) Delete

func (kv *KVMock[T]) Delete(k string)

func (*KVMock[T]) Get

func (kv *KVMock[T]) Get(k string) (v instance.State, ok bool)

func (*KVMock[T]) Put

func (kv *KVMock[T]) Put(k string, v T, expiresAfter time.Duration) error

func (*KVMock[T]) Wait

func (kv *KVMock[T]) Wait()

type ProviderMock

type ProviderMock struct {
	providers.Provider
	mock.Mock
	// contains filtered or unexported fields
}

func NewProviderMock

func NewProviderMock() *ProviderMock

func NewProviderMockWithStoppedInstancesEvents

func NewProviderMockWithStoppedInstancesEvents(stoppedInstances []string) *ProviderMock

func (*ProviderMock) Add

func (provider *ProviderMock) Add(count int)

func (*ProviderMock) GetGroups

func (provider *ProviderMock) GetGroups(ctx context.Context) (map[string][]string, error)

func (*ProviderMock) GetState

func (provider *ProviderMock) GetState(ctx context.Context, name string) (instance.State, error)

func (*ProviderMock) NotifyInstanceStopped

func (provider *ProviderMock) NotifyInstanceStopped(ctx context.Context, instance chan<- string)

func (*ProviderMock) Wait

func (provider *ProviderMock) Wait()