cron

Documentation

Index

• Constants
• type CronManager
  • func NewCronManager(cfg *config.Config, log logger.Logger, k8s kubernetes.Interface, ...) *CronManager
  • func (cm *CronManager) Start(podName, namespace string) error
  • func (cm *CronManager) StartCron()
  • func (cm *CronManager) Stop()

Constants

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

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

func (*CronManager) Stop

func (cm *CronManager) Stop()

Stop gracefully stops the cron manager