tasks

package

v0.8.0 Latest Latest Go to latest Published: Apr 21, 2026 License: Apache-2.0 Imports: 15 Imported by: 0

Details

This section is empty.

View Source

var ErrRunningTask = errors.New("task failed")

func NewKeystorePoolFiller(
	updater KeystorePoolFiller,
	repo repo.Repo,
	poolConfig config.KeystorePool,
) async.TaskHandler

func NewNotificationSender(
	client NotificationClient,
) async.TaskHandler

func NewWorkflowProcessor(
	updater WorkflowUpdater,
	repo repo.Repo,
) async.TaskHandler

type KeystorePoolFiller interface {
	FillKeystorePool(ctx context.Context, size int) error
}

type NotificationClient interface {
	CreateNotification(ctx context.Context, notif client.Data) error
}

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

func (s *WorkflowProcessor) ProcessTask(ctx context.Context, task *asynq.Task) error

func (s *WorkflowProcessor) TaskType() string

type WorkflowUpdater interface {
	AutoAssignApprovers(ctx context.Context, workflowID uuid.UUID) (*model.Workflow, error)
}

Path	Synopsis
tenant