runstate

package

v1.9.0 Latest Latest Go to latest Published: Oct 27, 2026 License: MIT Imports: 5 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/xraph/cortex

Links

Open Source Insights

Documentation ¶

Overview ¶

Package runstate encodes storage states that fence unsupported workers.

Index ¶

Constants
func Decode(stored string) run.State
func Encode(r *run.Run) string
func NextRevision(current int64) (int64, error)
func UpdateConflict(ctx context.Context, reader interface{ ... }, scope cortex.Scope, ...) error

Constants ¶

View Source

const PausedPrepared = "paused_prepared"

PausedPrepared is deliberately unknown to readers predating preparation. Their atomic resume and expiry claims match only the literal paused state.

Variables ¶

This section is empty.

Functions ¶

func Decode ¶

func Decode(stored string) run.State

Decode restores the public state understood by preparation-aware workers.

func Encode ¶

func Encode(r *run.Run) string

Encode protects prepared pauses while retaining the public lifecycle.

func NextRevision ¶

func NextRevision(current int64) (int64, error)

NextRevision rejects invalid or exhausted versions without wrapping around.

func UpdateConflict ¶

func UpdateConflict(ctx context.Context, reader interface {
	GetRun(context.Context, id.AgentRunID) (*run.Run, error)
}, scope cortex.Scope, runID id.AgentRunID) error

UpdateConflict classifies a failed conditional write without exposing a run outside the exact caller scope. The read is diagnostic, never write authority.

Types ¶

This section is empty.

Source Files ¶

View all Source files

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