state

Dec 27, 2024

Changes in this version

type EventType

+ const Noop

type WatchKindOption

+ func WithBootstrapBookmark(enable bool) WatchKindOption

type WatchKindOptions

+ BootstrapBookmark bool

Dec 12, 2024

Changes in this version

+ func IsInvalidWatchBookmarkError(err error) bool

+ type ErrInvalidWatchBookmark interface

+ InvalidWatchBookmarkError func()

Nov 4, 2024

Changes in this version

+ type Bookmark []byte

type Event

+ Bookmark Bookmark

type WatchKindOption

+ func WithKindStartFromBookmark(bookmark Bookmark) WatchKindOption

type WatchKindOptions

+ StartFromBookmark Bookmark

type WatchOption

+ func WithStartFromBookmark(bookmark Bookmark) WatchOption

type WatchOptions

+ StartFromBookmark Bookmark

Sep 12, 2024

Changes in this version

type ErrConflict

+ GetResource func() resource.Pointer

+ type ErrcheckOption func(*ErrcheckOptions)

+ func WithResourceNamespace(ns resource.Namespace) ErrcheckOption

+ func WithResourceType(rt resource.Type) ErrcheckOption

+ type ErrcheckOptions struct

Apr 4, 2024

Changes in this version

type State

+ ContextWithTeardown func(context.Context, resource.Pointer) (context.Context, error)

Aug 24, 2023

Changes in this version

type ListOptions

+ LabelQueries resource.LabelQueries

type WatchKindOptions

+ LabelQueries resource.LabelQueries

Mar 20, 2023

Changes in this version

type CoreState

+ WatchKindAggregated func(context.Context, resource.Kind, chan<- []Event, ...WatchKindOption) error

type ListOption

+ func WithIDQuery(opt ...resource.IDQueryOption) ListOption

type ListOptions

+ IDQuery resource.IDQuery

type WatchKindOption

+ func WatchWithIDQuery(opt ...resource.IDQueryOption) WatchKindOption

type WatchKindOptions

+ IDQuery resource.IDQuery

Nov 29, 2022

Changes in this version

+ func IsUnsupportedError(err error) bool

+ type ErrUnsupported interface

+ UnsupportedError func()

type Event

+ Error error

type EventType

+ const Bootstrapped

+ const Errored

type GetOption

+ func WithGetUnmarshalOptions(opt ...UnmarshalOption) GetOption

type GetOptions

+ UnmarshalOptions UnmarshalOptions

type ListOption

+ func WithListUnmarshalOptions(opt ...UnmarshalOption) ListOption

type ListOptions

+ UnmarshalOptions UnmarshalOptions

+ type UnmarshalOption func(*UnmarshalOptions)

+ func WithSkipProtobufUnmarshal() UnmarshalOption

+ type UnmarshalOptions struct

+ SkipProtobufUnmarshal bool

type WatchKindOption

+ func WithWatchKindUnmarshalOptions(opt ...UnmarshalOption) WatchKindOption

type WatchKindOptions

+ UnmarshalOptions UnmarshalOptions

type WatchOption

+ func WithWatchUnmarshalOptions(opt ...UnmarshalOption) WatchOption

type WatchOptions

+ UnmarshalOptions UnmarshalOptions

Aug 15, 2022

Changes in this version

+ func IsConflictError(err error) bool

+ func IsNotFoundError(err error) bool

+ func IsOwnerConflictError(err error) bool

+ func IsPhaseConflictError(err error) bool

+ type Access struct

+ ResourceID resource.ID

+ ResourceNamespace resource.Namespace

+ ResourceType resource.Type

+ Verb Verb

+ type CoreState interface

+ Create func(context.Context, resource.Resource, ...CreateOption) error

+ Destroy func(context.Context, resource.Pointer, ...DestroyOption) error

+ Get func(context.Context, resource.Pointer, ...GetOption) (resource.Resource, error)

+ List func(context.Context, resource.Kind, ...ListOption) (resource.List, error)

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

+ Watch func(context.Context, resource.Pointer, chan<- Event, ...WatchOption) error

+ WatchKind func(context.Context, resource.Kind, chan<- Event, ...WatchKindOption) error

+ func Filter(coreState CoreState, rule FilteringRule) CoreState

+ type CreateOption func(*CreateOptions)

+ func WithCreateOwner(owner string) CreateOption

+ type CreateOptions struct

+ Owner string

+ type DestroyOption func(*DestroyOptions)

+ func WithDestroyOwner(owner string) DestroyOption

+ type DestroyOptions struct

+ Owner string

+ type ErrConflict interface

+ ConflictError func()

+ type ErrNotFound interface

+ NotFoundError func()

+ type ErrOwnerConflict interface

+ OwnerConflictError func()

+ type ErrPhaseConflict interface

+ PhaseConflictError func()

+ type Event struct

+ Old resource.Resource

+ Resource resource.Resource

+ Type EventType

+ type EventType int

+ const Created

+ const Destroyed

+ const Updated

+ func (eventType EventType) String() string

+ type FilteringRule func(ctx context.Context, access Access) error

+ type GetOption func(*GetOptions)

+ type GetOptions struct

+ type ListOption func(*ListOptions)

+ func WithLabelQuery(opt ...resource.LabelQueryOption) ListOption

+ type ListOptions struct

+ LabelQuery resource.LabelQuery

+ type ResourceConditionFunc func(resource.Resource) (bool, error)

+ type State interface

+ AddFinalizer func(context.Context, resource.Pointer, ...resource.Finalizer) error

+ RemoveFinalizer func(context.Context, resource.Pointer, ...resource.Finalizer) error

+ Teardown func(context.Context, resource.Pointer, ...TeardownOption) (bool, error)

+ UpdateWithConflicts func(context.Context, resource.Pointer, UpdaterFunc, ...UpdateOption) (resource.Resource, error)

+ WatchFor func(context.Context, resource.Pointer, ...WatchForConditionFunc) (resource.Resource, error)

+ func WrapCore(coreState CoreState) State

+ type TeardownOption func(*TeardownOptions)

+ func WithTeardownOwner(owner string) TeardownOption

+ type TeardownOptions struct

+ Owner string

+ type UpdateOption func(*UpdateOptions)

+ func WithExpectedPhase(phase resource.Phase) UpdateOption

+ func WithExpectedPhaseAny() UpdateOption

+ func WithUpdateOwner(owner string) UpdateOption

+ type UpdateOptions struct

+ ExpectedPhase *resource.Phase

+ Owner string

+ func DefaultUpdateOptions() UpdateOptions

+ type UpdaterFunc func(resource.Resource) error

+ type Verb int

+ const Create

+ const Destroy

+ const Get

+ const List

+ const Update

+ const Watch

+ func (verb Verb) Readonly() bool

+ type WatchForCondition struct

+ Condition ResourceConditionFunc

+ EventTypes []EventType

+ FinalizersEmpty bool

+ Phases []resource.Phase

+ func (condition *WatchForCondition) Matches(event Event) (bool, error)

+ type WatchForConditionFunc func(*WatchForCondition) error

+ func WithCondition(conditionFunc ResourceConditionFunc) WatchForConditionFunc

+ func WithEventTypes(types ...EventType) WatchForConditionFunc

+ func WithFinalizerEmpty() WatchForConditionFunc

+ func WithPhases(phases ...resource.Phase) WatchForConditionFunc

+ type WatchKindOption func(*WatchKindOptions)

+ func WatchWithLabelQuery(opt ...resource.LabelQueryOption) WatchKindOption

+ func WithBootstrapContents(enable bool) WatchKindOption

+ func WithKindTailEvents(n int) WatchKindOption

+ type WatchKindOptions struct

+ BootstrapContents bool

+ LabelQuery resource.LabelQuery

+ TailEvents int

+ type WatchOption func(*WatchOptions)

+ func WithTailEvents(n int) WatchOption

+ type WatchOptions struct

+ TailEvents int