state

type Aborter interface {
	Abort() error
}

type KubernetesStore struct{}

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

type ReadJSONFunc[T any] func(r io.Reader) (T, error)

type RunConfigPersister interface {
	// WriteJSON serializes the object to JSON and writes it to the provided writer
	WriteJSON(w io.Writer) error
	// GetBaseName returns the base name used for persistence
	GetBaseName() string
}

type Store interface {
	// GetReader returns a reader for the state data
	// This is useful for streaming large state data
	GetReader(ctx context.Context, name string) (io.ReadCloser, error)

	// GetWriter returns a writer for the state data. For stores that publish state on Close,
	// callers must return Close errors because the write may not be visible until Close succeeds.
	// Callers must use AbortWriter instead of Close when abandoning a write, because Close may publish it.
	// This is useful for streaming large state data.
	GetWriter(ctx context.Context, name string) (io.WriteCloser, error)

	// CreateExclusive creates a new state entry exclusively, returning an error if it already exists.
	// For stores that publish state on Close, exclusivity is enforced at Close and Close can return
	// an error with http.StatusConflict if another writer published the entry first.
	// Callers must return Close errors and use AbortWriter rather than Close when abandoning a write,
	// because the write may not be visible until Close succeeds.
	// This provides atomic check-and-create semantics to prevent race conditions.
	CreateExclusive(ctx context.Context, name string) (io.WriteCloser, error)

	// Delete removes the data for the given name
	Delete(ctx context.Context, name string) error

	// List returns all available state names
	List(ctx context.Context) ([]string, error)

	// Exists checks if data exists for the given name
	Exists(ctx context.Context, name string) (bool, error)
}