Documentation
¶
Index ¶
- Variables
- func NewCertRotator(certClient CertUpdater, repo repo.Repo, opts ...async.TaskOption) async.TenantTaskHandler
- func NewHYOKSync(hyokClient HYOKUpdater, repo repo.Repo, opts ...async.TaskOption) async.TenantTaskHandler
- func NewSystemsRefresher(systemClient SystemUpdater, repo repo.Repo, opts ...async.TaskOption) async.TenantTaskHandler
- func NewTenantNameRefresher(r repo.Repo, registry registry.Service, opts ...async.TaskOption) async.TenantTaskHandler
- func NewWorkflowCleaner(workflowRemoval WorkflowRemoval, repo repo.Repo, opts ...async.TaskOption) async.TenantTaskHandler
- func NewWorkflowExpiryProcessor(updater WorkflowExpiryUpdater, repo repo.Repo, opts ...async.TaskOption) async.TenantTaskHandler
- type CertRotator
- type CertUpdater
- type HYOKSync
- type HYOKUpdater
- type SystemUpdater
- type SystemsRefresher
- type TenantNameRefresher
- type WorkflowCleaner
- type WorkflowExpiryProcessor
- type WorkflowExpiryUpdater
- type WorkflowRemoval
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 (*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 (*HYOKSync) TenantQuery ¶
type HYOKUpdater ¶
type SystemUpdater ¶
type SystemsRefresher ¶
type SystemsRefresher struct {
// contains filtered or unexported fields
}
func (*SystemsRefresher) FanOutFunc ¶
func (s *SystemsRefresher) FanOutFunc() async.FanOutFunc
func (*SystemsRefresher) ProcessTask ¶
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 (*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 (*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 (*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 ¶
Click to show internal directories.
Click to hide internal directories.