cluster

type DefaultInventory struct {
	*repository.Repository
	// contains filtered or unexported fields
}

type Inventory interface {
	CreateOrUpdate(contractVersion int64, cluster *keb.Cluster) (*State, error)
	UpdateStatus(State *State, status model.Status) (*State, error)
	MarkForDeletion(runtimeID string) (*State, error)
	Delete(runtimeID string) error
	Get(runtimeID string, configVersion int64) (*State, error)
	GetLatest(runtimeID string) (*State, error)
	GetAll() ([]*State, error)
	StatusChanges(runtimeID string, offset time.Duration) ([]*StatusChange, error)
	ClustersToReconcile(reconcileInterval time.Duration) ([]*State, error)
	ClustersNotReady() ([]*State, error)
	CountRetries(runtimeID string, configVersion int64, maxRetries int, errorStatus ...model.Status) (int, error)
	WithTx(tx *db.TxConnection) (Inventory, error)
	RemoveStatusesWithoutReconciliations(timeout time.Duration, statusCleanupBatchSize int) (int, error)
	RemoveDeletedClustersOlderThan(deadline time.Time) (int, error)
}

type MetricsCollectorMock struct{}

type MockInventory struct {
	ClustersToReconcileResult             []*State
	ClustersNotReadyResult                []*State
	GetResult                             *State
	GetLatestResult                       *State
	GetAllResult                          []*State
	CreateOrUpdateResult                  *State
	MarkForDeletionResult                 *State
	DeleteResult                          error
	UpdateStatusResult                    *State
	ChangesResult                         []*StatusChange
	RetriesCount                          int
	DeletedStatusesWoReconciliationResult int
	DeletedStatusesOlderThanResult        int
	DeletedClustersOlderThanResult        int
}

type MockKubeconfigProvider struct {
	KubeconfigResult string
}

type State struct {
	Cluster       *model.ClusterEntity
	Configuration *model.ClusterConfigurationEntity
	Status        *model.ClusterStatusEntity
}

type StatusChange struct {
	Status   *model.ClusterStatusEntity
	Duration time.Duration
}