retention

Documentation

Index

• Constants
• Variables
• type Controller
  • func NewController() Controller
• type TriggerParam

Constants

const (
	// SchedulerCallback ...
	SchedulerCallback = "RETENTION"
)

Variables

var (
	// Ctl is a global retention controller instance
	Ctl = NewController()
)

Types

type Controller

type Controller interface {
	GetRetention(ctx context.Context, id int64) (*policy.Metadata, error)

	CreateRetention(ctx context.Context, p *policy.Metadata) (int64, error)

	UpdateRetention(ctx context.Context, p *policy.Metadata) error

	DeleteRetention(ctx context.Context, id int64) error

	TriggerRetentionExec(ctx context.Context, policyID int64, trigger string, dryRun bool) (int64, error)

	OperateRetentionExec(ctx context.Context, eid int64, action string) error

	GetRetentionExec(ctx context.Context, eid int64) (*retention.Execution, error)

	ListRetentionExecs(ctx context.Context, policyID int64, query *q.Query) ([]*retention.Execution, error)

	GetTotalOfRetentionExecs(ctx context.Context, policyID int64) (int64, error)

	ListRetentionExecTasks(ctx context.Context, executionID int64, query *q.Query) ([]*retention.Task, error)

	GetTotalOfRetentionExecTasks(ctx context.Context, executionID int64) (int64, error)

	GetRetentionExecTaskLog(ctx context.Context, taskID int64) ([]byte, error)

	GetRetentionExecTask(ctx context.Context, taskID int64) (*retention.Task, error)
	// DeleteRetentionByProject delete retetion rule by project id
	DeleteRetentionByProject(ctx context.Context, projectID int64) error
}

Controller to handle the requests related with retention

func NewController

func NewController() Controller

NewController ...

type TriggerParam

type TriggerParam struct {
	PolicyID int64
	Trigger  string
	Operator string
}

TriggerParam ...