cron

package
v0.2.24 Latest Latest
Warning

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

Go to latest
Published: May 18, 2025 License: Apache-2.0 Imports: 17 Imported by: 0

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 (*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

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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