facade4datatug

Oct 16, 2026

Changes in this version

+ func EmbeddedDemoSessionScope(space, project, environment string) (sessioncontext.Scope, sessioncontext.Subject, error)

+ func SessionNativeRepository(mounted sessioncontext.MountedDatabase, scope SessionOperationScope) (*sessioncontext.DALRepository, error)

+ type HostedSessionDetectiveOptions struct

+ ActiveAccount func(context.Context, string) error

+ AuthorizeContent func(context.Context, string, SessionOperationScope, *sessioncontext.Scope) error

+ Detective *DetectiveService

+ Enabled bool

+ Mounted sessioncontext.MountedDatabase

+ type HostedSessionDetectiveService struct

+ func NewHostedSessionDetectiveService(options HostedSessionDetectiveOptions) (*HostedSessionDetectiveService, error)

+ func (s *HostedSessionDetectiveService) Dispatch(ctx context.Context, actor string, scope SessionOperationScope, ...) (SessionDetectiveStatus, error)

+ func (s *HostedSessionDetectiveService) Enabled() bool

+ func (s *HostedSessionDetectiveService) ProviderAvailable() bool

+ func (s *HostedSessionDetectiveService) RedactAcceptedPins(ctx context.Context, actor string, scope SessionOperationScope, ...) (string, error)

+ func (s *HostedSessionDetectiveService) RequireActiveAccount(ctx context.Context, actor string) error

+ func (s *HostedSessionDetectiveService) Status(ctx context.Context, actor string, scope SessionOperationScope, op string, ...) (SessionDetectiveStatus, error)

+ type SessionDetectiveBinding struct

+ EntryID string

+ InputName string

+ RevisionID string

+ type SessionDetectiveRequest struct

+ Attachments []sessioncontext.EntryRef

+ Bindings []SessionDetectiveBinding

+ CaseID string

+ CheckID string

+ ExpectedContextSetID string

+ ExpectedVersion int64

+ Inputs map[string]detective.InputValue

+ OpID string

+ Scope sessioncontext.Scope

+ SessionID string

+ type SessionDetectiveStatus struct

+ OperationID string

+ OperationScope SessionOperationScope

+ Status sessioncontext.AcceptedDetectiveStatus

+ type SessionOperationScope struct

+ DatabaseID string

+ NamespaceID string

+ Project string

+ ProjectID string

+ SpaceID string

+ Storage string

+ func SessionOperationScopeFor(mounted sessioncontext.MountedDatabase, storage, source, space, project string) (SessionOperationScope, error)

Oct 15, 2026

Changes in this version

type SharedProjectService

+ func (s *SharedProjectService) SessionContextDemoEnvironments(ctx context.Context, actor, spaceID, projectID string) ([]string, error)

Oct 14, 2026

Changes in this version

+ const HostedEmbeddedDemoOrigin

+ var ErrDetectiveCapacity = errors.New("hosted Detective capacity reached")

+ var ErrDetectiveConflict = errors.New("hosted Detective operation conflict")

+ var ErrDetectiveInterrupted = errors.New("hosted execution interrupted; start a new authorized operation")

+ var ErrDetectiveInvalid = errors.New("invalid hosted Detective request")

+ var ErrDetectiveSnapshot = errors.New("hosted execution snapshot unavailable")

+ var ErrDetectiveUnauthorized = errors.New("hosted Detective access denied")

+ var ErrDetectiveUnavailable = errors.New("hosted Detective unavailable")

+ type DemoPersonalSpaceProvisioner interface

+ EnsurePersonalSpace func(context.Context, string) (PersonalAccount, error)

+ type DetectiveDemoProjectRequest struct

+ OperationID string

+ SpaceID string

+ type DetectivePersonalActivationOptions struct

+ Activator contract4spaceus.TransactionalPersonalCapabilityActivator

+ type DetectiveService struct

+ func NewDetectiveService(project *SharedProjectService, executor HostedDetectiveQueryExecutor) (*DetectiveService, error)

+ func (s *DetectiveService) AIConfirm(ctx context.Context, actor string, request HostedAIConfirm) (detectiveai.Receipt, error)

+ func (s *DetectiveService) AIGenerate(ctx context.Context, actor string, request HostedAIGenerate, ...) (detectiveai.Response, error)

+ func (s *DetectiveService) AIProposals(ctx context.Context, actor, space, project, after string) (HostedAIPage, error)

+ func (s *DetectiveService) AIReview(ctx context.Context, actor string, request HostedAIReview) (detectiveai.Proposal, error)

+ func (s *DetectiveService) Action(ctx context.Context, actor string, request HostedDetectiveAction) (HostedDetectiveResponse, error)

+ func (s *DetectiveService) CaseEvents(ctx context.Context, actor, space, project, caseID string, before int) (detective.CaseEventsPage, error)

+ func (s *DetectiveService) ConfigureDemo(space DemoPersonalSpaceProvisioner, authority SharedProjectCreateAuthority) error

+ func (s *DetectiveService) ConfigureDemoWithActivation(space DemoPersonalSpaceProvisioner, owner PersonalPlanOwnerPort, ...) error

+ func (s *DetectiveService) ConfigureIncidents(store incidents.APIStore, storeID string) error

+ func (s *DetectiveService) ConfigurePaidEnvironments(provider HostedProjectEnvironmentProvider) error

+ func (s *DetectiveService) CreateOrResumeDemo(ctx context.Context, actor string, request DetectiveDemoProjectRequest) (models4datatug.SharedProjectRef, error)

+ func (s *DetectiveService) IncidentAction(ctx context.Context, actor string, request HostedIncidentAction) (HostedIncidentResponse, error)

+ func (s *DetectiveService) KnowledgeAction(ctx context.Context, actor string, request HostedKnowledgeAction) (HostedKnowledgeResponse, error)

+ func (s *DetectiveService) KnowledgeProposals(ctx context.Context, actor, space, project, after string) (HostedKnowledgePage, error)

+ func (s *DetectiveService) LinkedIncidents(ctx context.Context, actor, space, project, caseID string) (HostedIncidentLinks, error)

+ func (s *DetectiveService) RunSavedQuery(ctx context.Context, actor string, request HostedQueryRunRequest) (HostedQueryRunResponse, error)

+ func (s *DetectiveService) State(ctx context.Context, actor, space, project, runsBefore string) (detective.State, error)

+ type HostedAIConfirm struct

+ type HostedAIGenerate struct

+ CaseID string

+ ExpectedCounts map[string]int

+ OperationID string

+ Sources []detectiveai.Source

+ Text string

+ type HostedAIPage struct

+ HasMore bool

+ NextCursor string

+ Proposals []detectiveai.Proposal

+ type HostedAIProjectRef struct

+ Project string

+ SpaceID string

+ Storage string

+ type HostedAIReview struct

+ Context *detectiveai.ContextReviewRequest

+ Draft *detectiveai.ReviewedDraftRequest

+ Type string

+ type HostedDemoExecutor struct

+ Embedded *HostedEmbeddedDemoExecutor

+ Public *HostedOVDBExecutor

+ func (e *HostedDemoExecutor) ExecuteSavedQuery(ctx context.Context, request HostedSavedQueryExecution) (HostedSavedQueryResult, error)

+ type HostedDetectiveAction struct

+ IfMatch int64

+ OperationID string

+ SpaceID string

+ Storage string

+ type HostedDetectiveQueryExecutor interface

+ ExecuteSavedQuery func(context.Context, HostedSavedQueryExecution) (HostedSavedQueryResult, error)

+ type HostedDetectiveResponse struct

+ CaseLinkStatus string

+ Receipt string

+ Revision int64

+ type HostedEmbeddedDemoExecutor struct

+ func NewHostedEmbeddedDemoExecutor(now func() time.Time) (_ *HostedEmbeddedDemoExecutor, err error)

+ func (d *HostedEmbeddedDemoExecutor) Close() error

+ type HostedIncidentAction struct

+ Case *detective.Case

+ CaseID string

+ Description string

+ Environment string

+ IfMatch int64

+ IncidentRef string

+ OperationID string

+ Project string

+ SpaceID string

+ Storage string

+ Title string

+ Type string

+ type HostedIncidentLinks struct

+ CaseID string

+ Incidents []incidents.IncidentView

+ type HostedIncidentResponse struct

+ Case *detective.Case

+ CaseLinkStatus string

+ Incident incidents.IncidentView

+ LinkPendingReason string

+ Receipt string

+ type HostedIncidentStore struct

+ func NewHostedIncidentStore(project *SharedProjectService, storeID string) (*HostedIncidentStore, error)

+ func (*HostedIncidentStore) Merge(context.Context, incidents.MergeMutation) (incidents.MergeResult, error)

+ func (s *HostedIncidentStore) Append(ctx context.Context, mutation incidents.Mutation) (incidents.AppendResult, error)

+ func (s *HostedIncidentStore) Create(ctx context.Context, mutation incidents.CreateMutation) (incidents.CreateResult, error)

+ func (s *HostedIncidentStore) Events(ctx context.Context, ref incidents.IncidentRef, afterSeq uint64) ([]incidents.Event, error)

+ func (s *HostedIncidentStore) List(ctx context.Context, query incidents.CandidateListQuery) ([]incidents.Incident, error)

+ func (s *HostedIncidentStore) Projection(ctx context.Context, ref incidents.IncidentRef, at *time.Time) (incidents.Incident, error)

+ func (s *HostedIncidentStore) Watch(ctx context.Context, query incidents.WatchQuery) (incidents.EventStream, error)

+ type HostedKnowledgeAction struct

+ IfMatch int64

+ OperationID string

+ Project string

+ Proposal *HostedKnowledgeProposal

+ ProposalID string

+ ReviewNote string

+ SpaceID string

+ Storage string

+ Target *HostedKnowledgeTarget

+ Type string

+ type HostedKnowledgeHandoff struct

+ CaseID string

+ ClaimStatus string

+ EvidenceRefs []string

+ FindingRefs []string

+ Kind string

+ PreparedAt time.Time

+ PreparedBy string

+ ProposalID string

+ ProposalVersion int64

+ Receipt string

+ Statement string

+ Status string

+ Target HostedKnowledgeTarget

+ type HostedKnowledgePage struct

+ HasMore bool

+ NextCursor string

+ Proposals []HostedKnowledgeProposal

+ type HostedKnowledgeProposal struct

+ CaseID string

+ ClaimStatus string

+ CreatedAt time.Time

+ CreatedBy string

+ EvidenceRefs []string

+ FindingRefs []string

+ Handoffs []HostedKnowledgeHandoff

+ ID string

+ Kind string

+ ReviewNote string

+ ReviewedAt time.Time

+ ReviewedBy string

+ Statement string

+ Status string

+ Title string

+ Version int64

+ type HostedKnowledgeResponse struct

+ Export *HostedKnowledgeHandoff

+ Proposal *HostedKnowledgeProposal

+ Receipt string

+ type HostedKnowledgeTarget struct

+ ExpectedRevision string

+ Repository string

+ ResourceID string

+ System string

+ type HostedOVDBExecutor struct

+ AllowedSources map[string]map[string]bool

+ Client *http.Client

+ Now func() time.Time

+ Origin string

+ func (e *HostedOVDBExecutor) ExecuteSavedQuery(ctx context.Context, request HostedSavedQueryExecution) (HostedSavedQueryResult, error)

+ type HostedProjectEnvironmentBinding struct

+ Name string

+ ProjectID string

+ Sources []HostedProjectSourceBinding

+ SpaceID string

+ type HostedProjectEnvironmentProvider interface

+ ReadProjectEnvironments func(context.Context, dal.ReadTransaction, string, string) ([]HostedProjectEnvironmentBinding, error)

+ type HostedProjectSourceBinding struct

+ Collection string

+ Database string

+ Origin string

+ type HostedQueryRunRequest struct

+ Environment string

+ Inputs map[string]apicontract.TypedValueOrSet

+ OperationID string

+ Project string

+ QueryID string

+ SpaceID string

+ Storage string

+ type HostedQueryRunResponse struct

+ QueryRevision string

+ Receipt string

+ Result apicontract.Result

+ ResultFingerprint string

+ type HostedSavedQueryExecution struct

+ ActorID string

+ Environment string

+ Inputs map[string]apicontract.TypedValueOrSet

+ ProjectID string

+ QueryID string

+ QueryJSON []byte

+ Revision string

+ SpaceID string

+ type HostedSavedQueryResult struct

+ Fingerprint string

+ ResultJSON []byte

+ Revision string

type SharedProjectService

+ func NewDetectiveSharedProjectService(db dal.DB, ids IDGenerator, now func() time.Time, ...) (*SharedProjectService, error)

Oct 13, 2026

Changes in this version

type SharedProjectService

+ func (s *SharedProjectService) AuthorizeSessionContextProject(ctx context.Context, actor, spaceID, projectID string) error

Oct 11, 2026

Changes in this version

+ var ErrSharedProjectQueryConflict = errors.New("shared project query conflict")

+ var ErrSharedProjectQueryInvalid = errors.New("invalid shared project query")

+ var ErrSharedProjectQueryUnavailable = errors.New("shared project query unavailable")

+ type SharedProjectQueryOperationScope struct

+ ActorID string

+ Kind string

+ ProjectID string

+ SpaceID string

+ StoreID string

+ func (s SharedProjectQueryOperationScope) Validate() error

+ type SharedProjectQueryReadResult struct

+ Query json.RawMessage

+ Revision string

+ SaveSupported bool

+ UnsupportedSaveReason string

type SharedProjectService

+ func (s *SharedProjectService) ListSharedProjectQueries(ctx context.Context, actorID, spaceID, projectID string) ([]datatug.QueryDefWithFolderPath, error)

+ func (s *SharedProjectService) ReadSharedProjectQuery(ctx context.Context, actorID, spaceID, projectID, folderPath, queryID string) (*SharedProjectQueryReadResult, error)

+ func (s *SharedProjectService) ReadSharedProjectSummary(ctx context.Context, actorID, spaceID, projectID string) (json.RawMessage, error)

+ func (s *SharedProjectService) SaveSharedProjectQuery(ctx context.Context, actorID, spaceID string, request dto.SaveQueryRequest) (*dto.SaveQueryResponse, error)

+ func (s *SharedProjectService) SharedProjectQueryCapabilities(ctx context.Context, actorID, spaceID, projectID string) (dto.ProjectCapabilities, error)

Oct 10, 2026

Changes in this version

type BusinessUsageTestClockRuntime

+ func (r *BusinessUsageTestClockRuntime) UsageInvoiceBuyerLookup() (contract4paymentus.UsageInvoiceBuyerLookup, error)

Oct 10, 2026

Changes in this version

type BusinessUsageTestClockRuntime

+ func (r *BusinessUsageTestClockRuntime) Drain(ctx context.Context, spaceID string, request QueryActivityDrainRequest) (QueryActivityDrainResult, error)

+ func (r *BusinessUsageTestClockRuntime) ReadPeriod(ctx context.Context, ref contract4paymentus.UsagePeriodRef) (contract4paymentus.UsagePeriodState, error)

+ func (r *BusinessUsageTestClockRuntime) ReplayPendingInvoicePaid(ctx context.Context, spaceID, eventID string, ...) error

+ type NativeProjectContactRoleTarget struct

+ func NewNativeProjectContactRoleTarget(contacts CurrentProjectContactPort, actors BusinessActivityActorVerifier) (*NativeProjectContactRoleTarget, error)

+ func (a *NativeProjectContactRoleTarget) AuthorizeProjectContactRoleChange(ctx context.Context, tx dal.ReadTransaction, ...) error

+ type NativeProjectRoleManager struct

+ func NewNativeProjectRoleManager(actors BusinessActivityActorVerifier) (*NativeProjectRoleManager, error)

+ func (a *NativeProjectRoleManager) AuthorizeProjectRoleMutation(ctx context.Context, tx dal.ReadTransaction, ...) error

Oct 10, 2026

Changes in this version

+ type GitHubActivityScope struct

+ ProjectID string

+ SpaceID string

type GitHubProjectAccess

+ ActivityScope *GitHubActivityScope

Oct 10, 2026

Changes in this version

+ type BusinessUsageTestClockRuntime struct

+ func NewBusinessUsageTestClockRuntime(options BusinessUsageRuntimeOptions, ...) (*BusinessUsageTestClockRuntime, error)

+ func (r *BusinessUsageTestClockRuntime) CloseDue(ctx context.Context, ref contract4paymentus.UsagePeriodRef) (contract4paymentus.UsagePeriodClose, error)

+ func (r *BusinessUsageTestClockRuntime) IssueContext(ctx context.Context, actorID, spaceID, projectID string) (QueryActivityContextResponse, error)

+ func (r *BusinessUsageTestClockRuntime) OpenCurrent(ctx context.Context, spaceID string) (contract4paymentus.UsagePeriodSnapshot, error)

+ func (r *BusinessUsageTestClockRuntime) PrepareInvoice(ctx context.Context, ref contract4paymentus.UsagePeriodRef) (contract4paymentus.UsageInvoiceResult, error)

+ func (r *BusinessUsageTestClockRuntime) ProcessInvoice(ctx context.Context, ref contract4paymentus.UsagePeriodRef) (contract4paymentus.UsageInvoiceResult, error)

+ func (r *BusinessUsageTestClockRuntime) ReadInvoice(ctx context.Context, ref contract4paymentus.UsagePeriodRef) (contract4paymentus.UsageInvoiceResult, error)

+ func (r *BusinessUsageTestClockRuntime) Report(ctx context.Context, actorID, spaceID string, request QueryActivityReport) (QueryActivityReportResult, error)

Oct 10, 2026

Changes in this version

+ var ErrBusinessUsageRuntimeUnavailable = errors.New("business usage runtime is unavailable")

type BusinessActivityBinding

+ PayerBindingDigest string

type BusinessProjectAccessPolicy

+ Mode contract4paymentus.Mode

type BusinessProjectAccessVerifier

+ func (v *BusinessProjectAccessVerifier) Mode() contract4paymentus.Mode

type BusinessUsageLifecycleResult

+ InvoicesProcessed int

type BusinessUsageLifecycleWorker

+ func NewBusinessUsageLifecycleWorkerWithInvoices(mode contract4paymentus.Mode, db dal.DB, query dal.QueryExecutor, ...) (*BusinessUsageLifecycleWorker, error)

type BusinessUsagePeriodAuthorityOptions

+ Mode contract4paymentus.Mode

+ type BusinessUsageRuntime struct

+ Access *BusinessProjectAccessVerifier

+ Activity *BusinessQueryActivityService

+ Invoices contract4paymentus.UsageInvoiceService

+ Ledger contract4paymentus.UsageLedger

+ PayerAuthority contract4paymentus.UsagePeriodInvoicePayerAuthority

+ PeriodReader contract4paymentus.UsagePeriodReader

+ Periods *BusinessUsagePeriodService

+ Worker *BusinessUsageLifecycleWorker

+ func NewBusinessUsageRuntime(options BusinessUsageRuntimeOptions) (*BusinessUsageRuntime, error)

+ type BusinessUsageRuntimeOptions struct

+ AccessPolicy BusinessProjectAccessPolicy

+ Actors BusinessActivityActorVerifier

+ Contacts CurrentProjectContactPort

+ CurrentService contract4paymentus.CurrentSpaceServiceReader

+ DB dal.DB

+ InitialStarts contract4paymentus.InitialServiceStartReader

+ InvoiceProvider contract4paymentus.UsageInvoiceProvider

+ Mode contract4paymentus.Mode

+ Now func() time.Time

+ Pricing func() contract4paymentus.UsagePricingConfig

+ Query dal.QueryExecutor

+ TaxPolicies []BusinessUsageTaxPolicyRegistration

+ type BusinessUsageTaxPolicyRegistration struct

+ Current bool

+ Policy contract4paymentus.UsageInvoiceStripeTaxPolicy

type SpaceServiceAccess

+ CustomerID string

+ LineageID string

+ ProviderAccountID string

Oct 10, 2026

Changes in this version

+ const BusinessUsageLifecycleMaxPageSize

+ var ErrBusinessUsageLifecycleUnavailable = errors.New("business usage lifecycle worker is unavailable")

+ type BusinessQueryActivityService struct

+ func NewBusinessQueryActivityService(periods BusinessUsagePeriodOpener, activity QueryActivityContextService) (*BusinessQueryActivityService, error)

+ func (s *BusinessQueryActivityService) IssueContext(ctx context.Context, actorID, spaceID, projectID string) (QueryActivityContextResponse, error)

+ func (s *BusinessQueryActivityService) Report(ctx context.Context, actorID, spaceID string, request QueryActivityReport) (QueryActivityReportResult, error)

+ type BusinessUsageLifecycleResult struct

+ ActivityDelivered int

+ ActivityScanned int

+ ActivitySpaces int

+ CheckpointAfter string

+ CheckpointHasMore bool

+ CheckpointsScanned int

+ Failures int

+ PendingAfter string

+ PendingHasMore bool

+ PeriodsClosed int

+ PeriodsOpened int

+ type BusinessUsageLifecycleWorker struct

+ func NewBusinessUsageLifecycleWorker(db dal.DB, query dal.QueryExecutor, periods *BusinessUsagePeriodService, ...) (*BusinessUsageLifecycleWorker, error)

+ func (w *BusinessUsageLifecycleWorker) Run(ctx context.Context, pageSize int) (BusinessUsageLifecycleResult, error)

+ type BusinessUsagePeriodOpener interface

+ OpenCurrent func(context.Context, string) (contract4paymentus.UsagePeriodSnapshot, error)

type BusinessUsagePeriodService

+ func (s *BusinessUsagePeriodService) CloseDue(ctx context.Context, ref contract4paymentus.UsagePeriodRef) (contract4paymentus.UsagePeriodClose, error)

+ func (s *BusinessUsagePeriodService) ResumeOpening(ctx context.Context, ref contract4paymentus.UsagePeriodRef) (contract4paymentus.UsagePeriodSnapshot, error)

+ type QueryActivityContextService interface

+ IssueContext func(context.Context, string, string, string) (QueryActivityContextResponse, error)

+ Report func(context.Context, string, string, QueryActivityReport) (QueryActivityReportResult, error)

Oct 10, 2026

Changes in this version

+ const BusinessUsageCloseGrace

+ const QueryActivityWatermarkBatchSize

+ var ErrBusinessUsagePeriodUnavailable = errors.New("business usage period is unavailable")

type BusinessActivityBindingReaderOptions

+ Periods contract4paymentus.UsagePeriodReader

+ type BusinessUsageCloseTerms struct

+ BaseEvent contract4paymentus.UsageBaseEvent

+ BillMonthlyOverage bool

+ Capacity contract4paymentus.UsageCapacityEvidence

+ DiscountPercent int

+ type BusinessUsageCloseTermsReader interface

+ ReadBusinessUsageCloseTerms func(context.Context, dal.ReadTransaction, contract4paymentus.UsagePeriodSnapshot) (BusinessUsageCloseTerms, error)

+ type BusinessUsagePeriodAuthorityOptions struct

+ Access *BusinessProjectAccessVerifier

+ CloseTerms BusinessUsageCloseTermsReader

+ InitialStarts contract4paymentus.InitialServiceStartReader

+ Now func() time.Time

+ Periods contract4paymentus.UsagePeriodReader

+ Pricing func() contract4paymentus.UsagePricingConfig

+ type BusinessUsagePeriodService struct

+ func NewBusinessUsagePeriodService(db dal.DB, authority *NativeBusinessUsagePeriodAuthority, ...) (*BusinessUsagePeriodService, error)

+ func (s *BusinessUsagePeriodService) Close(ctx context.Context, request contract4paymentus.UsageCloseRequest) (contract4paymentus.UsagePeriodClose, error)

+ func (s *BusinessUsagePeriodService) OpenCurrent(ctx context.Context, spaceID string) (contract4paymentus.UsagePeriodSnapshot, error)

+ type NativeBusinessUsageCloseTermsReader struct

+ func NewNativeBusinessUsageCloseTermsReader(db dal.DB, initialStarts contract4paymentus.InitialServiceStartReader, ...) (*NativeBusinessUsageCloseTermsReader, error)

+ func (r *NativeBusinessUsageCloseTermsReader) ReadBusinessUsageCloseTerms(ctx context.Context, tx dal.ReadTransaction, ...) (BusinessUsageCloseTerms, error)

+ type NativeBusinessUsagePeriodAuthority struct

+ func NewNativeBusinessUsagePeriodAuthority(options BusinessUsagePeriodAuthorityOptions) (*NativeBusinessUsagePeriodAuthority, error)

+ func (a *NativeBusinessUsagePeriodAuthority) VerifyUsage(ctx context.Context, tx dal.ReadTransaction, ...) error

Oct 10, 2026

Changes in this version

+ var ErrBusinessActivityBindingUnavailable = errors.New("business activity binding is unavailable")

+ type BusinessActivityActorVerifier interface

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

+ type BusinessActivityBindingReaderOptions struct

+ Access *BusinessProjectAccessVerifier

+ Actors BusinessActivityActorVerifier

+ Contacts CurrentProjectContactPort

+ InitialStarts contract4paymentus.InitialServiceStartReader

+ type NativeBusinessActivityBindingReader struct

+ func NewNativeBusinessActivityBindingReader(options BusinessActivityBindingReaderOptions) (*NativeBusinessActivityBindingReader, error)

+ func (r *NativeBusinessActivityBindingReader) ReadCurrentBusinessActivityBinding(ctx context.Context, tx dal.ReadTransaction, ...) (BusinessActivityBinding, error)

Oct 10, 2026

Changes in this version

type AccountPlanEffect

+ PlaceID string

Oct 10, 2026

Changes in this version

+ const BusinessAnnualPlanID

+ const BusinessMonthlyPlanID

+ const BusinessProjectAccountKind

+ const BusinessProjectOwnerFamily

+ const BusinessProjectProductID

+ const BusinessProjectServiceID

+ type BusinessProjectAccessPolicy struct

+ GrantVersion string

+ type BusinessSharedProjectOptions struct

+ AccessPolicy BusinessProjectAccessPolicy

+ ContactLinks *PaidProjectOwnerLinksOptions

+ ServiceReader contract4paymentus.CurrentSpaceServiceReader

type GitHubProjectCreateCommand

+ BillingIntent SharedProjectBillingIntent

type PaidProjectLinkageOptions

+ Business *BusinessProjectAccessVerifier

+ type ProBusinessSharedProjectOptions struct

+ Business BusinessSharedProjectOptions

+ Pro PaidSharedProjectOptions

+ type SharedProjectBillingIntent string

+ const BillingIntentPersonalPro

+ const BillingIntentSpaceBusiness

+ func (i SharedProjectBillingIntent) Validate() error

type SharedProjectCreateCommand

+ BillingIntent SharedProjectBillingIntent

type SharedProjectService

+ func NewActivatingBusinessSharedProjectService(db dal.DB, ids IDGenerator, now func() time.Time, ...) (*SharedProjectService, error)

+ func NewActivatingProBusinessSharedProjectService(db dal.DB, ids IDGenerator, now func() time.Time, ...) (*SharedProjectService, error)

+ func NewBusinessSharedProjectService(db dal.DB, ids IDGenerator, authority SharedProjectCreateAuthority, ...) (*SharedProjectService, error)

+ func NewProBusinessSharedProjectService(db dal.DB, ids IDGenerator, authority SharedProjectCreateAuthority, ...) (*SharedProjectService, error)

Oct 10, 2026

Changes in this version

+ const QueryActivityMaxDrainBatchSize

+ var ErrQueryActivityConflict = errors.New("query activity identity conflicts")

+ var ErrQueryActivityInvalid = errors.New("invalid query activity request")

+ var ErrQueryActivityRateLimited = errors.New("query activity rate limit exceeded")

+ var ErrQueryActivityUnauthorized = errors.New("query activity is unauthorized")

+ var ErrQueryActivityUnavailable = errors.New("query activity is unavailable")

+ type BusinessActivityBinding struct

+ PaidBindingProofID string

+ PaidUntilUTC time.Time

+ Period contract4paymentus.UsagePeriodRef

+ PeriodEndUTC time.Time

+ PeriodStartUTC time.Time

+ QueryUseAllowed bool

+ QueryUseProofID string

+ type BusinessActivityBindingReader interface

+ ReadCurrentBusinessActivityBinding func(context.Context, dal.ReadTransaction, string, string, string, time.Time) (BusinessActivityBinding, error)

+ type QueryActivityContextResponse struct

+ ContextID string

+ ExpiresAtUTC time.Time

+ type QueryActivityDrainRequest struct

+ AfterID string

+ Limit int

+ type QueryActivityDrainResult struct

+ Delivered int

+ Failed int

+ HasMore bool

+ NextAfterID string

+ Scanned int

+ type QueryActivityReport struct

+ ContextID string

+ Kind models4datatug.QueryActivityKind

+ OperationID string

+ type QueryActivityReportResult struct

+ Accepted bool

+ Coalesced bool

+ ReceiptID string

+ type QueryActivityService struct

+ func NewQueryActivityService(db dal.DB, binding BusinessActivityBindingReader, ...) (*QueryActivityService, error)

+ func (s *QueryActivityService) Deliver(ctx context.Context, spaceID, receiptID string) error

+ func (s *QueryActivityService) Drain(ctx context.Context, spaceID string, request QueryActivityDrainRequest) (QueryActivityDrainResult, error)

+ func (s *QueryActivityService) IssueContext(ctx context.Context, actorID, spaceID, projectID string) (QueryActivityContextResponse, error)

+ func (s *QueryActivityService) Report(ctx context.Context, actorID, spaceID string, report QueryActivityReport) (QueryActivityReportResult, error)

+ type QueryActivityUsageAuthority struct

+ func NewQueryActivityUsageAuthority() QueryActivityUsageAuthority

+ func (QueryActivityUsageAuthority) VerifyUsage(ctx context.Context, tx dal.ReadTransaction, ...) error

Oct 9, 2026

Changes in this version

+ var ErrBusinessServiceEnded = errors.New("business space service has ended")

+ var ErrBusinessServiceUnproved = errors.New("business space service access is unproved")

+ type BusinessProjectAccessVerifier struct

+ func NewBusinessProjectAccessVerifier(reader CurrentSpaceServiceAccessReader, now func() time.Time) (*BusinessProjectAccessVerifier, error)

+ func (v *BusinessProjectAccessVerifier) ReadCurrent(ctx context.Context, tx dal.ReadTransaction, spaceID string) (SpaceServiceAccess, error)

+ type CurrentSpaceServiceAccessReader interface

+ ReadCurrentSpaceServiceAccess func(context.Context, dal.ReadTransaction, string, string, string) (SpaceServiceAccess, error)

+ type SpaceServiceAccess struct

+ AccountKind string

+ GrantVersion string

+ Mode string

+ OwnerFamily string

+ OwnerGeneration int64

+ OwnerRevision int64

+ OwnerSubscriptionID string

+ PaidServiceProofID string

+ PaidUntilUTC time.Time

+ PayerSpaceID string

+ PlanID string

+ ProductID string

+ ServiceID string

+ State string

+ UnlimitedContacts bool

+ UnlimitedProjects bool

Oct 9, 2026

Changes in this version

type GitHubQuerySavePlan

+ BodyChanged bool

type PaidSharedProjectOptions

+ EnableQueryEditCandidates bool

Oct 8, 2026

Changes in this version

+ var ErrProjectAIEligibilityUnavailable = errors.New("project AI eligibility unavailable")

+ type ProjectAIEligibility struct

+ AIAllowed bool

+ Reason string

type SharedProjectService

+ func (s *SharedProjectService) ReadGitHubProjectAIEligibility(ctx context.Context, actorID string, repositoryID int64, ...) (ProjectAIEligibility, error)

+ func (s *SharedProjectService) ReadSharedProjectAIEligibility(ctx context.Context, actorID, spaceID, projectID string) (ProjectAIEligibility, error)

Oct 7, 2026

Changes in this version

+ var ErrProtectedProjectInventory = errors.New("protected project inventory could not be proved complete")

+ var ErrSharedProjectActivationUnavailable = errors.New("shared project activation is unavailable")

+ type DALProtectedProjectInventory struct

+ func NewDALProtectedProjectInventory(query dal.QueryExecutor) (*DALProtectedProjectInventory, error)

+ func (i *DALProtectedProjectInventory) CompleteProtectedProjectBasis(ctx context.Context, mode, product, payer string) (InitialProtectedProjectBasis, error)

+ type SharedProjectActivationOptions struct

+ Activator contract4spaceus.TransactionalRoleCapabilityActivator

+ InventoryQuery dal.QueryExecutor

+ RequiredRoles []string

type SharedProjectService

+ func NewActivatingPaidSharedProjectService(db dal.DB, ids IDGenerator, now func() time.Time, ...) (*SharedProjectService, error)

+ func (s *SharedProjectService) EnsureProtectedProjectQuotaForCreate(ctx facade.ContextWithUser, binding SharedProjectCreateBinding) error

+ func (s *SharedProjectService) PlanExplicitProjectCreateActivationInTransaction(ctx facade.ContextWithUser, tx dal.ReadwriteTransaction, ...) (contract4spaceus.PreparedRoleCapabilityActivation, error)

Oct 7, 2026

Changes in this version

+ var ErrGitHubOutcomeUncertain = errors.New("GitHub project create outcome uncertain")

+ var ErrGitHubProjectConflict = errors.New("GitHub project create conflict")

+ var ErrGitHubProjectInvalid = errors.New("invalid GitHub project create command")

+ var ErrGitHubProjectNotRegistered = errors.New("GitHub project is not registered")

+ var ErrGitHubQueryConflict = errors.New("GitHub query mutation conflict")

+ var ErrGitHubQueryInvalid = errors.New("invalid GitHub query mutation")

+ var ErrGitHubQueryOutcomeUncertain = errors.New("GitHub query mutation outcome uncertain")

+ type GitHubCreateRepository interface

+ CreateFilesCommit func(context.Context, string, string, string, map[string][]byte) (string, error)

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

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

+ FindCommitByMarker func(context.Context, string, string, string, map[string][]byte) (string, error)

+ Scope func() GitHubCreateRepositoryScope

+ type GitHubCreateRepositoryScope struct

+ ActorID string

+ Name string

+ Owner string

+ Permission string

+ RepositoryID int64

+ type GitHubProjectAccess struct

+ Binding models4datatug.GitHubProjectBinding

+ SharedProjectID string

+ SpaceID string

+ type GitHubProjectCreateCommand struct

+ ActorID string

+ OperationID string

+ Source models4datatug.GitHubCreateSource

+ SpaceID string

+ Title string

+ func (c GitHubProjectCreateCommand) Validate() error

+ type GitHubProjectCreateResult struct

+ Branch string

+ BranchHead string

+ ID string

+ Project string

+ Revision string

+ SharedProjectID string

+ SpaceID string

+ Storage string

+ TemplateCommit string

+ TemplateID string

+ type GitHubQueryExpectedFile struct

+ Mode string

+ OID string

+ Size int64

+ type GitHubQueryFileChange struct

+ Content []byte

+ Delete bool

+ Path string

+ type GitHubQueryRepository interface

+ CreateQueryCommit func(context.Context, string, string, string, *GitHubQuerySavePlan) (string, error)

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

+ FindQueryCommit func(context.Context, string, string, string, *GitHubQuerySavePlan) (string, error)

+ PrepareQuerySave func(context.Context, string, string, string, dto.SaveQueryRequest) (*GitHubQuerySavePlan, error)

+ Scope func() GitHubCreateRepositoryScope

+ type GitHubQuerySavePlan struct

+ Changes []GitHubQueryFileChange

+ ExpectedTree map[string]GitHubQueryExpectedFile

+ Response dto.SaveQueryResponse

type SharedProjectService

+ func (s *SharedProjectService) AuthorizeGitHubProjectWrite(ctx context.Context, actorID string, repositoryID int64, ...) (GitHubProjectAccess, error)

+ func (s *SharedProjectService) CreateGitHubProject(ctx context.Context, command GitHubProjectCreateCommand, ...) (GitHubProjectCreateResult, error)

+ func (s *SharedProjectService) ResolveGitHubProject(ctx context.Context, actorID string, repositoryID int64, ...) (GitHubProjectAccess, error)

+ func (s *SharedProjectService) SaveGitHubQuery(ctx context.Context, actorID string, repositoryID int64, ...) (*dto.SaveQueryResponse, error)

Oct 7, 2026

Changes in this version

+ var ErrProjectContactLimit = errors.New("protected project contact limit unavailable or exhausted")

+ type CurrentProjectContactPort interface

+ ReadCurrentProjectContact func(context.Context, dal.ReadTransaction, contract4linkage.RelationshipEntityRef) (ProjectContactState, error)

+ type PaidProjectLinkageOptions struct

+ Contacts CurrentProjectContactPort

+ Manager ProjectRoleManagerPort

+ Now func() time.Time

+ Paid PaidSharedProjectOptions

+ Roles ProjectRoleCatalog

+ Targets ProjectContactRoleTargetPort

+ type PaidProjectLinkagePolicy struct

+ func NewPaidProjectLinkagePolicy(o PaidProjectLinkageOptions) (*PaidProjectLinkagePolicy, error)

+ func (p *PaidProjectLinkagePolicy) AuthorizeRelationshipMutation(ctx context.Context, tx dal.ReadTransaction, ...) error

+ type PaidProjectOwnerLinksOptions struct

+ Contacts CurrentProjectContactPort

+ Owner ProjectOwnerContactPort

+ Roles ProjectRoleCatalog

type PaidSharedProjectOptions

+ ContactLinks *PaidProjectOwnerLinksOptions

+ type ProjectContactRoleChange struct

+ Before []string

+ Contact ProjectContactState

+ Proposed []string

+ type ProjectContactRoleTargetPort interface

+ AuthorizeProjectContactRoleChange func(context.Context, dal.ReadTransaction, ProjectRoleMutationAuthorization, ...) error

+ type ProjectContactState struct

+ Active bool

+ Exists bool

+ Ref contract4linkage.RelationshipEntityRef

+ UserID string

+ type ProjectOwnerContactPort interface

+ ResolveProjectOwnerContact func(context.Context, dal.ReadTransaction, SharedProjectCreateBinding) (contract4linkage.RelationshipEntityRef, error)

+ type ProjectRoleCatalog struct

+ OwnerRole string

+ Roles []string

+ Version string

+ type ProjectRoleEvidence struct

+ Contact ProjectContactState

+ Roles []string

+ type ProjectRoleManagerPort interface

+ AuthorizeProjectRoleMutation func(context.Context, dal.ReadTransaction, ProjectRoleMutationAuthorization) error

+ type ProjectRoleMutationAuthorization struct

+ ActorContacts []ProjectRoleEvidence

+ ActorID string

+ Changes []ProjectContactRoleChange

+ Project models4datatug.SharedProjectRef

Oct 6, 2026

Changes in this version

+ var ErrProtectedProjectQuota = errors.New("protected project quota unavailable or exhausted")

+ func InitializeProtectedProjectQuota(ctx context.Context, db dal.DB, options PaidSharedProjectOptions, ...) error

+ type InitialProtectedProjectBasis struct

+ Allocated int64

+ Digest string

+ type PaidSharedProjectOptions struct

+ Config PlanConfig

+ Directory PersonalAccountDirectory

+ Mode string

+ Owner interface{ ... }

+ Personal PersonalPlanOwnerPort

+ Product string

+ Version string

+ type ProtectedProjectBasisAuthority interface

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

type SharedProjectCreateBinding

+ Mode string

+ PayerID string

+ Product string

type SharedProjectService

+ func NewPaidSharedProjectService(db dal.DB, ids IDGenerator, authority SharedProjectCreateAuthority, ...) (*SharedProjectService, error)

Oct 6, 2026

Changes in this version

+ var ErrSharedProjectConflict = errors.New("shared project create command conflicts")

+ var ErrSharedProjectInvalid = errors.New("invalid shared project create command")

+ var ErrSharedProjectUnauthorized = errors.New("shared project creation is unauthorized")

+ var ErrSharedProjectUnavailable = errors.New("shared project creation is unavailable")

+ type PreparedSharedProjectCreate struct

+ Binding SharedProjectCreateBinding

+ IssuedAt time.Time

+ Validator SharedProjectCreateTransactionAuthority

+ type SharedProjectCreateAuthority interface

+ PrepareSharedProjectCreate func(context.Context, SharedProjectCreateBinding) (PreparedSharedProjectCreate, error)

+ type SharedProjectCreateBinding struct

+ ActorID string

+ CommandID string

+ RequestDigest string

+ SpaceID string

+ type SharedProjectCreateCommand struct

+ ActorID string

+ CommandID string

+ SpaceID string

+ Title string

+ func (c SharedProjectCreateCommand) Validate() error

+ type SharedProjectCreateTransactionAuthority interface

+ ValidateSharedProjectCreateInTransaction func(context.Context, dal.ReadwriteTransaction, SharedProjectCreateBinding, ...) error

+ type SharedProjectService struct

+ func NewSharedProjectService(db dal.DB, ids IDGenerator, authority SharedProjectCreateAuthority, ...) (*SharedProjectService, error)

+ func (s *SharedProjectService) Create(ctx context.Context, command SharedProjectCreateCommand) (models4datatug.SharedProjectRef, error)

Oct 6, 2026

Changes in this version

type AccountPlanEffect

+ TerminalFullRefund bool

type PlanEffectGrants

+ ProtectedProjectUsers *int64

+ ProtectedProjects *int64

type PlanFacts

+ TerminalFullRefund bool

Oct 6, 2026

Changes in this version

+ func ValidatePlanConfig(config PlanConfig) error

Oct 6, 2026

Changes in this version

+ type CallerAdmissionReader interface

+ ReadAdmissionForCaller func(context.Context, string, string, time.Time) (AdmissionState, error)

type PersonalPlanService

+ CallerAdmission CallerAdmissionReader

Oct 6, 2026

Changes in this version

+ var ErrPlanEffectUnproved = errors.New("plan effect is not proved")

+ type AccountPlanEffect struct

+ AccountKind string

+ AppliedPercent int

+ BasisOnly bool

+ BuyerID string

+ CashBasisKnown bool

+ CheckoutStartedAt time.Time

+ EffectiveEnd time.Time

+ Fence PlanOwnerFence

+ Grants PlanEffectGrants

+ LastPaidEnd time.Time

+ LastServiceRefund *ServiceRefundProof

+ LaunchGrant bool

+ MoneyIngestEpoch int64

+ ObservedAt time.Time

+ PaidService bool

+ PaidServiceProofID string

+ Payments []PlanPayment

+ Period string

+ PlanID string

+ QuoteKey string

+ ScheduledEnd time.Time

+ SourcePaidService bool

+ SourcePaidServiceProofID string

+ SourceQuoteKey string

+ SourceRevision int64

+ SourceSubscriptionID string

+ Status string

+ Tier string

+ type AccountPlanWriter struct

+ Allocator PaidMonthAllocator

+ Clock PlanClock

+ DB dal.DB

+ Limits ProLimitsResolver

+ Owner PlanEffectOwnerPort

+ Personal PersonalPlanOwnerPort

+ func (w AccountPlanWriter) Apply(ctx context.Context, effect AccountPlanEffect) (PlanApplyOutcome, error)

+ type ConfiguredProLimits struct

+ ByPlanID map[string]ProLimitsSnapshot

+ func (c ConfiguredProLimits) ResolveProLimits(planID string, grants PlanEffectGrants) (ProLimitsSnapshot, error)

+ type PaidMonthAllocator interface

+ AllocatePaidMonths func(PlanPayment, string) (map[string]int64, error)

+ type PersonalPlanOwnerPort interface

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

+ type PlanApplyOutcome string

+ const PlanApplied

+ const PlanIdempotent

+ const PlanObsolete

+ type PlanEffectAuthority string

+ const PlanEffectCurrent

+ const PlanEffectObsolete

+ const PlanEffectUnproved

+ type PlanEffectGrants struct

+ AIPaysFor string

+ AIQuestions int64

+ Contributors int64

+ ProjectContributors int64

+ type PlanEffectOwnerPort interface

+ ClassifyEffect func(context.Context, dal.ReadTransaction, PlanOwnerFence) (PlanEffectAuthority, error)

+ ReadMoneyFence func(context.Context, dal.ReadTransaction, string, string, string) (PlanMoneyFence, error)

+ ReadOwner func(context.Context, dal.ReadTransaction, string, string, string) (PlanOwnerFence, error)

+ ReconcileMoney func(context.Context, dal.ReadwriteTransaction, AccountPlanEffect) error

+ VerifyCurrentEffect func(context.Context, dal.ReadTransaction, AccountPlanEffect) error

+ type PlanMoneyFence struct

+ IngestEpoch int64

+ ReconciledEpoch int64

+ Unresolved bool

+ type PlanOwnerFence struct

+ AccountID string

+ Family string

+ Mode string

+ OwnerGeneration int64

+ OwnerSubscriptionID string

+ SubscriptionRevision int64

+ type PlanPayment struct

+ AccountID string

+ CashConfirmed bool

+ Currency string

+ DisputeResolved bool

+ InvoiceID string

+ Lines []PlanPaymentLine

+ Mode string

+ PaymentID string

+ Provider string

+ ReceivedCents int64

+ Refunds []PlanRefund

+ RefundsKnown bool

+ SubscriptionID string

+ type PlanPaymentLine struct

+ CashCents int64

+ EndUTC time.Time

+ ID string

+ ProductFamily string

+ RetainedTaxCents int64

+ RetainedTaxKnown bool

+ StartUTC time.Time

+ type PlanRefund struct

+ AttributionKnown bool

+ GrossCents int64

+ ID string

+ LineGrossCents map[string]int64

+ type ProLimitsResolver interface

+ ResolveProLimits func(string, PlanEffectGrants) (ProLimitsSnapshot, error)

+ type ProLimitsSnapshot struct

+ Limits models4datatug.PlanLimits

+ ProjectGuestsKnown bool

+ Version string

+ type PurchaseReadiness struct

+ Clock PlanClock

+ Config PlanConfigReader

+ DB dal.DB

+ Owner PlanEffectOwnerPort

+ Personal PersonalPlanOwnerPort

+ func (r PurchaseReadiness) ReadyForPurchase(ctx context.Context, req PurchaseReadinessRequest) (bool, error)

+ type PurchaseReadinessRequest struct

+ AccountID string

+ BuyerID string

+ Family string

+ Mode string

+ PlanID string

+ QuoteKey string

+ SessionID string

+ SiteID string

+ SubscriptionID string

+ type ServiceRefundProof struct

+ HasPaidServiceInvoice bool

+ InvoiceID string

+ Known bool

+ RefundedInFull bool

+ ServiceEndUTC time.Time

+ ServiceStartUTC time.Time

Oct 5, 2026

Changes in this version

+ var ErrForeignAccount = errors.New("account is not the caller's personal account")

+ var ErrPersonalAccountUnavailable = errors.New("personal account unavailable")

+ var ErrPlanUnavailable = errors.New("plan response unavailable")

+ type AdmissionReader interface

+ ReadAdmission func(context.Context, string, time.Time) (AdmissionState, error)

+ type AdmissionState struct

+ Blocked string

+ TodayUsed int64

+ type FirstAdmittedMonthReader interface

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

+ type PersonalAccount struct

+ ID string

+ Title string

+ func ResolvePersonalPayer(ctx context.Context, callerID, accountHint string, ...) (PersonalAccount, error)

+ type PersonalAccountDirectory interface

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

+ type PersonalPlanService struct

+ Admission AdmissionReader

+ Clock PlanClock

+ Config PlanConfigReader

+ Directory PersonalAccountDirectory

+ FirstMonth FirstAdmittedMonthReader

+ Plans PlanReader

+ Usage UsageReader

+ func (s PersonalPlanService) Read(ctx context.Context, callerID, accountHint, _ string) (PlanResponse, error)

+ type PlanAI struct

+ Blocked *string

+ Enforced bool

+ Left int64

+ Limit int64

+ Models []PlanModel

+ PeriodID string

+ ResetsAt time.Time

+ Today PlanToday

+ Unit string

+ Used int64

+ type PlanAccount struct

+ AccountID string

+ Kind string

+ Pays bool

+ Plan string

+ Role string

+ Title string

+ type PlanClock interface

+ Now func() time.Time

+ type PlanConfig struct

+ ActiveGrace time.Duration

+ DailyLimit int64

+ Enforced bool

+ FreeFirstMonthLimits models4datatug.PlanLimits

+ FreeLaterMonthLimits models4datatug.PlanLimits

+ FreeModels []PlanModel

+ ManageURL string

+ PastDueGrace time.Duration

+ ProLimits models4datatug.PlanLimits

+ ProModels []PlanModel

+ SupportEmail string

+ UpgradeURL string

+ type PlanConfigReader interface

+ ReadPlanConfig func(context.Context, string, time.Time) (PlanConfig, error)

+ type PlanFacts struct

+ AccountKind string

+ EndsAt *time.Time

+ FirstPaidAt *time.Time

+ Founding bool

+ Grants *models4datatug.PlanLimits

+ LastInvoiceRefundedInFull bool

+ PaidUntil *time.Time

+ Period string

+ ProviderStatus string

+ RefundedAt *time.Time

+ Tier string

+ type PlanModel struct

+ Class string

+ Default bool

+ ID string

+ Weight int64

+ type PlanReader interface

+ ReadCurrentPlan func(context.Context, string) (*models4datatug.PlanRecord, error)

+ type PlanResponse struct

+ AI PlanAI

+ AccountID string

+ AccountTitle string

+ Accounts []PlanAccount

+ CanUpgrade bool

+ EffectivePlan string

+ Founding bool

+ Limits models4datatug.PlanLimits

+ ManageURL string

+ OwnKeyWorks bool

+ PaidUntil *time.Time

+ Payer string

+ Period string

+ Plan string

+ Role string

+ Status string

+ SupportEmail string

+ UpgradeURL string

+ V int

+ type PlanStateResult struct

+ Outcome string

+ Reason string

+ Record *models4datatug.PlanRecord

+ func PlanStateFor(f PlanFacts) PlanStateResult

+ type PlanToday struct

+ Limit int64

+ Used int64

+ type UsageReader interface

+ ReadUsage func(context.Context, string, string) (*models4datatug.AIUsageRecord, error)

Sep 15, 2026

Changes in this version

+ var ErrOrgRequired = errors.New("github org is required")

+ var ErrRepoRequired = errors.New("github repo is required")

type Facade

+ func (f Facade) RegisterGithubProject(ctx context.Context, userID string, request RegisterGithubProjectRequest) (projectID string, err error)

+ type RegisterGithubProjectRequest struct

+ Folder string

+ Org string

+ Repo string

+ Title string

+ func (v RegisterGithubProjectRequest) Validate() error

Sep 15, 2026

Changes in this version

+ var ErrTitleRequired = errors.New("project title is required")

+ var ErrUnsupportedStore = errors.New("store is not served by the DataTug cloud API")

+ var ErrUserIDRequired = errors.New("user id is required")

+ type Facade struct

+ func NewFacade(db dal.DB, ids IDGenerator) Facade

+ func (f Facade) CreateProject(ctx context.Context, userID, storeID, title string) (projectID string, err error)

+ type IDGenerator interface

+ NewID func(ctx context.Context) (string, error)