janitor

Documentation

Index

• Variables
• func VersionString() string
• type AggregateLogs
  • func (c AggregateLogs) Run()
• type FailExpiredJobs
  • func (c FailExpiredJobs) Run()
• type FailQueuedJobs
  • func (c FailQueuedJobs) Run()
• type Janitor
  • func InitJanitor(conf JanitorConf) *Janitor
  • func (j *Janitor) InitScheduler()
  • func (j *Janitor) InitServer()
  • func (j *Janitor) Start()
  • func (j *Janitor) Stop()
• type JanitorConf
• type PruneCertificates
  • func (c PruneCertificates) Run()
• type PruneJobs
  • func (c PruneJobs) Run()
• type PruneLocks
  • func (c PruneLocks) Run()
• type PruneTokens
  • func (c PruneTokens) Run()

Variables

var (
	Version   = "develop"
	GITCOMMIT = "HEAD"
)

var SCHEDULE_TIME = "@every 60s"

Functions

func VersionString

func VersionString() string

Types

type AggregateLogs

type AggregateLogs struct {
	// contains filtered or unexported fields
}

aggregate all log parts when final log_part created_at > 5 min or older the 1 day

func (AggregateLogs) Run

func (c AggregateLogs) Run()

type FailExpiredJobs

type FailExpiredJobs struct {
	// contains filtered or unexported fields
}

fail jobs which the timeout + 60 sec has exceeded and still in queued or executing status

func (FailExpiredJobs) Run

func (c FailExpiredJobs) Run()

type FailQueuedJobs

type FailQueuedJobs struct {
	// contains filtered or unexported fields
}

fail jobs which no heartbeat was send back after created_at + 60 sec

func (FailQueuedJobs) Run

func (c FailQueuedJobs) Run()

type Janitor

type Janitor struct {
	Conf JanitorConf
}

func InitJanitor

func InitJanitor(conf JanitorConf) *Janitor

func (*Janitor) InitScheduler

func (j *Janitor) InitScheduler()

func (*Janitor) InitServer

func (j *Janitor) InitServer()

func (*Janitor) Start

func (j *Janitor) Start()

func (*Janitor) Stop

func (j *Janitor) Stop()

type JanitorConf

type JanitorConf struct {
	BindAddress  string
	DbConfigFile string
	Environment  string
}

type PruneCertificates

type PruneCertificates struct {
	// contains filtered or unexported fields
}

func (PruneCertificates) Run

func (c PruneCertificates) Run()

type PruneJobs

type PruneJobs struct {
	// contains filtered or unexported fields
}

delete jobs which are older than 30 days and the respective logs (use of ON DELETE CASCADE in the logs table)

func (PruneJobs) Run

func (c PruneJobs) Run()

type PruneLocks

type PruneLocks struct {
	// contains filtered or unexported fields
}

func (PruneLocks) Run

func (c PruneLocks) Run()

type PruneTokens

type PruneTokens struct {
	// contains filtered or unexported fields
}

func (PruneTokens) Run

func (c PruneTokens) Run()