githubapp

Sep 15, 2026

Changes in this version

type Dashboard

+ Fleet *FleetSnapshot

+ type FleetMachine struct

+ LastSeenAt string

+ Name string

+ PublishedAt string

+ Stale bool

+ State string

+ Worktrees []FleetWorktree

+ type FleetPullRequest struct

+ Number int

+ State string

+ URL string

+ type FleetSnapshot struct

+ Machines []FleetMachine

+ type FleetWorktree struct

+ AttentionReason string

+ Branch string

+ LastActivityAt string

+ NeedsAttention bool

+ OwnerState string

+ PullRequest *FleetPullRequest

+ Repository string

+ Status string

+ Stream string

+ Task string

+ type RemoteStateReadModel struct

+ Access MachineAccessResolver

+ Now func() time.Time

+ StaleAfter time.Duration

+ Store SnapshotReader

+ func (model RemoteStateReadModel) Dashboard(ctx context.Context, viewer Viewer) (Access[Dashboard], error)

+ func (model RemoteStateReadModel) LatestMerges(_ context.Context, _ Viewer, _ int) (Access[[]LatestMerge], error)

+ func (model RemoteStateReadModel) Leaderboard(_ context.Context, _ Viewer, metric string) (Access[Leaderboard], error)

+ func (model RemoteStateReadModel) Series(_ context.Context, _ Viewer, scope Scope, id, metric string) (Access[Series], error)

+ func (model RemoteStateReadModel) Stats(ctx context.Context, viewer Viewer, scope Scope, id string) (Access[Stat], error)

+ type SnapshotReader interface

+ ListLatest func(context.Context) ([]machinesnapshot.StoredSnapshot, error)

type Stat

+ Fleet *FleetSnapshot

Sep 11, 2026

Changes in this version

+ type DocumentProjectionDeliveryStore struct

+ Backend DocumentStore

+ Lease time.Duration

+ Now func() time.Time

+ func (store DocumentProjectionDeliveryStore) ClaimDelivery(ctx context.Context, id string) (bool, error)

+ func (store DocumentProjectionDeliveryStore) CommitDeliveryAndWakeup(ctx context.Context, id string, wakeup Wakeup) (bool, error)

+ func (store DocumentProjectionDeliveryStore) HasDelivery(ctx context.Context, id string) (bool, error)

+ func (store DocumentProjectionDeliveryStore) ReleaseDelivery(ctx context.Context, id string) error

+ type DocumentProjectionStore struct

+ Backend DocumentStore

+ func (store DocumentProjectionStore) GetLeaderboard(ctx context.Context, metric string) (LeaderboardDocument, error)

+ func (store DocumentProjectionStore) GetProjection(ctx context.Context, scope Scope, id string) (ProjectionDocument, error)

+ func (store DocumentProjectionStore) ListProjections(ctx context.Context, scope Scope) ([]ProjectionDocument, error)

+ func (store DocumentProjectionStore) ListPublicLatestMerges(ctx context.Context, limit int) (PublicLatestMerges, error)

+ func (store DocumentProjectionStore) ListSeries(ctx context.Context, scope Scope, id, metric string) (SeriesDocument, error)

+ type DocumentProjectionWriter struct

+ Backend DocumentStore

+ func (writer DocumentProjectionWriter) WriteLatestMerges(ctx context.Context, deliveryID string, batch RepositoryLatestMerges) error

+ func (writer DocumentProjectionWriter) WriteOrganizations(ctx context.Context, deliveryID string, records []ProjectionDocument) error

+ func (writer DocumentProjectionWriter) WriteRepositories(ctx context.Context, deliveryID string, records []ProjectionDocument) error

+ type DocumentStore interface

+ Get func(context.Context, string, string, any) (bool, error)

+ Query func(context.Context, string, map[string]any, int, any) error

+ Set func(context.Context, string, string, any) error

+ UpdateAtomic func(context.Context, func(DocumentTransaction) error) error

+ type DocumentTransaction interface

+ Delete func(context.Context, string, string) error

+ Get func(context.Context, string, string, any) (bool, error)

+ Set func(context.Context, string, string, any) error

Sep 10, 2026

Changes in this version

type FirestoreTransaction

+ Delete func(context.Context, string, string) error

Sep 6, 2026

Changes in this version

+ var ErrPublisherIdentity = errors.New("machine publisher identity is unavailable")

+ var ErrPublisherMismatch = errors.New("published login or machine does not match the authenticated publisher")

type HandlerOptions

+ MachineSnapshots *MachineSnapshotService

+ PublisherResolver MachinePublisherResolver

+ type MachinePublisher struct

+ Login string

+ Machine string

+ type MachinePublisherResolver interface

+ Publisher func(*http.Request) (MachinePublisher, error)

+ type MachineSnapshotService struct

+ Now func() time.Time

+ Store machinesnapshot.SnapshotStore

+ func (service MachineSnapshotService) List(ctx context.Context, publisher MachinePublisher) (machinesnapshot.ListResponse, error)

+ func (service MachineSnapshotService) Publish(ctx context.Context, publisher MachinePublisher, ...) (machinesnapshot.Receipt, error)

type RemoteStateWorktreeReadModel

+ Store machinesnapshot.SnapshotStore

Sep 6, 2026

Changes in this version

+ const DefaultMachineStaleAfter

+ type MachineAccessResolver interface

+ CanViewMachine func(context.Context, Viewer, string, string) (bool, error)

+ type RemoteSnapshotSource interface

+ List func(context.Context) ([]remotestate.Entry, error)

+ type RemoteStateWorktreeReadModel struct

+ Access MachineAccessResolver

+ Now func() time.Time

+ Source RemoteSnapshotSource

+ StaleAfter time.Duration

+ func (model RemoteStateWorktreeReadModel) Worktrees(ctx context.Context, viewer Viewer, filter WorktreeFilter) (Access[WorktreeTable], error)

type Service

+ Worktrees WorktreeReadModel

+ func (service Service) WorktreeTable(ctx context.Context, viewer Viewer, filter WorktreeFilter) (WorktreeTable, error)

+ type WorktreeFilter struct

+ Machine string

+ NeedsAttention *bool

+ Repository string

+ Status string

+ Stream string

+ Task string

+ type WorktreeReadModel interface

+ Worktrees func(context.Context, Viewer, WorktreeFilter) (Access[WorktreeTable], error)

+ type WorktreeRow struct

+ AttentionReason string

+ Branch string

+ LastActivityAt *time.Time

+ Lifecycle string

+ Machine string

+ MachineSeenAt time.Time

+ MachineStale bool

+ NeedsAttention bool

+ Owner string

+ OwnerStatus string

+ PublishedAt time.Time

+ PullRequest int

+ PullRequestURL string

+ Repository string

+ Status string

+ Stream string

+ Task string

+ type WorktreeTable struct

+ GeneratedAt time.Time

+ Rows []WorktreeRow

Sep 6, 2026

Changes in this version

+ type RepositoryLatestMerges struct

+ Entries []LatestMerge

+ PublicOptIn bool

+ Repository string

Sep 6, 2026

Changes in this version

+ type InstallationTokenSource struct

+ APIBase string

+ AppID int64

+ Now func() time.Time

+ PrivateKeyPEM []byte

+ Transport http.RoundTripper

+ func (source InstallationTokenSource) Token(ctx context.Context, delivery WebhookDelivery) (string, error)

Sep 6, 2026

Changes in this version

+ type AuthoritativeProjectionReader interface

+ RefreshAuthoritativeProjection func(context.Context, WebhookDelivery) (ProjectionSnapshot, error)

+ type GitHubRESTProjectionReader struct

+ APIBase string

+ HTTP HTTPDoer

+ Now func() time.Time

+ Tokens GitHubTokenSource

+ func (reader GitHubRESTProjectionReader) Refresh(ctx context.Context, delivery WebhookDelivery) error

+ func (reader GitHubRESTProjectionReader) RefreshAuthoritativeProjection(ctx context.Context, delivery WebhookDelivery) (ProjectionSnapshot, error)

+ func (reader GitHubRESTProjectionReader) RefreshProjection(ctx context.Context, delivery WebhookDelivery) (ProjectionSnapshot, error)

+ type GitHubTokenSource interface

+ Token func(context.Context, WebhookDelivery) (string, error)

+ type HTTPDoer interface

+ Do func(*http.Request) (*http.Response, error)

Sep 6, 2026

Changes in this version

+ func ValidatePublicEligibility(evidence PublicEligibility) error

+ type FirestoreBackend interface

+ Get func(context.Context, string, string, any) (bool, error)

+ Query func(context.Context, string, map[string]any, int, any) error

+ Set func(context.Context, string, string, any) error

+ UpdateAtomic func(context.Context, func(FirestoreTransaction) error) error

+ type FirestoreProjectionDeliveryStore struct

+ Backend FirestoreBackend

+ Lease time.Duration

+ Now func() time.Time

+ func (store FirestoreProjectionDeliveryStore) ClaimDelivery(ctx context.Context, id string) (bool, error)

+ func (store FirestoreProjectionDeliveryStore) CommitDeliveryAndWakeup(ctx context.Context, id string, wakeup Wakeup) (bool, error)

+ func (store FirestoreProjectionDeliveryStore) HasDelivery(ctx context.Context, id string) (bool, error)

+ func (store FirestoreProjectionDeliveryStore) ReleaseDelivery(ctx context.Context, id string) error

+ type FirestoreProjectionStore struct

+ Backend FirestoreBackend

+ func (store FirestoreProjectionStore) GetLeaderboard(ctx context.Context, metric string) (LeaderboardDocument, error)

+ func (store FirestoreProjectionStore) GetProjection(ctx context.Context, scope Scope, id string) (ProjectionDocument, error)

+ func (store FirestoreProjectionStore) ListProjections(ctx context.Context, scope Scope) ([]ProjectionDocument, error)

+ func (store FirestoreProjectionStore) ListPublicLatestMerges(ctx context.Context, limit int) (PublicLatestMerges, error)

+ func (store FirestoreProjectionStore) ListSeries(ctx context.Context, scope Scope, id, metric string) (SeriesDocument, error)

+ type FirestoreProjectionWriter struct

+ Backend FirestoreBackend

+ func (writer FirestoreProjectionWriter) WriteLatestMerges(ctx context.Context, deliveryID string, records []LatestMerge) error

+ func (writer FirestoreProjectionWriter) WriteOrganizations(ctx context.Context, deliveryID string, records []ProjectionDocument) error

+ func (writer FirestoreProjectionWriter) WriteRepositories(ctx context.Context, deliveryID string, records []ProjectionDocument) error

+ type FirestoreTransaction interface

+ Get func(context.Context, string, string, any) (bool, error)

+ Set func(context.Context, string, string, any) error

type ProjectionDocument

+ PublicEligibility *PublicEligibility

type PublicEligibility

+ VerifiedAt time.Time

+ func VerifyPublicEligibility(repository, readmeURL, markdown string, verifiedAt time.Time) (PublicEligibility, error)

Sep 6, 2026

Changes in this version

+ var ErrInvalidProjection = errors.New("invalid workbench projection snapshot")

+ var ErrNoProjector = errors.New("workbench projection engine is not configured")

+ type ProjectionDeliveryStore interface

+ ClaimDelivery func(context.Context, string) (bool, error)

+ ReleaseDelivery func(context.Context, string) error

+ type ProjectionEngine struct

+ AuthoritativeReader AuthoritativeReader

+ Deliveries ProjectionDeliveryStore

+ Reader ProjectionReader

+ WebhookSecret []byte

+ Writer ProjectionWriter

+ func (engine ProjectionEngine) Process(ctx context.Context, delivery WebhookDelivery, signature string) (queued bool, processErr error)

+ type ProjectionReader interface

+ RefreshProjection func(context.Context, WebhookDelivery) (ProjectionSnapshot, error)

+ type ProjectionSnapshot struct

+ LatestMerges []LatestMerge

+ Organizations []ProjectionDocument

+ Repositories []ProjectionDocument

+ type ProjectionWriter interface

+ WriteLatestMerges func(context.Context, string, []LatestMerge) error

+ WriteOrganizations func(context.Context, string, []ProjectionDocument) error

+ WriteRepositories func(context.Context, string, []ProjectionDocument) error

type Service

+ Projector *ProjectionEngine

Sep 6, 2026

Changes in this version

+ const LeaderboardCollection

+ const MergeCollection

+ const ProjectionCollection

+ const SeriesCollection

+ var ErrProjectionNotFound = errors.New("workbench projection not found")

+ func ProjectionKey(scope Scope, id string) string

+ func ValidateProjectionDocument(document ProjectionDocument) error

+ type LeaderboardDocument struct

+ Entries []LeaderboardEntry

+ Metric string

+ PublicOnly bool

+ type MembershipResolver interface

+ Member func(context.Context, Viewer, Scope, string) (bool, error)

+ type ProjectionDocument struct

+ DisplayName string

+ ID string

+ PublicOptIn bool

+ Scope Scope

+ Summary Summary

+ UpdatedAt time.Time

+ type ProjectionStore interface

+ GetLeaderboard func(context.Context, string) (LeaderboardDocument, error)

+ GetProjection func(context.Context, Scope, string) (ProjectionDocument, error)

+ ListProjections func(context.Context, Scope) ([]ProjectionDocument, error)

+ ListPublicLatestMerges func(context.Context, int) (PublicLatestMerges, error)

+ ListSeries func(context.Context, Scope, string, string) (SeriesDocument, error)

+ type PublicLatestMerges struct

+ Entries []LatestMerge

+ type SeriesDocument struct

+ ID string

+ Metric string

+ Points []SeriesPoint

+ Scope Scope

+ type StoreReadModel struct

+ Membership MembershipResolver

+ Store ProjectionStore

+ func (model StoreReadModel) Dashboard(ctx context.Context, viewer Viewer) (Access[Dashboard], error)

+ func (model StoreReadModel) LatestMerges(ctx context.Context, viewer Viewer, limit int) (Access[[]LatestMerge], error)

+ func (model StoreReadModel) Leaderboard(ctx context.Context, viewer Viewer, metric string) (Access[Leaderboard], error)

+ func (model StoreReadModel) Series(ctx context.Context, viewer Viewer, scope Scope, id, metric string) (Access[Series], error)

+ func (model StoreReadModel) Stats(ctx context.Context, viewer Viewer, scope Scope, id string) (Access[Stat], error)

Sep 6, 2026

Changes in this version

+ const APIPrefix

+ const ControlPlaneHost

+ const ControlPlaneOrigin

+ const UIOrigin

+ var ErrNoReadModel = errors.New("workbench read model is not configured")

+ var ErrNoWebhook = errors.New("workbench webhook processor is not configured")

+ var ErrPrivateData = errors.New("private Workbench data requires membership")

+ func NewHandler(options HandlerOptions) http.Handler

+ type Access struct

+ Value T

+ Visibility Visibility

+ type AuthoritativeReader interface

+ Refresh func(context.Context, WebhookDelivery) error

+ type Dashboard struct

+ GeneratedAt time.Time

+ Links []Link

+ Summary Summary

+ type DeliveryStore interface

+ CommitDeliveryAndWakeup func(context.Context, string, Wakeup) (bool, error)

+ HasDelivery func(context.Context, string) (bool, error)

+ type Event struct

+ At time.Time

+ ID uint64

+ Operation string

+ Payload json.RawMessage

+ Repository string

+ Session string

+ Severity string

+ Task string

+ Type EventType

+ Visibility Visibility

+ type EventFilter struct

+ After uint64

+ Operation string

+ Repository string

+ Session string

+ Severity string

+ Since time.Time

+ Task string

+ type EventSource interface

+ Replay func(context.Context, EventFilter) ([]Event, error)

+ Subscribe func(context.Context, EventFilter) (<-chan Event, error)

+ type EventType string

+ const EventCI

+ const EventCleanup

+ const EventDaemonGeneration

+ const EventJobPhase

+ const EventJobProgress

+ const EventQueue

+ const EventSync

+ type HandlerOptions struct

+ AllowedOrigin string

+ Service Service

+ ViewerResolver ViewerResolver

+ type LatestMerge struct

+ IssueURL string

+ MergeCommitSHA string

+ MergeCommitURL string

+ MergedAt time.Time

+ PullRequest int

+ PullRequestURL string

+ ReceiptURL string

+ ReleaseURL string

+ Repository string

+ type Leaderboard struct

+ Entries []LeaderboardEntry

+ Metric string

+ type LeaderboardEntry struct

+ DisplayName string

+ Rank int

+ SubjectID string

+ Value int64

+ type Link struct

+ Href string

+ Kind string

+ type PublicEligibility struct

+ GrantedAt time.Time

+ READMEURL string

+ Repository string

+ type ReadModel interface

+ Dashboard func(context.Context, Viewer) (Access[Dashboard], error)

+ LatestMerges func(context.Context, Viewer, int) (Access[[]LatestMerge], error)

+ Leaderboard func(context.Context, Viewer, string) (Access[Leaderboard], error)

+ Series func(context.Context, Viewer, Scope, string, string) (Access[Series], error)

+ Stats func(context.Context, Viewer, Scope, string) (Access[Stat], error)

+ type Scope string

+ const ScopeOrganization

+ const ScopeRepository

+ const ScopeUser

+ type Series struct

+ ID string

+ Metric string

+ Points []SeriesPoint

+ Scope Scope

+ type SeriesPoint struct

+ At time.Time

+ Value int64

+ type Service struct

+ AuthoritativeReader AuthoritativeReader

+ Deliveries DeliveryStore

+ Events EventSource

+ ReadModel ReadModel

+ WebhookSecret []byte

+ func (service Service) Dashboard(ctx context.Context, viewer Viewer) (Dashboard, error)

+ func (service Service) EventStream(ctx context.Context, viewer Viewer, filter EventFilter) ([]Event, <-chan Event, error)

+ func (service Service) LatestMerges(ctx context.Context, viewer Viewer, limit int) ([]LatestMerge, error)

+ func (service Service) Leaderboard(ctx context.Context, viewer Viewer, metric string) (Leaderboard, error)

+ func (service Service) ProcessWebhook(ctx context.Context, delivery WebhookDelivery, signature string) (bool, error)

+ func (service Service) Series(ctx context.Context, viewer Viewer, scope Scope, id, metric string) (Series, error)

+ func (service Service) Stats(ctx context.Context, viewer Viewer, scope Scope, id string) (Stat, error)

+ type Stat struct

+ DisplayName string

+ ID string

+ Links []Link

+ Scope Scope

+ Summary Summary

+ UpdatedAt time.Time

+ type Summary struct

+ MergedPulls int

+ OpenIssues int

+ OpenPulls int

+ Releases int

+ Repositories int

+ type Viewer struct

+ Authenticated bool

+ Member bool

+ UserID string

+ type ViewerResolver interface

+ Viewer func(*http.Request) (Viewer, error)

+ type Visibility string

+ const VisibilityPrivate

+ const VisibilityPublic

+ type Wakeup struct

+ Event string

+ Key string

+ Repository string

+ type WebhookDelivery struct

+ Event string

+ ID string

+ Payload []byte

+ Repository string