beehive

Aug 22, 2026

Changes in this version

+ var ErrInvalidCondition = storeapi.ErrInvalidCondition

+ var ErrInvalidStoreIdentity = errors.New("beehive: store reports no identity")

+ var ErrStoreInUse = errors.New("beehive: store already has a running Beehive")

Aug 19, 2026

Changes in this version

+ var ErrDeletionPending = storeapi.ErrDeletionPending

Aug 19, 2026

Changes in this version

type Option

+ func WithTriggerByID(ch <-chan ObjectID) Option

+ func WithTriggerByName(ch <-chan string) Option

Aug 19, 2026

Changes in this version

type Option

+ func WithIndividualPassInterval(d time.Duration) Option

Aug 18, 2026

Changes in this version

+ type AdminClient struct

+ func NewAdminClient[Status any](bh *Beehive, gk GroupKind) *AdminClient[Status]

+ func (a *AdminClient[Status]) AddDependency(ctx context.Context, fromID, toID ObjectID) error

+ func (a *AdminClient[Status]) AddEvent(ctx context.Context, id ObjectID, event EventSpec) error

+ func (a *AdminClient[Status]) DeleteCondition(ctx context.Context, id ObjectID, conditionType string) error

+ func (a *AdminClient[Status]) DeleteDependency(ctx context.Context, fromID, toID ObjectID) error

+ func (a *AdminClient[Status]) DeleteFinalizer(ctx context.Context, id ObjectID, finalizer string) error

+ func (a *AdminClient[Status]) SetCondition(ctx context.Context, id ObjectID, condition Condition) error

+ func (a *AdminClient[Status]) SetConditions(ctx context.Context, id ObjectID, conditions []Condition) error

+ func (a *AdminClient[Status]) UpdateStatus(ctx context.Context, id ObjectID, status Status) error

Aug 18, 2026

Changes in this version

type ReconcileResult

+ func (r ReconcileResult) Err() error

+ func (r ReconcileResult) RequeueAfter(d time.Duration) ReconcileResult

Aug 18, 2026

Changes in this version

+ var ErrInvalidResult = errors.New("beehive: unusable ReconcileResult")

+ var ErrReconcileReturned = errors.New("beehive: the ControllerClient passed to Reconcile is no longer usable")

+ type ReconcileResult struct

+ func Fail(err error) ReconcileResult

+ func Settled(requeueAfter time.Duration) ReconcileResult

+ func Unsettled(requeueAfter time.Duration) ReconcileResult

Aug 13, 2026

Changes in this version

+ type EventRetention struct

+ MaxAge time.Duration

+ PerTimeline int

type EventStream

+ Retention EventRetention

+ type ObjectListStream struct

+ Changes <-chan ObjectChange[Spec, Status]

+ Objects []*Object[Spec, Status]

+ ResourceVersion int64

+ func (f ObjectListStream) Err() error

+ type ObjectStream struct

+ Changes <-chan ObjectChange[Spec, Status]

+ Object *Object[Spec, Status]

+ ResourceVersion int64

+ func (f ObjectStream) Err() error

Aug 7, 2026

Changes in this version

type Condition

+ Unconfirmed bool

Aug 7, 2026

Changes in this version

+ var ErrDuplicateConditionType = storeapi.ErrDuplicateConditionType

+ var ErrInvalidObservedGeneration = storeapi.ErrInvalidObservedGeneration

type Condition

+ TransitionedAt time.Time

+ UpdatedAt time.Time

type ControllerClient

+ SetConditions func(ctx context.Context, id ObjectID, conditions []Condition) error

+ SetObservedGeneration func(ctx context.Context, id ObjectID, observedGeneration int64) error

Aug 7, 2026

Changes in this version

type Client

+ WatchOwnedObjects func(ctx context.Context, ownerID ObjectID, opts ...WatchOption) (ObjectListSnapshot[Spec, Status], <-chan ObjectChange[Spec, Status], error)

type ControllerClient

+ AddEvent func(ctx context.Context, id ObjectID, event EventSpec) error

+ HasIncomingEdges func(ctx context.Context, id ObjectID) (bool, error)

Aug 7, 2026

Changes in this version

+ const Failed

+ const WriteCreate

+ const WriteDelete

+ const WriteUpdate

+ var ErrConcurrentNestedTx = storeapi.ErrConcurrentNestedTx

+ var ErrInvalidName = storeapi.ErrInvalidName

+ var ErrInvalidOption = errors.New("beehive: option value is invalid")

+ var ErrNameTaken = storeapi.ErrNameTaken

+ var ErrStaleTxContext = storeapi.ErrStaleTxContext

+ var ErrStopped = errors.New("beehive: the beehive has stopped")

+ var ErrWatchTooNew = errors.New("beehive: watch resumes above the log's head")

+ var ErrWatchTooOld = errors.New("beehive: watch is below the log's retention horizon")

+ func GenerateName(prefix string) string

type Client

+ DeleteByName func(ctx context.Context, name string) error

+ DependenciesList func(ctx context.Context, id ObjectID) ([]ObjectRef, error)

+ DependentsList func(ctx context.Context, id ObjectID) ([]ObjectRef, error)

+ EventsGetLatest func(ctx context.Context, id ObjectID, category string) (Event, bool, error)

+ EventsList func(ctx context.Context, id ObjectID, opts ...EventOption) ([]Event, error)

+ EventsWatch func(ctx context.Context, id ObjectID, opts ...EventOption) (*EventStream, error)

+ GetByName func(ctx context.Context, name string, loads ...LoadOption) (*Object[Spec, Status], error)

+ OwnedList func(ctx context.Context, id ObjectID) ([]ObjectRef, error)

+ OwnedObjectsList func(ctx context.Context, ownerID ObjectID, loads ...LoadOption) ([]*Object[Spec, Status], error)

+ OwnedObjectsListWatch func(ctx context.Context, ownerID ObjectID, opts ...WatchOption) (ObjectListSnapshot[Spec, Status], <-chan ObjectChange[Spec, Status], error)

+ OwnersGet func(ctx context.Context, id ObjectID) (ObjectRef, bool, error)

+ SchedulesGet func(ctx context.Context, id ObjectID) (Schedule, error)

+ SchedulesWatch func(ctx context.Context, id ObjectID) (<-chan Schedule, error)

+ UpdateByName func(ctx context.Context, name string, spec Spec) (*Object[Spec, Status], error)

type ControllerClient

+ ConditionsDelete func(ctx context.Context, id ObjectID, conditionType string) error

+ ConditionsSet func(ctx context.Context, id ObjectID, condition Condition) error

+ DependenciesAdd func(ctx context.Context, fromID, toID ObjectID) error

+ DependenciesDelete func(ctx context.Context, fromID, toID ObjectID) error

+ DependenciesList func(ctx context.Context, id ObjectID) ([]ObjectRef, error)

+ DependentsList func(ctx context.Context, id ObjectID) ([]ObjectRef, error)

+ EdgesHasIncoming func(ctx context.Context, id ObjectID) (bool, error)

+ EventsAdd func(ctx context.Context, id ObjectID, event EventSpec) error

+ FinalizersDelete func(ctx context.Context, id ObjectID, finalizer string) error

+ OwnedList func(ctx context.Context, id ObjectID) ([]ObjectRef, error)

+ OwnersGet func(ctx context.Context, id ObjectID) (ObjectRef, bool, error)

+ type DeletionCascadeChild = storeapi.DeletionCascadeChild

+ type DriverCursorer = storeapi.DriverCursorer

type Event

+ ResourceVersion int64

type EventOption

+ func WithEventsResumeFrom(rv int64) EventOption

+ type EventStream struct

+ Events <-chan Event

+ ResourceVersion int64

+ Runs []Event

+ func (s *EventStream) Err() error

+ type EventsAddInput = storeapi.EventsAddInput

+ type FreePagesReleaser = storeapi.FreePagesReleaser

type Object

+ Name string

+ func (o *Object[Spec, Status]) Events() ([]Event, error)

+ type ObjectChange struct

+ Err error

+ ID ObjectID

+ Object *Object[Spec, Status]

+ ResourceVersion int64

+ Type ChangeType

+ type ObjectListSnapshot struct

+ Objects []*Object[Spec, Status]

+ ResourceVersion int64

+ type ObjectRef = storeapi.ObjectRef

+ type ObjectSnapshot struct

+ Object *Object[Spec, Status]

+ ResourceVersion int64

+ type ObjectWrite = storeapi.ObjectWrite

+ type ObjectsCreateInput = storeapi.ObjectsCreateInput

type Option

+ func WithFullPassInterval(d time.Duration) Option

+ func WithGCInterval(d time.Duration) Option

+ func WithOwedPassInterval(d time.Duration) Option

+ func WithStaleDependentsInterval(d time.Duration) Option

+ func WithStartupFullPass(enabled bool) Option

+ func WithWatchFloorInterval(d time.Duration) Option

+ func WithWriteLogRetention(perKind int, maxAge time.Duration) Option

+ type StalePos = storeapi.StalePos

+ type WatchOption func(*watchConfig)

+ func WithLoads(loads ...LoadOption) WatchOption

+ func WithResumeFrom(rv int64) WatchOption

+ type WriteOp = storeapi.WriteOp

Jul 23, 2026

Changes in this version

+ var ErrSchemaVersionDowngrade = storeapi.ErrSchemaVersionDowngrade

type Client

+ DeleteBySlug func(ctx context.Context, slug string) error

+ ListOwnedObjects func(ctx context.Context, ownerID ObjectID, loads ...LoadOption) ([]*Object[Spec, Status], error)

Jul 22, 2026

Changes in this version

+ var ErrConflictingOption = errors.New("beehive: option conflicts with an explicit argument")

type Client

+ GetOrCreate func(ctx context.Context, slug string, spec Spec, opts ...Option) (*Object[Spec, Status], bool, error)

type Option

+ func WithOnCreate(fn func(ctx context.Context)) Option

Jul 2, 2026

Changes in this version

type Client

+ GetSchedule func(ctx context.Context, id ObjectID) (Schedule, error)

+ WatchSchedule func(ctx context.Context, id ObjectID) (<-chan Schedule, error)

+ type Schedule struct

+ NextRequeueAt time.Time

Jul 2, 2026

Changes in this version

+ const Added

+ const Deleted

+ const Modified

+ type Change struct

+ Object *Object[Spec, Status]

+ Type ChangeType

+ type ChangeType = storeapi.ChangeType

Jul 1, 2026

Changes in this version

+ func EventDetail[T any](e Event) (T, error)

type Client

+ GetLatestEvent func(ctx context.Context, id ObjectID, category string) (Event, bool, error)

+ ListEvents func(ctx context.Context, id ObjectID, opts ...EventOption) ([]Event, error)

+ WatchEvents func(ctx context.Context, id ObjectID, opts ...EventOption) (<-chan Event, error)

type ControllerClient

+ RecordEvent func(ctx context.Context, id ObjectID, event EventSpec) error

+ type Event struct

+ Category string

+ Count int

+ Detail json.RawMessage

+ FirstAt time.Time

+ ID EventID

+ LastAt time.Time

+ Message string

+ ObjectID ObjectID

+ Reason string

+ Type EventType

+ type EventID = storeapi.EventID

+ type EventOption func(*storeapi.EventQuery)

+ func WithEventCategory(category string) EventOption

+ func WithEventLimit(n int) EventOption

+ func WithEventReason(reason string) EventOption

+ func WithEventType(t EventType) EventOption

+ func WithEventsSince(t time.Time) EventOption

+ type EventSpec struct

+ Category string

+ Detail any

+ Message string

+ Reason string

+ Type EventType

+ type EventType string

+ const EventNormal

+ const EventWarning

+ type EventWatcher = storeapi.EventWatcher

type LoadOption

+ func LoadEvents() LoadOption

type LoadSet

+ const LoadEventsBit

type Object

+ func (o *Object[Spec, Status]) ListEvents() ([]Event, error)

type Option

+ func WithEventRetention(perObject int, maxAge time.Duration) Option

+ type RawEvent = storeapi.Event

Jun 30, 2026

Changes in this version

+ type RequeueOption func(*requeueOptions)

+ func WithResetBackoff() RequeueOption

Jun 29, 2026

Changes in this version

+ var ErrNoController = errors.New("beehive: no controller registered for kind")

type Client

+ NextRequeueAt func(ctx context.Context, id ObjectID) (time.Time, error)

+ Requeue func(ctx context.Context, id ObjectID) error

Jun 25, 2026

Changes in this version

type Object

+ func (o *Object[Spec, Status]) ListDependencies() ([]Ref, error)

+ func (o *Object[Spec, Status]) ListDependents() ([]Ref, error)

+ func (o *Object[Spec, Status]) ListOwned() ([]Ref, error)

Jun 25, 2026

Changes in this version

type Client

+ ListOwned func(ctx context.Context, id ObjectID) ([]Ref, error)

type ControllerClient

+ ListOwned func(ctx context.Context, id ObjectID) ([]Ref, error)

type LoadOption

+ func LoadOwned() LoadOption

type LoadSet

+ const LoadOwnedBit

type Object

+ Owned []Ref

+ func (o *Object[Spec, Status]) GetOwned() ([]Ref, error)

Jun 24, 2026

Changes in this version

+ var ErrNotLoaded = errors.New("beehive: secondary lookup not loaded")

type Client

+ GetOwner func(ctx context.Context, id ObjectID) (Ref, bool, error)

+ ListDependencies func(ctx context.Context, id ObjectID) ([]Ref, error)

+ ListDependents func(ctx context.Context, id ObjectID) ([]Ref, error)

type ControllerClient

+ GetOwner func(ctx context.Context, id ObjectID) (Ref, bool, error)

+ ListDependencies func(ctx context.Context, id ObjectID) ([]Ref, error)

+ ListDependents func(ctx context.Context, id ObjectID) ([]Ref, error)

+ type LoadOption func(*LoadSet)

+ func LoadDependencies() LoadOption

+ func LoadDependents() LoadOption

+ func LoadOwner() LoadOption

+ type LoadSet uint8

+ const LoadDependenciesBit

+ const LoadDependentsBit

+ const LoadOwnerBit

type Object

+ Dependencies []Ref

+ Dependents []Ref

+ Owner *Ref

+ func (o *Object[Spec, Status]) GetDependencies() ([]Ref, error)

+ func (o *Object[Spec, Status]) GetDependents() ([]Ref, error)

+ func (o *Object[Spec, Status]) GetOwner() (Ref, bool, error)

+ type Ref = storeapi.Referrer

Jun 23, 2026

Changes in this version

+ type Migrator interface

+ ConvertSpec func(from int, raw json.RawMessage) (json.RawMessage, error)

+ ConvertStatus func(from int, raw json.RawMessage) (json.RawMessage, error)

+ SchemaVersionSpec func() int

+ SchemaVersionStatus func() int

type Option

+ func WithMigrator(m Migrator) Option

Jun 22, 2026

Changes in this version

type Client

+ CreateOrUpdate func(ctx context.Context, slug string, spec Spec) (*Object[Spec, Status], error)

Jun 21, 2026

Changes in this version

+ const RelationDependsOn

+ const RelationOwnedBy

+ const WatchEventAdded

+ const WatchEventDeleted

+ const WatchEventModified

+ var ErrNotFound = storeapi.ErrNotFound

+ var ErrObservedGenerationFuture = storeapi.ErrObservedGenerationFuture

+ var ErrWrongKind = storeapi.ErrWrongKind

+ func Register[Spec, Status any](bh *Beehive, gk GroupKind, c Controller[Spec, Status], opts ...Option) error

+ type Beehive struct

+ func New(s Store, opts ...Option) (*Beehive, error)

+ func (bh *Beehive) Start() error

+ func (bh *Beehive) Stop(ctx context.Context)

+ type Client interface

+ Create func(ctx context.Context, spec Spec, opts ...Option) (*Object[Spec, Status], error)

+ Delete func(ctx context.Context, id ObjectID) error

+ Get func(ctx context.Context, id ObjectID) (*Object[Spec, Status], error)

+ GetBySlug func(ctx context.Context, slug string) (*Object[Spec, Status], error)

+ List func(ctx context.Context) ([]*Object[Spec, Status], error)

+ Update func(ctx context.Context, id ObjectID, spec Spec) (*Object[Spec, Status], error)

+ Watch func(ctx context.Context, id ObjectID) (<-chan WatchEvent[Spec, Status], error)

+ WatchList func(ctx context.Context) (<-chan WatchEvent[Spec, Status], error)

+ func NewClient[Spec, Status any](bh *Beehive, gk GroupKind) Client[Spec, Status]

+ type Condition struct

+ Liveness bool

+ Message string

+ Reason string

+ Status ConditionStatus

+ Type string

+ type ConditionStatus string

+ const ConditionFalse

+ const ConditionTrue

+ const ConditionUnknown

+ type Controller interface

+ Reconcile func(ctx context.Context, obj *Object[Spec, Status]) (Result, error)

+ Start func(client ControllerClient[Status]) error

+ Stop func(ctx context.Context) error

+ type ControllerClient interface

+ AddDependency func(ctx context.Context, fromID, toID ObjectID) error

+ DeleteCondition func(ctx context.Context, id ObjectID, conditionType string) error

+ DeleteDependency func(ctx context.Context, fromID, toID ObjectID) error

+ DeleteFinalizer func(ctx context.Context, id ObjectID, finalizer string) error

+ HasIncomingRefs func(ctx context.Context, id ObjectID) (bool, error)

+ SetCondition func(ctx context.Context, id ObjectID, condition Condition) error

+ UpdateStatus func(ctx context.Context, id ObjectID, observedGeneration int64, status Status) error

+ Within func(ctx context.Context, fn func(ctx context.Context) error) error

+ type GroupKind = storeapi.GroupKind

+ type Object struct

+ Conditions []Condition

+ CreatedAt time.Time

+ DeletionRequestedAt *time.Time

+ Finalizers []string

+ Generation int64

+ Group string

+ ID ObjectID

+ Kind string

+ ObservedAt *time.Time

+ ObservedGeneration *int64

+ ResourceVersion int64

+ Slug *string

+ Spec Spec

+ Status *Status

+ UpdatedAt time.Time

+ type ObjectID = storeapi.ObjectID

+ type Option func(target any) error

+ func WithConcurrency(n int) Option

+ func WithFinalizers(f ...string) Option

+ func WithLogLevel(level slog.Level) Option

+ func WithLogger(l *slog.Logger) Option

+ func WithMaxRetryInterval(d time.Duration) Option

+ func WithOwner(id ObjectID) Option

+ func WithResyncInterval(d time.Duration) Option

+ func WithSlug(slug string) Option

+ func WithStartupReconcileStrategy(s StartupReconcileStrategy) Option

+ type RawObject = storeapi.RawObject

+ type Referrer = storeapi.Referrer

+ type Relation = storeapi.Relation

+ type Result struct

+ RequeueAfter time.Duration

+ type StartupReconcileStrategy int

+ const StartupReconcileAll

+ const StartupReconcileNone

+ const StartupReconcileUnsettled

+ type Store = storeapi.Store

+ type WatchEvent struct

+ Object *Object[Spec, Status]

+ Type WatchEventType

+ type WatchEventType = storeapi.WatchEventType

+ type Watcher = storeapi.Watcher