watch

Nov 4, 2026

Changes in this version

type Claim

+ Deadline time.Time

+ func (c Claim) ExecutionCeiling(at time.Time, bounds ...time.Time) (time.Time, error)

Oct 31, 2026

Changes in this version

type Store

+ func (s *Store) ListDefinitionsInTransaction(ctx context.Context, tx dal.ReadTransaction, actor Actor) ([]Definition, error)

Oct 29, 2026

Changes in this version

+ const CloudDefinitionCollection

+ const CloudRunCollection

+ type CloudRetainedDocument struct

+ Collection string

+ Environment string

+ ID string

+ Owner string

+ Payload json.RawMessage

+ WatchID string

+ type CloudRetainedInventory struct

+ Collections []string

+ Documents []CloudRetainedDocument

+ Namespace string

+ Project string

+ type CloudRetainedInventoryLimits struct

+ MaxBytes int

+ MaxDocuments int

+ type CloudRetainedSource struct

+ Active bool

+ Collection string

+ Definition *Definition

+ DeliveryID string

+ Event *Event

+ EventID string

+ Observation *Observation

+ Owner string

+ RecordID string

+ Run *Run

+ RunID string

+ Scope Scope

+ WatchID string

+ func ProjectCloudRetainedSources(ctx context.Context, inventory CloudRetainedInventory) ([]CloudRetainedSource, error)

+ type CloudRetainedWrite struct

+ After *CloudRetainedDocument

+ Before *CloudRetainedDocument

+ type CloudRetainedWriteAdmission func(context.Context, dal.ReadwriteTransaction, string, string, ...) (CloudRetainedWritePlan, error)

+ type CloudRetainedWritePlan struct

+ Persist func() error

+ WriteBytes int

+ WriteRows int

type FirestoreOptions

+ AdmitRetainedWrite CloudRetainedWriteAdmission

type Store

+ func (s *Store) RetainedProjectInventoryInTransaction(ctx context.Context, tx dal.ReadTransaction, ...) (CloudRetainedInventory, error)

Oct 24, 2026

Changes in this version

type Store

+ func (s *Store) ReadPutDefinitionOperationInTransaction(ctx context.Context, tx dal.ReadTransaction, actor Actor, requested Definition, ...) (Definition, bool, error)

Oct 24, 2026

Changes in this version

type Store

+ func (s *Store) ReadDefinitionInTransaction(ctx context.Context, tx dal.ReadTransaction, actor Actor, id string) (Definition, error)

Oct 24, 2026

Changes in this version

+ func ValidateDefinition(definition Definition) error

Oct 24, 2026

Changes in this version

+ const MaxEventPageSize

+ type Event struct

+ CheckID string

+ CheckRunRef string

+ CheckVersion string

+ DefinitionVersion int64

+ ID string

+ Inputs map[string]detective.InputValue

+ Kind string

+ OccurredAt time.Time

+ Outcome string

+ Owner string

+ Previous string

+ RunID string

+ SourceFingerprint string

+ Title string

+ Visibility string

+ WatchID string

type Notification

+ EventID string

type Observation

+ LastEventID string

type Run

+ EventID string

type Store

+ func (s *Store) GetEvent(ctx context.Context, a Actor, id string) (Event, error)

+ func (s *Store) ListEventPage(ctx context.Context, a Actor, watchID, before string, limit int) ([]Event, string, error)

+ func (s *Store) ListEvents(ctx context.Context, a Actor, watchID string) ([]Event, error)

Oct 24, 2026

Changes in this version

+ var ErrCapacity = errors.New("watch operation exceeds its bounded storage budget")

type Completion

+ SourceRevision string

type Definition

+ SourceRevision string

+ type FirestoreOptions struct

+ AccountNamespace string

+ AccountRoot *record.Key

+ AdmitDefinition func(context.Context, dal.ReadTransaction, Definition, string) (string, error)

+ AdmitRecipient func(context.Context, dal.ReadTransaction, Definition, string) (RecipientAuthority, error)

+ AdmitRunner func(context.Context, dal.ReadTransaction, Definition, RunnerIdentity) (bool, error)

+ Authorize func(context.Context, dal.ReadTransaction) error

+ Config Config

+ DefinitionChanged func(context.Context, dal.ReadwriteTransaction, Definition) error

+ ProjectID string

+ ProjectKey *record.Key

+ StorageRoot *record.Key

+ WorkReady func(context.Context, dal.ReadwriteTransaction, WorkEvent) error

+ type RecipientAuthority struct

+ AccountID string

+ Email string

+ Paid bool

+ Phone string

type Store

+ func NewFirestoreStore(db dal.DB, options FirestoreOptions) (*Store, error)

+ func (s *Store) GetClaim(ctx context.Context, id RunnerIdentity, runID string, fence int64) (Claim, error)

+ func (s *Store) NextWakeup(ctx context.Context) (time.Time, bool, error)

+ func (s *Store) Prune(ctx context.Context, maxRows int) error

+ func (s *Store) ReconcileScope(ctx context.Context, scope Scope, maxWatches int) (bool, error)

+ func (s *Store) RevalidateSources(ctx context.Context, scope Scope, maxWatches int, after string) (string, error)

+ func (s *Store) WithClaim(ctx context.Context, id RunnerIdentity, runID string, fence int64, ...) error

+ type WorkEvent struct

+ ID string

+ Kind string

+ RunID string

+ WatchID string

Oct 24, 2026

Changes in this version

+ var ErrConflict = errors.New("watch version conflict")

+ var ErrForbidden = errors.New("watch access forbidden")

+ var ErrInvalid = errors.New("invalid watch request")

+ var ErrNotFound = errors.New("watch resource not found")

+ var ErrStaleLease = errors.New("watch lease expired or superseded")

+ type Actor struct

+ AccountID string

+ Email string

+ ID string

+ Phone string

+ Scope Scope

+ SharedEditor bool

+ Tier string

+ type AuditEvent struct

+ Action string

+ Actor string

+ At time.Time

+ ID string

+ ResourceID string

+ Scope Scope

+ type Claim struct

+ ClaimID string

+ Definition Definition

+ Fence int64

+ LeaseUntil time.Time

+ RunID string

+ type Completion struct

+ CheckRunRef string

+ ClaimID string

+ DurationMS int64

+ ExecutionStatus string

+ FailureCode string

+ Fence int64

+ Outcome string

+ RunID string

+ Severity string

+ SourceFingerprint string

+ type Config struct

+ EmailDailyLimit int

+ EmailMinuteLimit int

+ ExecutionTimeout time.Duration

+ HistoryLimit int

+ IsPaidAccount func(string) bool

+ LeaseDuration time.Duration

+ MaxAttempts int

+ MaxWatchesPerUser int

+ MinIntervalSeconds int

+ Namespace string

+ Now func() time.Time

+ RunnerTTL time.Duration

+ SMSDailyLimit int

+ SMSMinuteLimit int

+ TelegramDailyLimit int

+ TelegramMinuteLimit int

+ type Definition struct

+ CheckID string

+ CheckVersion string

+ CreatedAt time.Time

+ Enabled bool

+ ID string

+ InitialObservation string

+ Inputs map[string]detective.InputValue

+ Lifecycle string

+ Mode string

+ NotificationPolicy NotificationPolicy

+ Owner string

+ Requirements []string

+ Schedule Schedule

+ SourceFingerprint string

+ Title string

+ Trigger string

+ UpdatedAt time.Time

+ Version int64

+ Visibility string

+ type DefinitionRepository interface

+ GetDefinition func(context.Context, Actor, string) (Definition, error)

+ ListDefinitions func(context.Context, Actor) ([]Definition, error)

+ PutDefinition func(context.Context, Actor, Definition, string, int64) (Definition, error)

+ type Delivery struct

+ AccountID string

+ Attempts int

+ Channel string

+ Email string

+ FailureCode string

+ Fence int64

+ LeaseUntil time.Time

+ Phone string

+ QuotaReserved bool

+ RetryAt time.Time

+ State string

+ TelegramBotID string

+ TelegramChatID string

+ TelegramLinkGeneration int64

+ type Notification struct

+ CreatedAt time.Time

+ Event string

+ ID string

+ Link string

+ ReadAt time.Time

+ RunID string

+ Title string

+ UserID string

+ WatchID string

+ type NotificationPolicy struct

+ CooldownSeconds int

+ Recovery bool

+ type Observation struct

+ Availability string

+ LastKnown string

+ LastNotifiedAt time.Time

+ LastObservedAt time.Time

+ LastRunID string

+ NextEvaluation time.Time

+ SourceFingerprint string

+ Value string

+ WatchID string

+ type Run struct

+ Attempts int

+ CheckRunRef string

+ CompletionHash string

+ Deadline time.Time

+ DefinitionVersion int64

+ DueAt time.Time

+ DurationMS int64

+ ExecutionStatus string

+ FailureCode string

+ Fence int64

+ FinishedAt time.Time

+ ID string

+ LeaseUntil time.Time

+ Outcome string

+ RetryAt time.Time

+ RunnerID string

+ Severity string

+ State string

+ WatchID string

+ type Runner struct

+ Capabilities []string

+ ID string

+ LastSeen time.Time

+ TelegramBotID string

+ TelegramBotUsername string

+ type RunnerIdentity struct

+ Capabilities []string

+ ID string

+ Scope Scope

+ TelegramBotID string

+ TelegramBotUsername string

+ type Schedule struct

+ IntervalSeconds int

+ type Scope struct

+ Environment string

+ Namespace string

+ Project string

+ type Status struct

+ Coordinator string

+ Observations []Observation

+ Runners []Runner

+ type Store struct

+ func NewSQLiteStore(connection string, c Config) (*Store, error)

+ func (s *Store) AdvanceTelegramPoll(ctx context.Context, id RunnerIdentity, fence, offset int64) error

+ func (s *Store) Audit(ctx context.Context, a Actor, watchID string) ([]AuditEvent, error)

+ func (s *Store) BeginTelegramLink(ctx context.Context, a Actor, nonceHash string, expiresAt time.Time) error

+ func (s *Store) ClaimDue(ctx context.Context, identity RunnerIdentity) (*Claim, error)

+ func (s *Store) ClaimNotifications(ctx context.Context) (*Delivery, error)

+ func (s *Store) ClaimTelegramNotification(ctx context.Context, id RunnerIdentity, pollFence int64) (*Delivery, error)

+ func (s *Store) ClaimTelegramPoll(ctx context.Context, id RunnerIdentity) (*TelegramPollLease, error)

+ func (s *Store) Close() error

+ func (s *Store) CompleteTelegramLinkByRunner(ctx context.Context, id RunnerIdentity, pollFence int64, ...) error

+ func (s *Store) DeferTelegramPoll(ctx context.Context, id RunnerIdentity, fence int64, retryAfterSeconds int) error

+ func (s *Store) DeleteDefinition(ctx context.Context, a Actor, id, operationID string, expectedVersion int64) error

+ func (s *Store) DisconnectTelegram(ctx context.Context, a Actor) error

+ func (s *Store) FinishNotification(ctx context.Context, id string, fence int64, failureCode string) error

+ func (s *Store) FinishRun(ctx context.Context, identity RunnerIdentity, c Completion) (Run, error)

+ func (s *Store) FinishTelegramNotification(ctx context.Context, identity RunnerIdentity, pollFence int64, id string, ...) error

+ func (s *Store) GetDefinition(ctx context.Context, a Actor, id string) (Definition, error)

+ func (s *Store) GetSubscription(ctx context.Context, a Actor, watchID string) (Subscription, error)

+ func (s *Store) Health(ctx context.Context) error

+ func (s *Store) Heartbeat(ctx context.Context, identity RunnerIdentity, id string, fence int64) error

+ func (s *Store) Inbox(ctx context.Context, a Actor) ([]Notification, error)

+ func (s *Store) ListDefinitions(ctx context.Context, a Actor) ([]Definition, error)

+ func (s *Store) ListDeliveries(ctx context.Context, a Actor, watchID string) ([]Delivery, error)

+ func (s *Store) ListRuns(ctx context.Context, a Actor, watchID string) ([]Run, error)

+ func (s *Store) MarkRead(ctx context.Context, a Actor, id string) error

+ func (s *Store) PutDefinition(ctx context.Context, a Actor, d Definition, operationID string, ...) (Definition, error)

+ func (s *Store) Reconcile(ctx context.Context) error

+ func (s *Store) RegisterRunner(ctx context.Context, identity RunnerIdentity) error

+ func (s *Store) RenewTelegramPoll(ctx context.Context, id RunnerIdentity, fence int64) (*TelegramPollLease, error)

+ func (s *Store) ResetBaseline(ctx context.Context, a Actor, id, operationID string, expectedVersion int64) (Definition, error)

+ func (s *Store) RetryNotification(ctx context.Context, a Actor, id string) error

+ func (s *Store) SetLifecycle(ctx context.Context, a Actor, id, lifecycle, operationID string, ...) (Definition, error)

+ func (s *Store) Status(ctx context.Context, a Actor) (Status, error)

+ func (s *Store) Subscribe(ctx context.Context, a Actor, sub Subscription) error

+ func (s *Store) TelegramProviderStatus(ctx context.Context, a Actor) (TelegramProviderStatus, error)

+ func (s *Store) TelegramStatus(ctx context.Context, a Actor) (bool, error)

+ type Subscription struct

+ AccountID string

+ Channels []string

+ Email string

+ NotifyOn []string

+ Phone string

+ TelegramBotID string

+ Tier string

+ Unsubscribed bool

+ UserID string

+ WatchID string

+ type TelegramPollLease struct

+ BotID string

+ Fence int64

+ LeaseUntil time.Time

+ NextAttemptAt time.Time

+ Offset int64

+ type TelegramProviderStatus struct

+ BotID string

+ BotUsername string

+ Connected bool

+ ConnectionError string

+ ReconnectRequired bool