ttlcontroller

Documentation

Index

• func Register(c *Controller, controllerRuntimeStopCh <-chan struct{})
• type Controller
  • func NewController(archive core.ExperimentStore, event core.EventStore, ttlc *TTLconfig) *Controller
• type TTLconfig

Functions

func Register

func Register(c *Controller, controllerRuntimeStopCh <-chan struct{})

Register periodically calls function runWorker to delete the data.

Types

type Controller

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

Controller defines the database ttl controller

func NewController

func NewController(
	archive core.ExperimentStore,
	event core.EventStore,
	ttlc *TTLconfig,
) *Controller

NewController returns a new database ttl controller

type TTLconfig

type TTLconfig struct {
	// databaseTTLResyncPeriod defines the time interval to cleanup data in the database.
	DatabaseTTLResyncPeriod time.Duration
	// EventTTL defines the ttl of events
	EventTTL time.Duration
	// ArchiveExperimentTTL defines the ttl of archive experiments
	ArchiveExperimentTTL time.Duration
}

TTLconfig defines the ttl