reaper

Documentation

Index

• Constants
• Variables
• type BucketReaper
  • func (r *BucketReaper) Run()
• type FileReaper
  • func (r *FileReaper) Run()
• type GroupReaper
  • func (r *GroupReaper) Run()
• type Manager
  • func (m *Manager) Run(ctx context.Context)
• type Reaper
• type RefCounter
  • func (r *RefCounter) Count(m interface{}, kind string, pk uint) (nRef int64, err error)
• type Task
• type TaskReaper
  • func (r *TaskReaper) Run()
  • func (r *TaskReaper) TTL(m *model.Task) (ttl api.TTL)

Constants

const (
	Unit = time.Minute
)

Variables

var (
	Settings = &settings.Settings
	Log      = logr.WithName("reaper")
)

Types

type BucketReaper

type BucketReaper struct {
	// DB
	DB *gorm.DB
}

BucketReaper bucket reaper.

func (*BucketReaper) Run

func (r *BucketReaper) Run()

Run Executes the reaper. A bucket is deleted when it is no longer referenced and the TTL has expired.

type FileReaper

type FileReaper struct {
	// DB
	DB *gorm.DB
}

FileReaper file reaper.

func (*FileReaper) Run

func (r *FileReaper) Run()

Run Executes the reaper. A file is deleted when it is no longer referenced and the TTL has expired.

type GroupReaper

type GroupReaper struct {
	// DB
	DB *gorm.DB
}

GroupReaper reaps task groups.

func (*GroupReaper) Run

func (r *GroupReaper) Run()

Run Executes the reaper. Rules by state:

Created
- Deleted after the defined period.
Ready (submitted)
- Deleted when all of its task have been deleted.
- Bucket is released immediately.

type Manager

type Manager struct {
	// DB
	DB *gorm.DB
	// k8s client.
	Client k8s.Client
}

Manager provides task management.

func (*Manager) Run

func (m *Manager) Run(ctx context.Context)

Run the manager.

type Reaper

type Reaper interface {
	Run()
}

Reaper interface.

type RefCounter

type RefCounter struct {
	// DB
	DB *gorm.DB
}

RefCounter provides model inspection for files tagged with: ref:<kind>.

func (*RefCounter) Count

func (r *RefCounter) Count(m interface{}, kind string, pk uint) (nRef int64, err error)

Count find & count references.

type Task

type Task = task.Task

type TaskReaper

type TaskReaper struct {
	// DB
	DB *gorm.DB
	// k8s client.
	Client k8s.Client
}

TaskReaper reaps tasks.

func (*TaskReaper) Run

func (r *TaskReaper) Run()

Run Executes the reaper. Rules by state:

Created
- Deleted after TTL.Created > created timestamp or
  settings.Task.Reaper.Created.
Pending
- Deleted after TTL.Pending > created timestamp or
  settings.Task.Reaper.Created.
Postponed
- Deleted after TTL.Postponed > created timestamp or
  settings.Task.Reaper.Created.
Running
- Deleted after TTL.Running > started timestamp.
Succeeded
- Deleted after TTL > terminated timestamp or
  settings.Task.Reaper.Succeeded.
- Bucket is released after the defined period.
- Pod is deleted after the defined period.
Failed
- Deleted after TTL > terminated timestamp or
  settings.Task.Reaper.Failed.
- Bucket is released after the defined period.
- Pod is deleted after the defined period.

func (*TaskReaper) TTL

func (r *TaskReaper) TTL(m *model.Task) (ttl api.TTL)

TTL returns the task TTL.