Documentation
¶
Index ¶
- Variables
- type BatchProcessor
- type CertRotator
- type CertUpdater
- type HYOKSync
- type HYOKUpdater
- type KeystorePoolFiller
- type KeystorePoolUpdater
- type NotificationClient
- type NotificationSender
- type SystemUpdater
- type SystemsRefresher
- type WorkflowCleaner
- type WorkflowExpiryProcessor
- type WorkflowExpiryUpdater
- type WorkflowProcessor
- type WorkflowRemoval
- type WorkflowUpdater
Constants ¶
This section is empty.
Variables ¶
View Source
var ErrRotatingCert = errors.New("error rotating certificate")
View Source
var ErrRunningTask = errors.New("task failed")
Functions ¶
This section is empty.
Types ¶
type BatchProcessor ¶
type BatchProcessor struct {
// contains filtered or unexported fields
}
BatchProcessor handles the common batch processing logic for async tasks
func NewBatchProcessor ¶
func NewBatchProcessor(repo repo.Repo) *BatchProcessor
NewBatchProcessor creates a new batch processor
func (*BatchProcessor) ProcessTenantsInBatch ¶
func (bp *BatchProcessor) ProcessTenantsInBatch( ctx context.Context, taskName string, asynqTask *asynq.Task, processTenant func(ctx context.Context, tenant *model.Tenant, index int) error, ) error
ProcessTenantsInBatch iterates through tenants in batches and applies the process function It tracks the total tenant count, logs batch progress, and logs task completion
type CertRotator ¶
type CertRotator struct {
// contains filtered or unexported fields
}
func NewCertRotator ¶
func NewCertRotator( certClient CertUpdater, repo repo.Repo, ) *CertRotator
func (*CertRotator) ProcessTask ¶
func (*CertRotator) TaskType ¶
func (s *CertRotator) TaskType() string
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 NewHYOKSync ¶
func NewHYOKSync( hyokClient HYOKUpdater, repo repo.Repo, ) *HYOKSync
func (*HYOKSync) ProcessTask ¶
type HYOKUpdater ¶
type KeystorePoolFiller ¶
type KeystorePoolFiller struct {
// contains filtered or unexported fields
}
func NewKeystorePoolFiller ¶
func NewKeystorePoolFiller( updater KeystorePoolUpdater, repo repo.Repo, poolConfig config.KeystorePool, ) *KeystorePoolFiller
func (*KeystorePoolFiller) ProcessTask ¶
func (*KeystorePoolFiller) TaskType ¶
func (k *KeystorePoolFiller) TaskType() string
type KeystorePoolUpdater ¶
type NotificationClient ¶
type NotificationSender ¶
type NotificationSender struct {
// contains filtered or unexported fields
}
func NewNotificationSender ¶
func NewNotificationSender( client NotificationClient, ) *NotificationSender
func (*NotificationSender) ProcessTask ¶
func (*NotificationSender) TaskType ¶
func (n *NotificationSender) TaskType() string
type SystemUpdater ¶
type SystemsRefresher ¶
type SystemsRefresher struct {
// contains filtered or unexported fields
}
func NewSystemsRefresher ¶
func NewSystemsRefresher( systemClient SystemUpdater, repo repo.Repo, ) *SystemsRefresher
func (*SystemsRefresher) ProcessTask ¶
func (*SystemsRefresher) TaskType ¶
func (s *SystemsRefresher) TaskType() string
type WorkflowCleaner ¶
type WorkflowCleaner struct {
// contains filtered or unexported fields
}
func NewWorkflowCleaner ¶
func NewWorkflowCleaner( workflowRemoval WorkflowRemoval, repo repo.Repo, ) *WorkflowCleaner
func (*WorkflowCleaner) ProcessTask ¶
func (*WorkflowCleaner) TaskType ¶
func (wc *WorkflowCleaner) TaskType() string
type WorkflowExpiryProcessor ¶
type WorkflowExpiryProcessor struct {
// contains filtered or unexported fields
}
func NewWorkflowExpiryProcessor ¶
func NewWorkflowExpiryProcessor( updater WorkflowExpiryUpdater, repo repo.Repo, ) *WorkflowExpiryProcessor
func (*WorkflowExpiryProcessor) ProcessTask ¶
func (*WorkflowExpiryProcessor) TaskType ¶
func (s *WorkflowExpiryProcessor) TaskType() string
type WorkflowExpiryUpdater ¶
type WorkflowProcessor ¶
type WorkflowProcessor struct {
// contains filtered or unexported fields
}
func NewWorkflowProcessor ¶
func NewWorkflowProcessor( updater WorkflowUpdater, repo repo.Repo, ) *WorkflowProcessor
func (*WorkflowProcessor) ProcessTask ¶
func (*WorkflowProcessor) TaskType ¶
func (s *WorkflowProcessor) TaskType() string
type WorkflowRemoval ¶
Click to show internal directories.
Click to hide internal directories.