async

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

type CloudTasksEnqueuerConfig struct {
	ProjectID string
	Location  string
	Queue     string

	RunURL string

	InvokerServiceAccountEmail string
	OIDCAudience               string
}

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

type Enqueuer interface {
	EnqueueRun(ctx context.Context, ref ExecutionRef, delay time.Duration) error
}

type Execution struct {
	Ref        ExecutionRef
	Status     ExecutionStatus
	Attempt    int
	LeaseOwner string
	LeaseUntil time.Time

	WakeAt     *time.Time
	Dirty      bool
	Checkpoint string

	WaitReason string
	LastError  string
	UpdatedAt  time.Time
}

type ExecutionRef struct {
	Kind string `json:"kind"`
	Key  string `json:"key"`
}

type ExecutionStatus string

type Handler interface {
	Run(ctx context.Context, exec Execution) (Outcome, error)
}

type Outcome struct {
	Type       OutcomeType
	Delay      time.Duration
	Reason     string
	Checkpoint string
	Err        error
}

type OutcomeType string

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

type Store interface {
	UpsertQueued(ctx context.Context, ref ExecutionRef, wakeNow bool) (bool, error)
	AcquireLease(ctx context.Context, ref ExecutionRef, owner string, ttl time.Duration) (bool, Execution, error)
	Get(ctx context.Context, ref ExecutionRef) (Execution, error)
	MarkWaiting(ctx context.Context, ref ExecutionRef, wakeAt time.Time, reason string, checkpoint string) error
	MarkDone(ctx context.Context, ref ExecutionRef, checkpoint string) error
	MarkFailed(ctx context.Context, ref ExecutionRef, errMsg string) error
	FinalizeAfterRun(ctx context.Context, ref ExecutionRef) (bool, error)
}