Documentation
¶
Index ¶
Constants ¶
View Source
const ( // GroupMailstackDomain is the group for mailstack domain related jobs GroupMailstackDomain = "mailstack_domain" // GroupMailstackMailbox is the group for mailstack mailbox related jobs GroupMailstackMailbox = "mailstack_mailbox" // LeaseDuration is how long a lease lasts before needing renewal LeaseDuration = 15 * time.Second // RenewDeadline is how long a leader has to renew its lease RenewDeadline = 10 * time.Second // RetryPeriod is how long to wait between leadership attempts RetryPeriod = 2 * time.Second )
CONSTANTS
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type CronManager ¶
type CronManager struct {
// contains filtered or unexported fields
}
func NewCronManager ¶
func NewCronManager(cfg *config.Config, log logger.Logger, k8s kubernetes.Interface, domain interfaces.DomainService, mailbox interfaces.MailboxService, postgres *repository.Repositories) *CronManager
func (*CronManager) Start ¶
func (cm *CronManager) Start(podName, namespace string) error
Start initializes and starts the cron manager with leader election If k8s is nil, it will start in local mode without leader election
func (*CronManager) StartCron ¶
func (cm *CronManager) StartCron()
StartCron initializes and starts the cron scheduler
Click to show internal directories.
Click to hide internal directories.