resources

type BundleActivationProjector[A any, B any] interface {
	Build(ctx context.Context, activations []Record[A], bundles []Record[B]) (ProjectionPlan, error)
	Apply(ctx context.Context, plan ProjectionPlan) error
}

type CodecRegistry struct {
	// contains filtered or unexported fields
}

type Draft[T any] struct {
	ID              string
	Scope           ResourceScope
	ExpectedVersion int64
	Spec            T
}

type Kernel struct {
	// contains filtered or unexported fields
}

type KindCodec[T any] interface {
	Kind() ResourceKind
	DecodeAndValidate(ctx context.Context, scope ResourceScope, raw []byte) (T, error)
	Encode(spec T) ([]byte, error)
	MaxBytes() int
}

type MutationActor struct {
	Kind          MutationActorKind   `json:"kind"`
	ID            string              `json:"id"`
	SessionNonce  string              `json:"session_nonce,omitempty"`
	Owner         ResourceOwner       `json:"owner"`
	Source        ResourceSource      `json:"source"`
	MaxScope      ResourceScope       `json:"max_scope"`
	GrantedKinds  []ResourceKind      `json:"granted_kinds,omitempty"`
	GrantedScopes []ResourceScopeKind `json:"granted_scopes,omitempty"`
}

type MutationActorKind string

type Option func(*Kernel)

type ProjectionPlan interface {
	Kind() ResourceKind
	Revision() int64
	OperationCount() int
}

type ProjectorRegistration interface {
	Kind() ResourceKind
	DependsOn() []ResourceKind
	// contains filtered or unexported methods
}

type RawDraft struct {
	Kind            ResourceKind
	ID              string
	Scope           ResourceScope
	ExpectedVersion int64
	SpecJSON        []byte
}

type RawRecord struct {
	Kind      ResourceKind
	ID        string
	Version   int64
	Scope     ResourceScope
	Owner     ResourceOwner
	Source    ResourceSource
	SpecJSON  []byte
	CreatedAt time.Time
	UpdatedAt time.Time
}

type RawStore interface {
	PutRaw(ctx context.Context, actor MutationActor, draft RawDraft) (RawRecord, error)
	DeleteRaw(ctx context.Context, actor MutationActor, kind ResourceKind, id string, expectedVersion int64) error
	ApplySourceSnapshotRaw(ctx context.Context, actor MutationActor, snapshot SourceSnapshot) error
	GetRaw(ctx context.Context, actor MutationActor, kind ResourceKind, id string) (RawRecord, error)
	ListRaw(ctx context.Context, actor MutationActor, filter ResourceFilter) ([]RawRecord, error)
}

type ReconcileDriver interface {
	Trigger(ctx context.Context, kind ResourceKind, reason ReconcileReason) error
	RunBoot(ctx context.Context) error
	Close(ctx context.Context) error
}

type ReconcileEvent struct {
	Type                ReconcileEventType
	Kind                ResourceKind
	Reason              ReconcileReason
	Duration            time.Duration
	Revision            int64
	Operations          int
	ConsecutiveFailures int
	DegradedUntil       time.Time
	Err                 error
}

type ReconcileEventSink interface {
	ObserveReconcileEvent(ctx context.Context, event ReconcileEvent)
}

type ReconcileEventType string

type ReconcileHealth struct {
	Kind                ResourceKind
	Status              ReconcileHealthStatus
	ConsecutiveFailures int
	DegradedUntil       time.Time
	LastError           error
}

type ReconcileHealthSink interface {
	ReportReconcileHealth(ctx context.Context, health ReconcileHealth)
}

type ReconcileHealthStatus string

type ReconcileOption func(*reconcileDriver)

type ReconcileReason string

type Record[T any] struct {
	Kind      ResourceKind
	ID        string
	Version   int64
	Scope     ResourceScope
	Owner     ResourceOwner
	Source    ResourceSource
	Spec      T
	CreatedAt time.Time
	UpdatedAt time.Time
}

type ResourceFilter struct {
	Kind   ResourceKind
	Scope  *ResourceScope
	Owner  *ResourceOwner
	Source *ResourceSource
	Limit  int
}

type ResourceKind string

type ResourceOwner struct {
	Kind ResourceOwnerKind `json:"kind"`
	ID   string            `json:"id"`
}

type ResourceOwnerKind string

type ResourceScope struct {
	Kind ResourceScopeKind `json:"kind"`
	ID   string            `json:"id,omitempty"`
}

type ResourceScopeKind string

type ResourceSource struct {
	Kind ResourceSourceKind `json:"kind"`
	ID   string             `json:"id"`
}

type ResourceSourceKind string

type SourceSessionManager interface {
	ActivateSourceSession(ctx context.Context, actor MutationActor, source ResourceSource, sessionNonce string) error
	ResetSource(ctx context.Context, actor MutationActor, source ResourceSource) error
}

type SourceSnapshot struct {
	SourceVersion int64
	Records       []RawDraft
}

type SpecValidator[T any] func(ctx context.Context, scope ResourceScope, spec T) (T, error)

type Store[T any] interface {
	Put(ctx context.Context, actor MutationActor, draft Draft[T]) (Record[T], error)
	Delete(ctx context.Context, actor MutationActor, id string, expectedVersion int64) error
	Get(ctx context.Context, actor MutationActor, id string) (Record[T], error)
	List(ctx context.Context, actor MutationActor, filter ResourceFilter) ([]Record[T], error)
}

type TypedProjector[T any] interface {
	Kind() ResourceKind
	DependsOn() []ResourceKind
	Build(ctx context.Context, records []Record[T]) (ProjectionPlan, error)
	Apply(ctx context.Context, plan ProjectionPlan) error
}