objectstore

func ClaimForDeployment ¶

func ClaimForDeployment(
	ctx context.Context,
	svc Service,
	keys statestore.KeyBuilder,
	st *statestore.State,
	instanceID string,
	expectedVersion int64,
	newStatus core.InstanceStatus,
) (int64, error)

ClaimForDeployment performs an atomic compare-and-swap on a single instance object in the Service. On success the instance's version is bumped, its status is set to newStatus, and the in-memory State is refreshed.

The CAS bypasses statestore.Storage deliberately — statestore.Storage has no ETag awareness, and the conditional write is what makes this safe for concurrent executions such as CI/CD runs sharing a bucket storage backend.

Returns state.InstanceNotFoundError when the instance object does not exist, and state.ErrVersionConflict when the persisted version does not match expectedVersion (either caught cheaply before the write, or via a 412 on IfMatch).

func InitialiseAndClaim ¶

func InitialiseAndClaim(
	ctx context.Context,
	svc Service,
	keys statestore.KeyBuilder,
	st *statestore.State,
	instanceState state.InstanceState,
	newStatus core.InstanceStatus,
) (int64, error)

InitialiseAndClaim performs an atomic create-if-absent of a new instance object at version 1 with the given status. The conditional Put with IfNoneMatch: "*" is what serialises concurrent first-deploys of the same instance ID sharing a bucket.

When the instance has a name the companion name-lookup record is written alongside it so LookupInstanceIDByName can resolve under ModeLazy without enumerating the instances prefix. A concurrent different-ID-same-name collision on the name record is also mapped to state.ErrInstanceAlreadyExists; the caller can distinguish by a subsequent read if needed.

Returns state.ErrInstanceAlreadyExists when the instance object already exists (412 on IfNoneMatch).

func NewAuthFailed ¶

func NewAuthFailed(message string) error

NewAuthFailed returns an Error with ReasonCodeAuthFailed.

func NewObjectNotFound ¶

func NewObjectNotFound(message string) error

NewObjectNotFound returns an Error with ReasonCodeObjectNotFound. Exported so provider-specific Service implementations can construct the canonical error shape from their SDK-native not-found signals.

func NewPreconditionFailed ¶

func NewPreconditionFailed(message string) error

NewPreconditionFailed returns an Error with ReasonCodePreconditionFailed. Used by provider Services when IfMatch / IfNoneMatch conditional writes fail.

func NewRateLimited ¶

func NewRateLimited(message string) error

NewRateLimited returns an Error with ReasonCodeRateLimited.