database

package

Go to main page

Versions in this module

v0

v0.3.1

Oct 19, 2026

v0.3.0

Oct 19, 2026

Changes in this version

+ type AcceptOutputTruncationParams struct

+ Reason string

+ RunID string

+ Sequence sql.NullInt64

+ type AcknowledgeOutputRunParams struct

+ AcknowledgedSequence int64

+ Bytes int64

+ EndAcknowledged bool

+ Frames int64

+ RunID string

+ type AdvanceOutputRunParams struct

+ Bytes int64

+ RunID string

+ type CreateBoundedDebugletParams struct

+ Addresses CommaSeparatedList

+ Args CommaSeparatedList

+ CeilBw int64

+ DispatcherIncarnation string

+ EgressGrant []byte

+ FloorBw int64

+ ListenScion bool

+ ListenTcp bool

+ ListenUdp bool

+ MaxQueuedBytes int64

+ MaxQueuedRuns int64

+ QueueBytes int64

+ RequireIcmp bool

+ SessionID string

+ StartTime UTCTime

+ TimeoutMs int64

+ TransactionID string

+ Uuid uuid.UUID

+ Wasm []byte

+ type CreateOutputFrameParams struct

+ Output []byte

+ RunID string

+ Sequence int64

+ TimestampNs int64

+ type CreateOutputRunParams struct

+ DispatcherIncarnation string

+ OutputVersion int64

+ RunID string

+ SessionID string

type CreateTeslaChainParams

+ DisclosureDelay sql.NullInt64

type Debuglet

+ EgressGrant []byte

+ type DeleteAcknowledgedOutputParams struct

+ RunID string

+ Sequence int64

+ type FinishOutputRunParams struct

+ Reason string

+ RunID string

+ Status string

+ type ListOutputFramesParams struct

+ Limit int64

+ RunID string

+ Sequence int64

+ type ListPendingOutputRunsParams struct

+ Limit int64

+ RunID string

+ type OperatorDisposition struct

+ Reason string

+ RecordedAtNs int64

+ RunID string

+ type OutputFrame struct

+ Output []byte

+ RunID string

+ Sequence int64

+ TimestampNs int64

+ type OutputRun struct

+ AcknowledgedSequence int64

+ DispatcherIncarnation string

+ EmittedBytes int64

+ EndAcknowledged bool

+ LastSequence int64

+ OutputVersion int64

+ QueuedBytes int64

+ QueuedFrames int64

+ Reason string

+ ReceiptReason string

+ ReceiptSequence sql.NullInt64

+ RunID string

+ SessionID string

+ Status string

+ type OutputUsage struct

+ ChargedBytes int64

+ Singleton int64

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) CountOutputRuns(ctx context.Context) (int64, error)

+ func (q *Queries) CreateBoundedDebuglet(ctx context.Context, arg CreateBoundedDebugletParams) (int64, error)

+ func (q *Queries) CreateOutputFrame(ctx context.Context, arg CreateOutputFrameParams) error

+ func (q *Queries) CreateOutputRun(ctx context.Context, arg CreateOutputRunParams) error

+ func (q *Queries) DeleteAcknowledgedOutput(ctx context.Context, arg DeleteAcknowledgedOutputParams) error

+ func (q *Queries) FinishOutputRun(ctx context.Context, arg FinishOutputRunParams) error

+ func (q *Queries) GetOutputRun(ctx context.Context, runID string) (OutputRun, error)

+ func (q *Queries) GetOutputUsage(ctx context.Context) (int64, error)

+ func (q *Queries) GetTeslaChain(ctx context.Context, generation int64) (TeslaChain, error)

+ func (q *Queries) InterruptOpenOutputRuns(ctx context.Context) 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) SumAcknowledgedOutput(ctx context.Context, arg SumAcknowledgedOutputParams) (SumAcknowledgedOutputRow, error)

+ type SumAcknowledgedOutputParams struct

+ RunID string

+ Sequence int64

+ type SumAcknowledgedOutputRow struct

+ ByteCount int64

+ FrameCount int64

type TeslaChain

+ DisclosureDelay sql.NullInt64

v0.3.0-rc.1

Oct 6, 2026

v0.2.0

Sep 27, 2026

Changes in this version

+ func MigrationFS() fs.FS

+ type CommaSeparatedList []string

+ func (b *CommaSeparatedList) Scan(src any) error

+ func (b CommaSeparatedList) Value() (driver.Value, error)

+ type CreateDebugletParams struct

+ Addresses CommaSeparatedList

+ Args CommaSeparatedList

+ CeilBw int64

+ DispatcherIncarnation string

+ FloorBw int64

+ ListenScion bool

+ ListenTcp bool

+ ListenUdp bool

+ RequireIcmp bool

+ SessionID string

+ StartTime UTCTime

+ TimeoutMs int64

+ TransactionID string

+ Uuid uuid.UUID

+ Wasm []byte

+ type CreateTeslaChainParams struct

+ Anchor []byte

+ ChainLength int64

+ CreatedAt time.Time

+ DelayNs int64

+ EpochBase time.Time

+ Generation int64

+ type DBTX interface

+ ExecContext func(context.Context, string, ...interface{}) (sql.Result, error)

+ PrepareContext func(context.Context, string) (*sql.Stmt, error)

+ QueryContext func(context.Context, string, ...interface{}) (*sql.Rows, error)

+ QueryRowContext func(context.Context, string, ...interface{}) *sql.Row

+ type Debuglet struct

+ Addresses CommaSeparatedList

+ Args CommaSeparatedList

+ CeilBw int64

+ DispatcherIncarnation string

+ FloorBw int64

+ ID int64

+ ListenScion bool

+ ListenTcp bool

+ ListenUdp bool

+ RequireIcmp bool

+ SessionID string

+ StartTime UTCTime

+ StartedAt UTCTime

+ TimeoutMs int64

+ TransactionID string

+ Uuid uuid.UUID

+ Wasm []byte

+ type DebugletExit struct

+ Attempts int64

+ DebugletID string

+ DispatcherIncarnation string

+ ErrorMessage sql.NullString

+ ExitCode int64

+ LastAttemptAt UTCTime

+ LastError string

+ RecordedAt UTCTime

+ Rejected bool

+ SessionID string

+ type DebugletLog struct

+ DebugletID int64

+ ID int64

+ Output []byte

+ Timestamp time.Time

+ type GetDebugletIdentityRow struct

+ DispatcherIncarnation string

+ SessionID string

+ StartTime UTCTime

+ StartedAt UTCTime

+ TransactionID string

+ Uuid uuid.UUID

+ type GetOwnedDebugletByUUIDParams struct

+ DispatcherIncarnation string

+ SessionID string

+ Uuid uuid.UUID

+ type ListDebugletExitsForBindingParams struct

+ DispatcherIncarnation string

+ Limit int64

+ SessionID string

+ type ListDebugletsParams struct

+ Limit int64

+ Offset int64

+ type NoteDebugletExitFailureParams struct

+ Attempts int64

+ DebugletID string

+ DispatcherIncarnation string

+ LastAttemptAt UTCTime

+ LastError string

+ Rejected bool

+ SessionID string

+ type Queries struct

+ func New(db DBTX) *Queries

+ func (q *Queries) CountDebugletExits(ctx context.Context) (int64, error)

+ func (q *Queries) CreateDebuglet(ctx context.Context, arg CreateDebugletParams) error

+ func (q *Queries) CreateTeslaChain(ctx context.Context, arg CreateTeslaChainParams) error

+ func (q *Queries) DeleteDebuglet(ctx context.Context, argUuid uuid.UUID) 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) GetOwnedDebugletByUUID(ctx context.Context, arg GetOwnedDebugletByUUIDParams) (Debuglet, 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) 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) UpdateDebugletStarted(ctx context.Context, arg UpdateDebugletStartedParams) (Debuglet, error)

+ func (q *Queries) WithTx(tx *sql.Tx) *Queries

+ type RecordDebugletExitParams struct

+ DebugletID string

+ DispatcherIncarnation string

+ ErrorMessage sql.NullString

+ ExitCode int64

+ RecordedAt UTCTime

+ SessionID string

+ type ReleaseDebugletExitParams struct

+ DebugletID string

+ DispatcherIncarnation string

+ SessionID string

+ type TeslaChain struct

+ Anchor []byte

+ ChainLength int64

+ CreatedAt time.Time

+ DelayNs int64

+ EpochBase time.Time

+ Generation int64

+ type UTCTime struct

+ func NewUTCTime(t time.Time) UTCTime

+ func (t *UTCTime) Scan(src any) error

+ func (t UTCTime) Value() (driver.Value, error)

+ type UpdateDebugletStartedParams struct

+ StartedAt UTCTime

+ Uuid uuid.UUID

v0.2.0-rc.3

Sep 26, 2026

v0.2.0-rc.2

Sep 26, 2026

v0.2.0-rc.1

Sep 25, 2026

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL