tasks

package
v0.8.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 21, 2026 License: Apache-2.0 Imports: 21 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var ErrRotatingCert = errors.New("error rotating certificate")

Functions

func NewCertRotator

func NewCertRotator(
	certClient CertUpdater,
	repo repo.Repo,
	opts ...async.TaskOption,
) async.TenantTaskHandler

func NewHYOKSync

func NewHYOKSync(
	hyokClient HYOKUpdater,
	repo repo.Repo,
	opts ...async.TaskOption,
) async.TenantTaskHandler

func NewSystemsRefresher

func NewSystemsRefresher(
	systemClient SystemUpdater,
	repo repo.Repo,
	opts ...async.TaskOption,
) async.TenantTaskHandler

func NewTenantNameRefresher

func NewTenantNameRefresher(
	r repo.Repo,
	registry registry.Service,
	opts ...async.TaskOption,
) async.TenantTaskHandler

func NewWorkflowCleaner

func NewWorkflowCleaner(
	workflowRemoval WorkflowRemoval,
	repo repo.Repo,
	opts ...async.TaskOption,
) async.TenantTaskHandler

func NewWorkflowExpiryProcessor

func NewWorkflowExpiryProcessor(
	updater WorkflowExpiryUpdater,
	repo repo.Repo,
	opts ...async.TaskOption,
) async.TenantTaskHandler

Types

type CertRotator

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

func (*CertRotator) FanOutFunc

func (c *CertRotator) FanOutFunc() async.FanOutFunc

func (*CertRotator) ProcessTask

func (c *CertRotator) ProcessTask(ctx context.Context, task *asynq.Task) error

func (*CertRotator) TaskType

func (c *CertRotator) TaskType() string

func (*CertRotator) TenantQuery

func (c *CertRotator) TenantQuery() *repo.Query

type CertUpdater

type CertUpdater interface {
	RotateExpiredCertificates(ctx context.Context) error
	RotateCertificate(ctx context.Context, args model.RequestCertArgs) (*model.Certificate,
		*rsa.PrivateKey, error)
}

type HYOKSync

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

func (*HYOKSync) FanOutFunc

func (h *HYOKSync) FanOutFunc() async.FanOutFunc

func (*HYOKSync) ProcessTask

func (h *HYOKSync) ProcessTask(ctx context.Context, _ *asynq.Task) error

func (*HYOKSync) TaskType

func (h *HYOKSync) TaskType() string

func (*HYOKSync) TenantQuery

func (h *HYOKSync) TenantQuery() *repo.Query

type HYOKUpdater

type HYOKUpdater interface {
	SyncHYOKKeys(ctx context.Context) error
}

type SystemUpdater

type SystemUpdater interface {
	UpdateSystems(ctx context.Context) error
}

type SystemsRefresher

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

func (*SystemsRefresher) FanOutFunc

func (s *SystemsRefresher) FanOutFunc() async.FanOutFunc

func (*SystemsRefresher) ProcessTask

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

func (*SystemsRefresher) TaskType

func (s *SystemsRefresher) TaskType() string

func (*SystemsRefresher) TenantQuery

func (s *SystemsRefresher) TenantQuery() *repo.Query

type TenantNameRefresher

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

func (*TenantNameRefresher) FanOutFunc

func (t *TenantNameRefresher) FanOutFunc() async.FanOutFunc

func (*TenantNameRefresher) ProcessTask

func (t *TenantNameRefresher) ProcessTask(ctx context.Context, task *asynq.Task) error

func (*TenantNameRefresher) TaskType

func (t *TenantNameRefresher) TaskType() string

func (*TenantNameRefresher) TenantQuery

func (t *TenantNameRefresher) TenantQuery() *repo.Query

type WorkflowCleaner

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

func (*WorkflowCleaner) FanOutFunc

func (wc *WorkflowCleaner) FanOutFunc() async.FanOutFunc

func (*WorkflowCleaner) ProcessTask

func (wc *WorkflowCleaner) ProcessTask(ctx context.Context, task *asynq.Task) error

func (*WorkflowCleaner) TaskType

func (wc *WorkflowCleaner) TaskType() string

func (*WorkflowCleaner) TenantQuery

func (wc *WorkflowCleaner) TenantQuery() *repo.Query

type WorkflowExpiryProcessor

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

func (*WorkflowExpiryProcessor) FanOutFunc

func (w *WorkflowExpiryProcessor) FanOutFunc() async.FanOutFunc

func (*WorkflowExpiryProcessor) ProcessTask

func (w *WorkflowExpiryProcessor) ProcessTask(ctx context.Context, task *asynq.Task) error

func (*WorkflowExpiryProcessor) TaskType

func (w *WorkflowExpiryProcessor) TaskType() string

func (*WorkflowExpiryProcessor) TenantQuery

func (w *WorkflowExpiryProcessor) TenantQuery() *repo.Query

type WorkflowExpiryUpdater

type WorkflowExpiryUpdater interface {
	GetWorkflows(ctx context.Context, params repo.QueryMapper) ([]*model.Workflow, int, error)
	TransitionWorkflow(
		ctx context.Context,
		workflowID uuid.UUID,
		transition wfMechanism.Transition,
	) (*model.Workflow, error)
	GetWorkflowAvailableTransitions(ctx context.Context, workflow *model.Workflow) ([]wfMechanism.Transition, error)
}

type WorkflowRemoval

type WorkflowRemoval interface {
	CleanupTerminalWorkflows(ctx context.Context) error
}

Jump to

Keyboard shortcuts

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