statusstoretest

Documentation

Index

• type FakeStatusStore
  • func NewFake() *FakeStatusStore
  • func (s *FakeStatusStore) CASStatus(ctx context.Context, t statusstore.ResourceType, id statusstore.ResourceID, ...) error
  • func (s *FakeStatusStore) DeleteStatus(t statusstore.ResourceType, id statusstore.ResourceID, ...) error
  • func (s *FakeStatusStore) DeleteStatusTxn(ctx context.Context, t statusstore.ResourceType, id statusstore.ResourceID, ...) error
  • func (s *FakeStatusStore) GetAllStatusForResource(t statusstore.ResourceType, id statusstore.ResourceID) (map[statusstore.Namespace]statusstore.Status, error)
  • func (s *FakeStatusStore) GetAllStatusForResourceType(t statusstore.ResourceType) (map[statusstore.ResourceID]map[statusstore.Namespace]statusstore.Status, error)
  • func (s *FakeStatusStore) GetStatus(t statusstore.ResourceType, id statusstore.ResourceID, ...) (statusstore.Status, *api.QueryMeta, error)
  • func (s *FakeStatusStore) SetStatus(t statusstore.ResourceType, id statusstore.ResourceID, ...) error
  • func (s *FakeStatusStore) SetTxn(ctx context.Context, t statusstore.ResourceType, id statusstore.ResourceID, ...) error
  • func (s *FakeStatusStore) WatchStatus(t statusstore.ResourceType, id statusstore.ResourceID, ...) (statusstore.Status, *api.QueryMeta, error)
• type StatusIdentifier
  • func (s StatusIdentifier) String() string

Types

type FakeStatusStore

type FakeStatusStore struct {
	Statuses map[StatusIdentifier]statusstore.Status

	// Imitates the ModifyIndex capability of consul, enabling CAS operations
	LastIndex uint64
	// contains filtered or unexported fields
}

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

func NewFake

func NewFake() *FakeStatusStore

func (*FakeStatusStore) CASStatus

func (s *FakeStatusStore) CASStatus(
	ctx context.Context,
	t statusstore.ResourceType,
	id statusstore.ResourceID,
	namespace statusstore.Namespace,
	status statusstore.Status,
	modifyIndex uint64,
) error

func (*FakeStatusStore) DeleteStatus

func (s *FakeStatusStore) DeleteStatus(
	t statusstore.ResourceType,
	id statusstore.ResourceID,
	namespace statusstore.Namespace,
) error

func (*FakeStatusStore) DeleteStatusTxn

func (s *FakeStatusStore) DeleteStatusTxn(
	ctx context.Context,
	t statusstore.ResourceType,
	id statusstore.ResourceID,
	namespace statusstore.Namespace,
) error

func (*FakeStatusStore) GetAllStatusForResource

func (s *FakeStatusStore) GetAllStatusForResource(
	t statusstore.ResourceType,
	id statusstore.ResourceID,
) (map[statusstore.Namespace]statusstore.Status, error)

func (*FakeStatusStore) GetAllStatusForResourceType

func (s *FakeStatusStore) GetAllStatusForResourceType(
	t statusstore.ResourceType,
) (map[statusstore.ResourceID]map[statusstore.Namespace]statusstore.Status, error)

func (*FakeStatusStore) GetStatus

func (s *FakeStatusStore) GetStatus(
	t statusstore.ResourceType,
	id statusstore.ResourceID,
	namespace statusstore.Namespace,
) (statusstore.Status, *api.QueryMeta, error)

func (*FakeStatusStore) SetStatus

func (s *FakeStatusStore) SetStatus(
	t statusstore.ResourceType,
	id statusstore.ResourceID,
	namespace statusstore.Namespace,
	status statusstore.Status,
) error

func (*FakeStatusStore) SetTxn

func (s *FakeStatusStore) SetTxn(
	ctx context.Context,
	t statusstore.ResourceType,
	id statusstore.ResourceID,
	namespace statusstore.Namespace,
	status statusstore.Status,
) error

func (*FakeStatusStore) WatchStatus

func (s *FakeStatusStore) WatchStatus(
	t statusstore.ResourceType,
	id statusstore.ResourceID,
	namespace statusstore.Namespace,
	waitIndex uint64,
) (statusstore.Status, *api.QueryMeta, error)

type StatusIdentifier

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

Just a convenient index into the status map that models the interface arguments

func (StatusIdentifier) String

func (s StatusIdentifier) String() string