common

Documentation

Index

• func NewResourceInstance(apiVersionKind string) *unstructured.Unstructured
• func NewResourceInstanceList(apiVersionKind string) *unstructured.UnstructuredList
• func ResolveOneTimeSchedule(creationTimestamp metav1.Time, dateTimeDuration string) (time.Time, error)
• type Config
  • func NewConfig() *Config
• type Scheduler
  • func NewScheduler(config *Config) Scheduler

Functions

func NewResourceInstance

func NewResourceInstance(apiVersionKind string) *unstructured.Unstructured

func NewResourceInstanceList

func NewResourceInstanceList(apiVersionKind string) *unstructured.UnstructuredList

func ResolveOneTimeSchedule

func ResolveOneTimeSchedule(creationTimestamp metav1.Time, dateTimeDuration string) (time.Time, error)

Types

type Config

type Config struct {
	EnableLeaderElection bool          `env:"ENABLE_LEADER_ELECTION" envDefault:"false"`
	SyncPeriod           time.Duration `env:"SYNC_PERIOD" envDefault:"60m"`
	MonitoringInterval   time.Duration `env:"MONITORING_INTERVAL" envDefault:"5s"`
	ExpirationLabel      string        `env:"EXPIRATION_LABEL" envDefault:"mayfly.cloud.namecheap.com/expire"`
	Resources            []string      `env:"RESOURCES" envSeparator:"," envDefault:"v1;Secret,cloud.namecheap.com/v1alpha2;ScheduledResource"`
}

func NewConfig

func NewConfig() *Config

type Scheduler

type Scheduler interface {
	CreateOrUpdateOneTimeTask(tag string, at time.Time, task func() error) error
	CreateOrUpdateRecurringTask(tag string, cron string, task func() error) error
	DeleteTask(tag string) error
	GetTaskNextRun(tag string) string
}

func NewScheduler

func NewScheduler(config *Config) Scheduler