runtime

type BackgroundTracing interface {
	StartBackground(context.Context, string, map[string]TraceAttribute) (context.Context, StageSpan)
}

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

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

type CapabilityOptions struct {
	SourceTypes            []string
	ArtifactFamilies       []string
	MemoryExtraction       bool
	ExperienceGeneration   bool
	ManagedSkillGeneration bool
	ExternalSkillRegistry  bool
	HandoffGeneration      bool
	SearchModes            []memory.SearchMode
	ContextVersions        []string
}

type CheckStatus string

type Clock func() time.Time

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

type CreateHandoffReportProject struct {
	ProjectKey, Title string
	Description       *string
	DefaultLocale     handoffreport.Locale
	Timezone          string
}

type DependencyOperation func(context.Context) error

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

type ExperienceIncubationBackend interface {
	ObserveWindow(context.Context, string, int64) (
		previous source.Cursor,
		next source.Cursor,
		generation *int64,
		highWatermark int64,
		values []source.Value,
		available []source.Ref,
		err error,
	)
	ApplyWindow(
		context.Context,
		string,
		[]string,
		[]experience.CandidateInput,
		source.Cursor,
		*int64,
	) error
}

type ExperienceIncubationBackendFactory func(string) (ExperienceIncubationBackend, error)

type ExperienceIncubationResult struct {
	PreviousCursor       int64
	HighWatermark        int64
	CurrentCursor        int64
	ProcessedSourceCount int
	CandidateCount       int
}

type ExperienceRecall interface {
	Search(context.Context, string, string, int) ([]experience.SearchHit, error)
}

type ExperienceRecallFunc func(context.Context, string, string, int) ([]experience.SearchHit, error)

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

type ExternalSkillRegistryFactory func(string) (*skill.RegistryService, error)

type ExternalSkillSnapshotStore interface {
	Store(context.Context, string, skill.SnapshotCapture) (source.Ref, error)
}

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

type GenerationServiceFactory func(string) (*review.GenerationService, error)

type GetHandoffReport struct {
	ScopeID               string
	Locale                *handoffreport.Locale
	IncludeEvidenceChecks bool
	Format                handoffreport.Format
	IncludeArchived       bool
	Period                *HandoffReportPeriod
}

type HandoffActivationBackend interface {
	LoadBoundary(context.Context, string, source.Ref, string) (int64, source.Cursor, *int64, error)
	SaveBoundary(context.Context, string, string, source.Cursor, *int64) error
}

type HandoffActivationResult = handoff.Activation

type HandoffActivationStatus = handoff.ActivationStatus

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

type HandoffReportActivityList struct {
	ProjectID              string
	PeriodStart, PeriodEnd *time.Time
	Sources                []handoffreport.ActivitySource
	AfterCursor            int64
	ThroughCursor          *int64
	Limit                  int
}

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

type HandoffReportBackend interface {
	CreateProject(context.Context, handoffreport.ProjectDescriptor, time.Time) (handoffreport.ProjectDescriptor, error)
	GetProject(context.Context, string) (handoffreport.ProjectDescriptor, error)
	UpdateProject(context.Context, handoffreport.ProjectDescriptor, int, time.Time) (handoffreport.ProjectDescriptor, error)
	ListProjects(context.Context, *string, int, bool) (handoffreport.Page[handoffreport.ProjectDescriptor], error)
	RegisterWorkstream(context.Context, handoffreport.WorkstreamDescriptor, time.Time) (handoffreport.WorkstreamDescriptor, error)
	UpdateWorkstream(context.Context, handoffreport.WorkstreamDescriptor, int, time.Time) (handoffreport.WorkstreamDescriptor, error)
	ListWorkstreams(context.Context, string, *string, int, bool) (handoffreport.Page[handoffreport.WorkstreamDescriptor], error)
	RecordActivity(context.Context, handoffreport.ActivityEvent) (handoffreport.StoredActivity, error)
	ListActivities(context.Context, string, *time.Time, *time.Time, []handoffreport.ActivitySource, int64, *int64, int) (handoffreport.ActivityPage, error)
	PurgeActivities(context.Context, string, time.Time) (int64, error)
	GetWorkspaceBinding(context.Context, string) (handoffreport.WorkspaceBinding, error)
	AttachWorkspaceBinding(context.Context, string, string, handoffreport.RepositoryRef, *int, time.Time) (handoffreport.WorkspaceBinding, error)
	DetachWorkspaceBinding(context.Context, string, int) (handoffreport.WorkspaceBinding, error)
	ReadHandoffReportInputs(context.Context, string, bool, *time.Time, *time.Time, *time.Time, *time.Time) (handoffreport.ProjectDescriptor, []handoffreport.WorkstreamDescriptor, []handoffreport.ActivityEvent, int64, int, error)
}

type HandoffReportIDFactory func(prefix string) (string, error)

type HandoffReportPeriod struct {
	Start, End              time.Time
	Timezone                *string
	CompareToPreviousPeriod bool
}

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

type HandoffScopeIDs func(context.Context) ([]string, error)

type HandoffServiceFactory func(string) (*handoff.Service, error)

type InvalidScopeError struct{ Detail string }

type KnownHandoffScopePage struct {
	Items      []string
	NextCursor *string
}

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

type MemoryChangesPage struct {
	MemoryRef *artifact.Ref
	Revisions []memory.RevisionChanges
}

type MemoryEntriesPage struct {
	MemoryRef *artifact.Ref
	Entries   []MemoryEntryRecord
}

type MemoryEntryRecord struct {
	MemoryRef artifact.Ref
	State     memory.EntryState
	Entry     memory.EntryVersion
}

type MemoryFlushBackend interface {
	ObserveWindow(context.Context, string, int64) (
		previous source.Cursor,
		next source.Cursor,
		generation *int64,
		highWatermark int64,
		values []source.Value,
		err error,
	)
	ApplyWindow(context.Context, string, memory.WritePlan, source.Cursor, *int64) (*memory.Memory, error)
}

type MemoryFlushBackendFactory func(string) (MemoryFlushBackend, error)

type MemoryFlushResult struct {
	PreviousCursor       int64
	CurrentCursor        int64
	HighWatermark        int64
	ProcessedSourceCount int
	MemoryRef            *artifact.Ref
}

type MemoryMutationResult struct {
	PreviousRevision *int64
	MemoryRef        artifact.Ref
	Entry            *MemoryEntryRecord
}

type MemorySearchPage struct {
	MemoryRef *artifact.Ref
	Mode      *memory.SearchMode
	Hits      []memory.Hit
	Rerank    *memory.RerankTrace
}

type MemoryServiceFactory func(string) (*memory.Service, error)

type ModelUsageRecorder interface {
	RecordModelUsage(
		context.Context,
		string,
		stats.ModelPurpose,
		stats.ModelOperation,
		inference.Usage,
	)
}

type ModelUsageRecorderFunc func(
	context.Context,
	string,
	stats.ModelPurpose,
	stats.ModelOperation,
	inference.Usage,
)

type Probe func(context.Context) (CheckStatus, error)

type ProbeDefinition struct {
	Name     string
	Probe    Probe
	Blocking bool
}

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

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

type ReadinessStatus string

type RecallStatistics interface {
	ObservePreparedContext(context.Context, string, contextpack.Build)
}

type RecallStatisticsFunc func(context.Context, string, contextpack.Build)

type RecordHandoffReportActivity struct {
	ProjectID      string
	ScopeID        *string
	Source         handoffreport.ActivitySource
	SourceEventID  string
	SourceRef      *handoffreport.ExternalReference
	OccurredAt     *time.Time
	TimeBasis      handoffreport.TimeBasis
	Title, Summary *string
	Agent          *handoffreport.ActivityAgent
	SessionID      *string
	VCSContext     *handoffreport.ActivityVCSContext
	EvidenceRefs   []handoffreport.ExternalReference
}

type RegisterHandoffReportWorkstream struct {
	ProjectID, ScopeID string
	Key                *string
	Title              string
	Kind               handoffreport.WorkstreamKind
	CatalogState       handoffreport.CatalogState
	ExternalRefs       []handoffreport.ExternalReference
	Labels             []string
}

type RememberMemoryRequest struct {
	Kind             string
	Text             string
	Reason           *string
	ExpectedRevision *int64
}

type Resource interface {
	Close(context.Context) error
}

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

type ReviewServiceFactory func(string) (*review.Service, error)

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

type RuntimeOptions struct {
	ScopeCacheSize int
	ScopeEvictor   ScopeEvictor
	ScopeObserver  ScopeCacheObserver
	Tracing        StageTracing
}

type ScheduledObservation struct {
	Operation      string
	Outcome        string
	Duration       time.Duration
	SourceCount    int
	CandidateCount *int
	Err            error
}

type ScheduledObserver func(context.Context, ScheduledObservation)

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

type ScheduledScopeLister interface {
	ScopeIDs(context.Context) ([]string, error)
}

type SchedulerLifecycle interface {
	Pause()
	Close(context.Context) error
}

type ScopeCacheObserver func(cached, active int)

type ScopeEvictor func(scopeID string)

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

type SourceCaptureBackend interface {
	Capture(context.Context, string, source.ContentCapture) (source.Ref, int64, error)
}

type SourceReceipt struct {
	Ref      source.Ref
	Sequence int64
}

type StageSpan interface {
	SetAttributes(map[string]TraceAttribute)
	Finish(outcome string, err error)
}

type StageTracing interface {
	StartStage(context.Context, string, map[string]TraceAttribute) (context.Context, StageSpan)
}

type StageTracingFunc func(context.Context, string, map[string]TraceAttribute) (context.Context, StageSpan)

type StateError struct{ Code string }

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

type StatisticsReader interface {
	Overview(context.Context, stats.Period, time.Time) (stats.Statistics, error)
}

type StatisticsReaderFactory func(string) (StatisticsReader, error)

type TraceAttribute = any

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

type WorkSourceBackend interface {
	Capture(context.Context, string, source.ContentCapture) (source.Ref, int64, error)
	Entries(context.Context, string) ([]source.JournalEntry, error)
}