inmem

Dec 12, 2024

Changes in this version

+ var ErrInvalidWatchBookmark = eInvalidWatchBookmark

Mar 20, 2023

Changes in this version

type State

+ func (st *State) WatchKindAggregated(ctx context.Context, resourceKind resource.Kind, ch chan<- []state.Event, ...) error

type StateOption

+ func WithHistoryInitialCapacity(initialCapacity int) StateOption

+ func WithHistoryMaxCapacity(maxCapacity int) StateOption

type StateOptions

+ HistoryInitialCapacity int

+ HistoryMaxCapacity int

Aug 15, 2022

Changes in this version

+ var NewState = NewStateWithOptions()

+ func Build(ns resource.Namespace) state.CoreState

+ func ErrAlreadyExists(r resource.Reference) error

+ func ErrNotFound(r resource.Pointer) error

+ func ErrOwnerConflict(r resource.Reference, owner string) error

+ func ErrPendingFinalizers(r resource.Metadata) error

+ func ErrPhaseConflict(r resource.Reference, expectedPhase resource.Phase) error

+ func ErrUpdateSameVersion(r resource.Reference, version resource.Version) error

+ func ErrVersionConflict(r resource.Reference, expected, found resource.Version) error

+ func NewStateWithOptions(opts ...StateOption) func(ns resource.Namespace) *State

+ type BackingStore interface

+ Destroy func(ctx context.Context, resourceType resource.Type, ...) error

+ Load func(ctx context.Context, handler LoadHandler) error

+ Put func(ctx context.Context, resourceType resource.Type, resource resource.Resource) error

+ type LoadHandler func(resourceType resource.Type, resource resource.Resource) error

+ type ResourceCollection struct

+ func NewResourceCollection(ns resource.Namespace, typ resource.Type, capacity, gap int, ...) *ResourceCollection

+ func (collection *ResourceCollection) Create(ctx context.Context, resource resource.Resource, owner string) error

+ func (collection *ResourceCollection) Destroy(ctx context.Context, ptr resource.Pointer, owner string) error

+ func (collection *ResourceCollection) Get(resourceID resource.ID) (resource.Resource, error)

+ func (collection *ResourceCollection) List(options *state.ListOptions) (resource.List, error)

+ func (collection *ResourceCollection) Update(ctx context.Context, curVersion resource.Version, ...) error

+ func (collection *ResourceCollection) Watch(ctx context.Context, id resource.ID, ch chan<- state.Event, ...) error

+ func (collection *ResourceCollection) WatchAll(ctx context.Context, ch chan<- state.Event, opts ...state.WatchKindOption) error

+ type State struct

+ func (st *State) Create(ctx context.Context, resource resource.Resource, opts ...state.CreateOption) error

+ func (st *State) Destroy(ctx context.Context, resourcePointer resource.Pointer, ...) error

+ func (st *State) Get(ctx context.Context, resourcePointer resource.Pointer, opts ...state.GetOption) (resource.Resource, error)

+ func (st *State) List(ctx context.Context, resourceKind resource.Kind, opts ...state.ListOption) (resource.List, error)

+ func (st *State) Update(ctx context.Context, curVersion resource.Version, ...) error

+ func (st *State) Watch(ctx context.Context, resourcePointer resource.Pointer, ch chan<- state.Event, ...) error

+ func (st *State) WatchKind(ctx context.Context, resourceKind resource.Kind, ch chan<- state.Event, ...) error

+ type StateOption func(options *StateOptions)

+ func WithBackingStore(store BackingStore) StateOption

+ func WithHistoryCapacity(capacity int) StateOption

+ func WithHistoryGap(gap int) StateOption

+ type StateOptions struct

+ BackingStore BackingStore

+ HistoryCapacity int

+ HistoryGap int

+ func DefaultStateOptions() StateOptions