workspacelogs

type AckKey struct {
	RunID      string
	ProducerID string
	Hop        Hop
}

type AckState struct {
	SchemaVersion int    `json:"schemaVersion"`
	RunID         string `json:"runId"`
	ProducerID    string `json:"producerId"`
	Hop           Hop    `json:"hop"`
	// Acked is the highest sequence the peer persisted or represented as a gap.
	Acked uint64 `json:"acked"`
	// Gapped is set once the peer reported sequences it will never hold.
	Gapped   bool   `json:"gapped,omitempty"`
	GapFirst uint64 `json:"gapFirst,omitempty"`
	GapLast  uint64 `json:"gapLast,omitempty"`
}

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

type AppendResult struct {
	// Accepted is the highest contiguous sequence persisted for the producer.
	// Acknowledge this value, never a higher one.
	Accepted   uint64
	Written    int
	Duplicates int
	Elided     int
}

type Backend interface {
	RegisterProducer(runID string, ref ProducerRef) error
	Append(records []Record) (AppendResult, error)
	AddCondition(runID string, c Condition) error
}

type BatchRequest struct {
	SchemaVersion int
	RunID         string
	ProducerID    string
	FirstSequence uint64
	LastSequence  uint64
	// Records holds JSON encoded Record values.
	Records [][]byte
}

type BatchResult struct {
	Result MirrorResult
	// Accepted is the highest contiguous sequence persisted for the producer.
	Accepted uint64
	GapFirst uint64
	GapLast  uint64
	Detail   string
}

type BoundedBuffer struct {
	Max int
	// contains filtered or unexported fields
}

type CaptureState string

type CommandState string

type Condition string

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

type Hop string

type ImportRequest struct {
	// RunID, Context and WorkspaceUID are the identity the caller expects. The
	// response must match all of them.
	RunID        string
	Context      string
	WorkspaceUID string
	Response     *ReadResponse
}

type ImportResult struct {
	Written    int
	Duplicates int
	// Stalled lists producers whose records could not be merged past a gap or
	// a malformed remote record. Their remaining records are not imported.
	Stalled []string
}

type IndexRequest struct {
	Context string
	// WorkspaceUID narrows the index to one workspace generation.
	WorkspaceUID string
	After        string
	// Limit is the most runs in the page. Zero means DefaultIndexLimit.
	Limit int
}

type IndexResponse struct {
	SchemaVersion int          `json:"schemaVersion"`
	Runs          []RunSummary `json:"runs"`
	NextCursor    string       `json:"nextCursor,omitempty"`
	HasMore       bool         `json:"hasMore"`
}

type Invocation struct {
	ID       string
	Phase    string
	Hook     string
	Index    *int
	Key      string
	State    InvocationState
	Reason   string
	ExitCode *int
	Signal   string
	Duration time.Duration
}

type InvocationState string

type Kind string

type Location string

type MirrorResult string

type Options struct {
	// Root is the absolute storage directory.
	Root string
	// Now overrides the clock in tests.
	Now func() time.Time
}

type ProducerRef struct {
	ProducerID       string        `json:"producerId"`
	ParentProducerID string        `json:"parentProducerId,omitempty"`
	State            ProducerState `json:"state"`
	Location         Location      `json:"location,omitempty"`
	Sealed           bool          `json:"discoverySealed,omitempty"`
}

type ProducerState string

type ReadRequest struct {
	RunID        string
	Hook         string
	InvocationID string
	// After is the NextCursor of the previous page.
	After string
	// Limit is the most records in the page. Zero means DefaultReadLimit.
	Limit int
	// MaxBytes caps the encoded page. Zero or less means MaxPageBytes.
	MaxBytes int
}

type ReadResponse struct {
	SchemaVersion int                  `json:"schemaVersion"`
	Run           RunSummary           `json:"run"`
	Records       []Record             `json:"records"`
	NextCursor    string               `json:"nextCursor,omitempty"`
	HasMore       bool                 `json:"hasMore"`
	Availability  []SourceAvailability `json:"availability,omitempty"`
	Complete      bool                 `json:"complete"`
}

type Record struct {
	SchemaVersion int       `json:"schemaVersion"`
	Kind          Kind      `json:"kind"`
	RunID         string    `json:"runId"`
	ProducerID    string    `json:"producerId"`
	Sequence      uint64    `json:"sequence"`
	Time          time.Time `json:"time"`

	// Producer and invocation transitions.
	ParentProducerID string `json:"parentProducerId,omitempty"`
	// ChildProducerID, on a producer record, reserves (or finalizes) a child
	// producer the writer is about to launch. Mirrored stores learn about the
	// child from this record, before any of its own records arrive.
	ChildProducerID string          `json:"childProducerId,omitempty"`
	ProducerState   ProducerState   `json:"producerState,omitempty"`
	DiscoverySealed bool            `json:"discoverySealed,omitempty"`
	InvocationID    string          `json:"invocationId,omitempty"`
	Phase           string          `json:"phase,omitempty"`
	Hook            string          `json:"hook,omitempty"`
	HookIndex       *int            `json:"hookIndex,omitempty"`
	HookKey         string          `json:"hookKey,omitempty"`
	Location        Location        `json:"location,omitempty"`
	State           InvocationState `json:"state,omitempty"`
	Reason          string          `json:"reason,omitempty"`
	DurationMillis  *int64          `json:"durationMillis,omitempty"`
	ExitCode        *int            `json:"exitCode,omitempty"`
	Signal          string          `json:"signal,omitempty"`

	// Output.
	Stream Stream `json:"stream,omitempty"`
	Text   string `json:"text,omitempty"`
	Bytes  int    `json:"bytes,omitempty"`
	// Elided marks output whose text was dropped for capacity. Sequence and
	// Bytes are kept so producers and readers stay contiguous.
	Elided bool `json:"elided,omitempty"`

	// Capture conditions.
	Condition    Condition `json:"condition,omitempty"`
	Detail       string    `json:"detail,omitempty"`
	DroppedBytes int64     `json:"droppedBytes,omitempty"`
}

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

type RecorderOptions struct {
	Backend  Backend
	RunID    string
	Location Location
	// ProducerID uses a producer ID its parent reserved earlier. Empty
	// generates one.
	ProducerID string
	// Resumed marks a worker that continues a run whose launching process
	// already recorded the plan. Plan-time transitions are not repeated.
	Resumed bool
	// ParentProducerID links this producer to the one that launched it.
	ParentProducerID string
	// Redactor masks known secrets before anything is persisted. Nil keeps text
	// as written.
	Redactor *secrets.Redactor
	// Now overrides the clock in tests.
	Now func() time.Time
}

type RunManifest struct {
	SchemaVersion      int           `json:"schemaVersion"`
	RunID              string        `json:"runId"`
	Context            string        `json:"context"`
	WorkspaceUID       *string       `json:"workspaceUid"`
	WorkspaceIDAtStart string        `json:"workspaceIdAtStart,omitempty"`
	Command            string        `json:"command"`
	TaskID             string        `json:"taskId,omitempty"`
	CreatedAt          time.Time     `json:"createdAt"`
	UpdatedAt          time.Time     `json:"updatedAt"`
	CommandState       CommandState  `json:"commandState"`
	CaptureState       CaptureState  `json:"captureState"`
	Conditions         []Condition   `json:"conditions,omitempty"`
	Producers          []ProducerRef `json:"producers,omitempty"`
	DiscoverySealed    bool          `json:"discoverySealed,omitempty"`
}

type RunSpec struct {
	// RunID joins an existing run created by another process. Empty allocates
	// a new run.
	RunID              string
	Context            string
	WorkspaceUID       string
	WorkspaceIDAtStart string
	Command            string
	TaskID             string
}

type RunSummary struct {
	RunID              string       `json:"runId"`
	Context            string       `json:"context"`
	WorkspaceUID       *string      `json:"workspaceUid"`
	WorkspaceIDAtStart string       `json:"workspaceIdAtStart,omitempty"`
	Command            string       `json:"command"`
	TaskID             string       `json:"taskId,omitempty"`
	CreatedAt          time.Time    `json:"createdAt"`
	CommandState       CommandState `json:"commandState"`
	CaptureState       CaptureState `json:"captureState"`
	Conditions         []Condition  `json:"conditions,omitempty"`
}

type Session struct {
	Store    *Store
	Recorder *Recorder
	RunID    string
	// contains filtered or unexported fields
}

type SessionOptions struct {
	// RunID joins a run allocated earlier (a detached submission or a parent
	// process). Empty allocates a new run.
	RunID string
	// ParentProducerID links this process's producer to the one that
	// launched it.
	ParentProducerID string
	// ProducerID uses a producer ID reserved by the parent process.
	ProducerID string
	// Resumed marks a worker continuing a run whose plan the parent recorded.
	Resumed  bool
	Run      RunSpec
	Location Location
	Redactor *secrets.Redactor
}

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

type SinkOptions struct {
	Store *Store
	// Spec identifies the run this host expects. RunID is required; the run is
	// created or joined at construction.
	Spec RunSpec
	// Acks persists the inbound position and retention gaps. Optional.
	Acks *AckStore
	// OnAccepted is called after records are persisted, so a forwarding host can
	// queue them for the next hop. It must not block.
	OnAccepted func(producerID string, accepted uint64)
}

type SourceAvailability struct {
	ProducerID string `json:"producerId"`
	Available  bool   `json:"available"`
	Reason     string `json:"reason,omitempty"`
}

type SpoolSelector struct {
	// Root is the validated spool root from ResolveSpool.
	Root string
	// Context and WorkspaceUID must match the stored run. An empty UID skips
	// the UID check only when the run is not bound to one.
	Context      string
	WorkspaceUID string
	Read         ReadRequest
}

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

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

type Stream string