statestore

package

Go to main page

Versions in this module

v0

v0.13.0

Jan 22, 2025

Changes in this version

type AbsenceTaskState

+ func (s *AbsenceTaskState) SetStatus(status AbsenceTaskStatus)

type PresenceTaskState

+ func (s *PresenceTaskState) SetStatus(status PresenceTaskStatus)

type ReadinessTaskState

+ func (s *ReadinessTaskState) SetStatus(status ReadinessTaskStatus)

type ResourceStatus

+ const ResourceStatusUnknown

v0.12.3

Jan 25, 2024

Changes in this version

type AbsenceTaskState

+ func (s *AbsenceTaskState) UUID() string

type PresenceTaskState

+ func (s *PresenceTaskState) UUID() string

type ReadinessTaskState

+ func (s *ReadinessTaskState) UUID() string

v0.12.2

Jan 22, 2024

v0.12.1

Jan 22, 2024

v0.12.0

Dec 28, 2023

Changes in this version

+ const AttributeNameConditionCurrentValue

+ const AttributeNameConditionTarget

+ const AttributeNameStatus

type Attribute

+ func NewAttribute[T int | string](name string, value T) *Attribute[T]

+ func (a *Attribute[T]) Name() string

type Attributer

+ Name func() string

type ResourceState

+ func (s *ResourceState) AddAttribute(attr Attributer)

v0.11.0

Dec 19, 2023

v0.10.0

Dec 18, 2023

Changes in this version

+ const AttributeNameRequiredReplicas

+ type AbsenceTaskConditionFn func(taskState *AbsenceTaskState) bool

+ type AbsenceTaskState struct

+ func NewAbsenceTaskState(name, namespace string, groupVersionKind schema.GroupVersionKind, ...) *AbsenceTaskState

+ func (s *AbsenceTaskState) GroupVersionKind() schema.GroupVersionKind

+ func (s *AbsenceTaskState) Name() string

+ func (s *AbsenceTaskState) Namespace() string

+ func (s *AbsenceTaskState) ResourceState() *util.Concurrent[*ResourceState]

+ func (s *AbsenceTaskState) Status() AbsenceTaskStatus

+ type AbsenceTaskStateOptions struct

+ type AbsenceTaskStatus string

+ const AbsenceTaskStatusAbsent

+ const AbsenceTaskStatusFailed

+ const AbsenceTaskStatusProgressing

+ type Attribute struct

+ Internal bool

+ Value T

+ type Attributer interface

+ type Error struct

+ Err error

+ Time time.Time

+ type Event struct

+ Message string

+ Time time.Time

+ type PresenceTaskConditionFn func(taskState *PresenceTaskState) bool

+ type PresenceTaskState struct

+ func NewPresenceTaskState(name, namespace string, groupVersionKind schema.GroupVersionKind, ...) *PresenceTaskState

+ func (s *PresenceTaskState) GroupVersionKind() schema.GroupVersionKind

+ func (s *PresenceTaskState) Name() string

+ func (s *PresenceTaskState) Namespace() string

+ func (s *PresenceTaskState) ResourceState() *util.Concurrent[*ResourceState]

+ func (s *PresenceTaskState) Status() PresenceTaskStatus

+ type PresenceTaskStateOptions struct

+ type PresenceTaskStatus string

+ const PresenceTaskStatusFailed

+ const PresenceTaskStatusPresent

+ const PresenceTaskStatusProgressing

+ type ReadinessTaskConditionFn func(taskState *ReadinessTaskState) bool

+ type ReadinessTaskState struct

+ func NewReadinessTaskState(name, namespace string, groupVersionKind schema.GroupVersionKind, ...) *ReadinessTaskState

+ func (s *ReadinessTaskState) AddDependency(fromName, fromNamespace string, fromGroupVersionKind schema.GroupVersionKind, ...)

+ func (s *ReadinessTaskState) AddResourceState(name, namespace string, groupVersionKind schema.GroupVersionKind)

+ func (s *ReadinessTaskState) GroupVersionKind() schema.GroupVersionKind

+ func (s *ReadinessTaskState) Name() string

+ func (s *ReadinessTaskState) Namespace() string

+ func (s *ReadinessTaskState) ResourceState(name, namespace string, groupVersionKind schema.GroupVersionKind) *util.Concurrent[*ResourceState]

+ func (s *ReadinessTaskState) ResourceStates() []*util.Concurrent[*ResourceState]

+ func (s *ReadinessTaskState) Status() ReadinessTaskStatus

+ func (s *ReadinessTaskState) TraverseResourceStates(fromName, fromNamespace string, fromGroupVersionKind schema.GroupVersionKind) []*util.Concurrent[*ResourceState]

+ type ReadinessTaskStateOptions struct

+ FailMode multitrack.FailMode

+ TotalAllowFailuresCount int

+ type ReadinessTaskStatus string

+ const ReadinessTaskStatusFailed

+ const ReadinessTaskStatusProgressing

+ const ReadinessTaskStatusReady

+ type ResourceState struct

+ func NewResourceState(name, namespace string, groupVersionKind schema.GroupVersionKind) *ResourceState

+ func (s *ResourceState) AddError(err error, source string, timestamp time.Time)

+ func (s *ResourceState) AddEvent(message string, timestamp time.Time)

+ func (s *ResourceState) Attributes() map[string]Attributer

+ func (s *ResourceState) Errors() map[string][]*Error

+ func (s *ResourceState) Events() []*Event

+ func (s *ResourceState) GroupVersionKind() schema.GroupVersionKind

+ func (s *ResourceState) ID() string

+ func (s *ResourceState) Name() string

+ func (s *ResourceState) Namespace() string

+ func (s *ResourceState) SetAttribute(name string, attr Attributer)

+ func (s *ResourceState) SetStatus(status ResourceStatus)

+ func (s *ResourceState) Status() ResourceStatus

+ type ResourceStatus string

+ const ResourceStatusCreated

+ const ResourceStatusDeleted

+ const ResourceStatusFailed

+ const ResourceStatusReady

+ type TaskStore struct

+ func NewTaskStore() *TaskStore

+ func (s *TaskStore) AbsenceTasksStates() []*util.Concurrent[*AbsenceTaskState]

+ func (s *TaskStore) AddAbsenceTaskState(task *util.Concurrent[*AbsenceTaskState])

+ func (s *TaskStore) AddPresenceTaskState(task *util.Concurrent[*PresenceTaskState])

+ func (s *TaskStore) AddReadinessTaskState(task *util.Concurrent[*ReadinessTaskState])

+ func (s *TaskStore) PresenceTasksStates() []*util.Concurrent[*PresenceTaskState]

+ func (s *TaskStore) ReadinessTasksStates() []*util.Concurrent[*ReadinessTaskState]

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL