execution

package

Go to main page

Versions in this module

v1

v1.4.0

Nov 8, 2026

v1.3.0

Oct 31, 2026

v1.2.0

Oct 23, 2026

Changes in this version

+ const TriggerSourceAgentCallback

+ const TriggerSourceDolphinWorker

+ const TriggerSourceReconciler

+ const TriggerSourceRequest

+ const TriggerSourceScheduler

+ func TriggerSourceFromContext(ctx context.Context) string

+ func WithTriggerSource(ctx context.Context, source string) context.Context

type CreateInput

+ ActorTokenID *uint64

+ ClientIP string

+ TokenName string

+ TokenPrefix string

+ TriggerSource string

+ UserAgent string

type Execution

+ ActorTokenID *uint64

+ ClientIP string

+ TokenName string

+ TokenPrefix string

+ TriggerSource string

+ UserAgent string

v1.2.0-beta.1

Oct 22, 2026

v1.1.2-beta.1

Oct 18, 2026

v1.1.1

Oct 3, 2026

v1.1.0

Oct 1, 2026

v1.0.0

Sep 25, 2026

Changes in this version

+ func WriteError(c *gin.Context, err error)

type Execution

+ ClientType string

type Service

+ func (s *Service) BeginSynchronous(ctx context.Context, actor Actor, input SynchronousInput) (*Execution, bool, error)

+ func (s *Service) EnrichAuditDetails(ctx context.Context, executionID string, extraDetails map[string]any) error

+ func (s *Service) FinishSynchronous(ctx context.Context, item *Execution, resultRef string, runErr error) error

+ type SynchronousInput struct

+ ClientType string

+ ConfirmationID string

+ Confirmed bool

+ IdempotencyKey string

+ Impact string

+ Module string

+ ModuleRef string

+ OperationID string

+ RequestHash string

+ RequestID string

+ RiskLevel RiskLevel

v1.0.0-beta

Sep 25, 2026

v0

v0.0.2-rc1

Sep 19, 2026

v0.0.1

Sep 19, 2026

Changes in this version

+ const ErrorCodeAdminRequired

+ const ErrorCodeConcurrentUpdate

+ const ErrorCodeConfirmationInvalid

+ const ErrorCodeConfirmationRequired

+ const ErrorCodeIdempotencyConflict

+ const ErrorCodeIdempotencyRequired

+ const ErrorCodeInvalidTransition

+ const ErrorCodeNotCancellable

+ const ErrorCodeNotFound

+ const ErrorCodePermissionDenied

+ const HeaderConfirm

+ const HeaderConfirmationID

+ const HeaderIdempotencyKey

+ const HeaderRequestID

+ var ErrAdminRequired = errors.New("administrator permission is required")

+ var ErrConcurrentUpdate = errors.New("execution status changed concurrently")

+ var ErrConfirmationInvalid = errors.New("operation confirmation is invalid or expired")

+ var ErrConfirmationRequired = errors.New("operation confirmation is required")

+ var ErrExecutionNotFound = errors.New("execution not found")

+ var ErrExplicitConfirmNeeded = errors.New("explicit confirmation is required")

+ var ErrIdempotencyConflict = errors.New("idempotency key was already used with a different request")

+ var ErrIdempotencyKeyMissing = errors.New("idempotency key is required")

+ var ErrInvalidExecution = errors.New("invalid execution")

+ var ErrInvalidTransition = errors.New("invalid execution status transition")

+ var ErrNotCancellable = errors.New("execution is not cancellable")

+ var ErrPermissionDenied = errors.New("permission denied")

+ var ErrProviderNotRegistered = errors.New("execution cancellation provider is not registered")

+ func CanTransition(from, to Status) bool

+ func HashRequest(value any) (string, error)

+ func HashString(value string) string

+ func IsTerminal(status Status) bool

+ type Actor struct

+ IsAdmin bool

+ UserID uint64

+ type ActorType string

+ const ActorTypeSystem

+ const ActorTypeUser

+ type AuthorizationInput struct

+ ConfirmationID string

+ Confirmed bool

+ IdempotencyKey string

+ Impact string

+ OperationID string

+ RequestHash string

+ RiskLevel RiskLevel

+ type CancelResult struct

+ Cancellable bool

+ CancellableReason string

+ Status Status

+ type CancellationProvider interface

+ RequestCancel func(ctx context.Context, execution *Execution, actor Actor) (CancelResult, error)

+ type Confirmation struct

+ ConfirmationHash string

+ ConsumedAt *time.Time

+ CreatedAt time.Time

+ ExpiresAt time.Time

+ ID uint64

+ IdempotencyKeyHash string

+ Impact string

+ OperationID string

+ OwnerUserID uint64

+ RequestHash string

+ RiskLevel RiskLevel

+ func (Confirmation) TableName() string

+ type ConfirmationData struct

+ ConfirmationID string

+ ConfirmationRequired bool

+ ExpiresAt time.Time

+ Impact string

+ RiskLevel RiskLevel

+ type ConfirmationRequiredError struct

+ ConfirmationID string

+ ExpiresAt time.Time

+ Impact string

+ RiskLevel RiskLevel

+ func (e *ConfirmationRequiredError) Error() string

+ func (e *ConfirmationRequiredError) Unwrap() error

+ type CreateInput struct

+ ActorType ActorType

+ Cancellable bool

+ CancellableReason string

+ ClientType string

+ IdempotencyKey string

+ Module string

+ ModuleRef string

+ OperationID string

+ OwnerUserID uint64

+ RequestHash string

+ RequestID string

+ RiskLevel RiskLevel

+ Status Status

+ type Execution struct

+ ActorType ActorType

+ Cancellable bool

+ CancellableReason string

+ CreatedAt time.Time

+ ErrorCode string

+ ErrorMessage string

+ ExecutionID string

+ FinishedAt *time.Time

+ ID uint64

+ IdempotencyKeyHash *string

+ Module string

+ ModuleRef string

+ OperationID string

+ OwnerUserID uint64

+ Progress int

+ RequestHash string

+ RequestID string

+ ResultRef string

+ RiskLevel RiskLevel

+ StartedAt *time.Time

+ Status Status

+ UpdatedAt time.Time

+ func (Execution) TableName() string

+ type Handler struct

+ func NewHandler(service *Service) *Handler

+ func (h *Handler) Cancel(c *gin.Context)

+ func (h *Handler) Get(c *gin.Context)

+ func (h *Handler) Wait(c *gin.Context)

+ type ProviderRegistry struct

+ func NewProviderRegistry() *ProviderRegistry

+ func (r *ProviderRegistry) Get(module string) (CancellationProvider, bool)

+ func (r *ProviderRegistry) Register(module string, provider CancellationProvider)

+ type Repository struct

+ func NewRepository(db *gorm.DB) *Repository

+ func (r *Repository) BindModuleRef(ctx context.Context, executionID, moduleRef string) error

+ func (r *Repository) ConsumeConfirmation(ctx context.Context, confirmationHash string, ownerUserID uint64, ...) error

+ func (r *Repository) CreateConfirmation(ctx context.Context, item *Confirmation) error

+ func (r *Repository) CreateOrGet(ctx context.Context, item *Execution) (*Execution, bool, error)

+ func (r *Repository) GetByExecutionID(ctx context.Context, executionID string) (*Execution, error)

+ func (r *Repository) UpdateStatus(ctx context.Context, executionID string, expected []Status, ...) error

+ type RequestMetadata struct

+ ClientType string

+ ConfirmationID string

+ Confirmed bool

+ IdempotencyKey string

+ RequestID string

+ func MetadataFromGin(c *gin.Context) RequestMetadata

+ type Response struct

+ Data any

+ ErrorCode string

+ ErrorMsg string

+ type RiskLevel string

+ const RiskLevelR0

+ const RiskLevelR1

+ const RiskLevelR2

+ const RiskLevelR3

+ type Service struct

+ func NewService(repo *Repository, providers *ProviderRegistry) *Service

+ func (s *Service) Authorize(ctx context.Context, actor Actor, input AuthorizationInput) error

+ func (s *Service) BindModuleRef(ctx context.Context, executionID, moduleRef string) error

+ func (s *Service) Cancel(ctx context.Context, actor Actor, executionID string) (*Execution, error)

+ func (s *Service) Create(ctx context.Context, input CreateInput) (*Execution, bool, error)

+ func (s *Service) FindIdempotent(ctx context.Context, actor Actor, ...) (*Execution, bool, error)

+ func (s *Service) Get(ctx context.Context, actor Actor, executionID string) (*Execution, error)

+ func (s *Service) SetAuditRepository(repo *audit.Repository)

+ func (s *Service) Transition(ctx context.Context, executionID string, from, to Status, ...) error

+ func (s *Service) Wait(ctx context.Context, actor Actor, executionID string, timeout time.Duration) (*Execution, bool, error)

+ type Status string

+ const StatusCancelRequested

+ const StatusCancelled

+ const StatusCancelling

+ const StatusFailed

+ const StatusPending

+ const StatusRunning

+ const StatusSucceeded

+ const StatusTimedOut

+ type WaitData struct

+ Execution *Execution

+ TimedOut bool

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