Documentation
¶
Index ¶
- func MigrationFS() fs.FS
- type AcceptOutputTruncationParams
- type AcknowledgeOutputRunParams
- type AdvanceOutputRunParams
- type CommaSeparatedList
- type CreateBoundedDebugletParams
- type CreateDebugletParams
- type CreateOutputFrameParams
- type CreateOutputRunParams
- type CreateTeslaChainParams
- type DBTX
- type Debuglet
- type DebugletExit
- type DebugletLog
- type DeleteAcknowledgedOutputParams
- type FinishOutputRunParams
- type GetDebugletIdentityRow
- type GetOwnedDebugletByUUIDParams
- type ListDebugletExitsForBindingParams
- type ListDebugletsParams
- type ListOutputFramesParams
- type ListPendingOutputRunsParams
- type NoteDebugletExitFailureParams
- type OperatorDisposition
- type OutputFrame
- type OutputRun
- type OutputUsage
- type Queries
- func (q *Queries) AbandonOutputRun(ctx context.Context, runID string) error
- func (q *Queries) AcceptOutputTruncation(ctx context.Context, arg AcceptOutputTruncationParams) error
- func (q *Queries) AcknowledgeOutputRun(ctx context.Context, arg AcknowledgeOutputRunParams) error
- func (q *Queries) AddOutputUsage(ctx context.Context, chargedBytes int64) error
- func (q *Queries) AdvanceOutputRun(ctx context.Context, arg AdvanceOutputRunParams) error
- func (q *Queries) CountDebugletExits(ctx context.Context) (int64, error)
- func (q *Queries) CountOutputRuns(ctx context.Context) (int64, error)
- func (q *Queries) CreateBoundedDebuglet(ctx context.Context, arg CreateBoundedDebugletParams) (int64, error)
- func (q *Queries) CreateDebuglet(ctx context.Context, arg CreateDebugletParams) error
- func (q *Queries) CreateOutputFrame(ctx context.Context, arg CreateOutputFrameParams) error
- func (q *Queries) CreateOutputRun(ctx context.Context, arg CreateOutputRunParams) error
- func (q *Queries) CreateTeslaChain(ctx context.Context, arg CreateTeslaChainParams) error
- func (q *Queries) DeleteAcknowledgedOutput(ctx context.Context, arg DeleteAcknowledgedOutputParams) error
- func (q *Queries) DeleteDebuglet(ctx context.Context, argUuid uuid.UUID) error
- func (q *Queries) FinishOutputRun(ctx context.Context, arg FinishOutputRunParams) error
- func (q *Queries) GetDebugletByUUID(ctx context.Context, argUuid uuid.UUID) (Debuglet, error)
- func (q *Queries) GetDebugletExit(ctx context.Context, debugletID string) (DebugletExit, error)
- func (q *Queries) GetDebugletIdentity(ctx context.Context, argUuid uuid.UUID) (GetDebugletIdentityRow, error)
- func (q *Queries) GetDebugletStarted(ctx context.Context, argUuid uuid.UUID) (UTCTime, error)
- func (q *Queries) GetOutputRun(ctx context.Context, runID string) (OutputRun, error)
- func (q *Queries) GetOutputUsage(ctx context.Context) (int64, error)
- func (q *Queries) GetOwnedDebugletByUUID(ctx context.Context, arg GetOwnedDebugletByUUIDParams) (Debuglet, error)
- func (q *Queries) GetTeslaChain(ctx context.Context, generation int64) (TeslaChain, error)
- func (q *Queries) InterruptOpenOutputRuns(ctx context.Context) error
- func (q *Queries) ListDebugletExits(ctx context.Context, limit int64) ([]DebugletExit, error)
- func (q *Queries) ListDebugletExitsForBinding(ctx context.Context, arg ListDebugletExitsForBindingParams) ([]DebugletExit, error)
- func (q *Queries) ListDebuglets(ctx context.Context, arg ListDebugletsParams) ([]Debuglet, error)
- func (q *Queries) ListOutputFrames(ctx context.Context, arg ListOutputFramesParams) ([]OutputFrame, error)
- func (q *Queries) ListPendingOutputRuns(ctx context.Context, arg ListPendingOutputRunsParams) ([]OutputRun, error)
- func (q *Queries) ListTeslaChains(ctx context.Context) ([]TeslaChain, error)
- func (q *Queries) NextTeslaChainGeneration(ctx context.Context) (int64, error)
- func (q *Queries) NoteDebugletExitFailure(ctx context.Context, arg NoteDebugletExitFailureParams) (int64, error)
- func (q *Queries) RecordDebugletExit(ctx context.Context, arg RecordDebugletExitParams) error
- func (q *Queries) ReleaseDebugletExit(ctx context.Context, arg ReleaseDebugletExitParams) (int64, error)
- func (q *Queries) SumAcknowledgedOutput(ctx context.Context, arg SumAcknowledgedOutputParams) (SumAcknowledgedOutputRow, error)
- func (q *Queries) UpdateDebugletStarted(ctx context.Context, arg UpdateDebugletStartedParams) (Debuglet, error)
- func (q *Queries) WithTx(tx *sql.Tx) *Queries
- type RecordDebugletExitParams
- type ReleaseDebugletExitParams
- type SumAcknowledgedOutputParams
- type SumAcknowledgedOutputRow
- type TeslaChain
- type UTCTime
- type UpdateDebugletStartedParams
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func MigrationFS ¶
MigrationFS exposes the canonical SQL migrations without global registration.
Types ¶
type AcceptOutputTruncationParams ¶ added in v0.3.0
type AcknowledgeOutputRunParams ¶ added in v0.3.0
type AdvanceOutputRunParams ¶ added in v0.3.0
type CommaSeparatedList ¶
type CommaSeparatedList []string
CommaSeparatedList allows lists of strings to be stored in a single database column as a comma-separated string, with each string base64-encoded to handle special characters and commas within the strings themselves.
func (*CommaSeparatedList) Scan ¶
func (b *CommaSeparatedList) Scan(src any) error
type CreateBoundedDebugletParams ¶ added in v0.3.0
type CreateBoundedDebugletParams struct {
Uuid uuid.UUID
StartTime UTCTime
Args CommaSeparatedList
Wasm []byte
TransactionID string
FloorBw int64
CeilBw int64
TimeoutMs int64
Addresses CommaSeparatedList
RequireIcmp bool
ListenUdp bool
ListenTcp bool
ListenScion bool
DispatcherIncarnation string
SessionID string
EgressGrant []byte
MaxQueuedRuns int64
MaxQueuedBytes int64
QueueBytes int64
}
type CreateDebugletParams ¶
type CreateDebugletParams struct {
Uuid uuid.UUID
StartTime UTCTime
Args CommaSeparatedList
Wasm []byte
TransactionID string
FloorBw int64
CeilBw int64
TimeoutMs int64
Addresses CommaSeparatedList
RequireIcmp bool
ListenUdp bool
ListenTcp bool
ListenScion bool
DispatcherIncarnation string
SessionID string
}
type CreateOutputFrameParams ¶ added in v0.3.0
type CreateOutputRunParams ¶ added in v0.3.0
type CreateTeslaChainParams ¶
type Debuglet ¶
type Debuglet struct {
ID int64
Uuid uuid.UUID
StartTime UTCTime
Args CommaSeparatedList
Wasm []byte
TransactionID string
FloorBw int64
CeilBw int64
TimeoutMs int64
Addresses CommaSeparatedList
RequireIcmp bool
ListenUdp bool
ListenTcp bool
ListenScion bool
StartedAt UTCTime
DispatcherIncarnation string
SessionID string
EgressGrant []byte
}
type DebugletExit ¶
type DebugletLog ¶
type DeleteAcknowledgedOutputParams ¶ added in v0.3.0
type FinishOutputRunParams ¶ added in v0.3.0
type GetDebugletIdentityRow ¶
type ListDebugletsParams ¶
type ListOutputFramesParams ¶ added in v0.3.0
type ListPendingOutputRunsParams ¶ added in v0.3.0
type OperatorDisposition ¶ added in v0.3.0
type OutputFrame ¶ added in v0.3.0
type OutputRun ¶ added in v0.3.0
type OutputRun struct {
RunID string
DispatcherIncarnation string
SessionID string
OutputVersion int64
LastSequence int64
AcknowledgedSequence int64
EmittedBytes int64
QueuedBytes int64
QueuedFrames int64
Status string
Reason string
EndAcknowledged bool
ReceiptSequence sql.NullInt64
ReceiptReason string
}
type OutputUsage ¶ added in v0.3.0
type Queries ¶
type Queries struct {
// contains filtered or unexported fields
}
func (*Queries) AbandonOutputRun ¶ added in v0.3.0
func (*Queries) AcceptOutputTruncation ¶ added in v0.3.0
func (q *Queries) AcceptOutputTruncation(ctx context.Context, arg AcceptOutputTruncationParams) error
func (*Queries) AcknowledgeOutputRun ¶ added in v0.3.0
func (q *Queries) AcknowledgeOutputRun(ctx context.Context, arg AcknowledgeOutputRunParams) error
func (*Queries) AddOutputUsage ¶ added in v0.3.0
func (*Queries) AdvanceOutputRun ¶ added in v0.3.0
func (q *Queries) AdvanceOutputRun(ctx context.Context, arg AdvanceOutputRunParams) error
func (*Queries) CountDebugletExits ¶
func (*Queries) CountOutputRuns ¶ added in v0.3.0
A run whose end the dispatcher acknowledged holds no further spool capacity.
func (*Queries) CreateBoundedDebuglet ¶ added in v0.3.0
func (q *Queries) CreateBoundedDebuglet(ctx context.Context, arg CreateBoundedDebugletParams) (int64, error)
The durable rows are the reservations. Keeping the quota predicate inside this INSERT makes concurrent admission and crash recovery use the same accounting, without a separate counter that can drift from retained work. Existing UUIDs still reach the UNIQUE constraint even when the queue is full.
func (*Queries) CreateDebuglet ¶
func (q *Queries) CreateDebuglet(ctx context.Context, arg CreateDebugletParams) error
func (*Queries) CreateOutputFrame ¶ added in v0.3.0
func (q *Queries) CreateOutputFrame(ctx context.Context, arg CreateOutputFrameParams) error
func (*Queries) CreateOutputRun ¶ added in v0.3.0
func (q *Queries) CreateOutputRun(ctx context.Context, arg CreateOutputRunParams) error
func (*Queries) CreateTeslaChain ¶
func (q *Queries) CreateTeslaChain(ctx context.Context, arg CreateTeslaChainParams) error
func (*Queries) DeleteAcknowledgedOutput ¶ added in v0.3.0
func (q *Queries) DeleteAcknowledgedOutput(ctx context.Context, arg DeleteAcknowledgedOutputParams) error
func (*Queries) DeleteDebuglet ¶
func (*Queries) FinishOutputRun ¶ added in v0.3.0
func (q *Queries) FinishOutputRun(ctx context.Context, arg FinishOutputRunParams) error
func (*Queries) GetDebugletByUUID ¶
func (*Queries) GetDebugletExit ¶
func (*Queries) GetDebugletIdentity ¶
func (q *Queries) GetDebugletIdentity(ctx context.Context, argUuid uuid.UUID) (GetDebugletIdentityRow, error)
Identity, original binding and start marker only: inspection never reads the stored WASM blob or arguments.
func (*Queries) GetDebugletStarted ¶
func (*Queries) GetOutputRun ¶ added in v0.3.0
func (*Queries) GetOutputUsage ¶ added in v0.3.0
func (*Queries) GetOwnedDebugletByUUID ¶
func (*Queries) GetTeslaChain ¶ added in v0.3.0
func (*Queries) InterruptOpenOutputRuns ¶ added in v0.3.0
func (*Queries) ListDebugletExits ¶
func (*Queries) ListDebugletExitsForBinding ¶
func (q *Queries) ListDebugletExitsForBinding(ctx context.Context, arg ListDebugletExitsForBindingParams) ([]DebugletExit, error)
Only a session's own deliverable results, so results no session can deliver cannot crowd out the ones that can be.
func (*Queries) ListDebuglets ¶
func (*Queries) ListOutputFrames ¶ added in v0.3.0
func (q *Queries) ListOutputFrames(ctx context.Context, arg ListOutputFramesParams) ([]OutputFrame, error)
func (*Queries) ListPendingOutputRuns ¶ added in v0.3.0
func (*Queries) ListTeslaChains ¶
func (q *Queries) ListTeslaChains(ctx context.Context) ([]TeslaChain, error)
func (*Queries) NextTeslaChainGeneration ¶
func (*Queries) NoteDebugletExitFailure ¶
func (*Queries) RecordDebugletExit ¶
func (q *Queries) RecordDebugletExit(ctx context.Context, arg RecordDebugletExitParams) error
The first write wins: a duplicate report never rewrites the chosen result.
func (*Queries) ReleaseDebugletExit ¶
func (*Queries) SumAcknowledgedOutput ¶ added in v0.3.0
func (q *Queries) SumAcknowledgedOutput(ctx context.Context, arg SumAcknowledgedOutputParams) (SumAcknowledgedOutputRow, error)
func (*Queries) UpdateDebugletStarted ¶
type SumAcknowledgedOutputParams ¶ added in v0.3.0
type SumAcknowledgedOutputRow ¶ added in v0.3.0
type TeslaChain ¶
type UTCTime ¶
UTCTime is a wrapper around time.Time that ensures the time is always stored and retrieved in UTC.