retention

Documentation

Overview

Package retention implements data retention for LUCI CV.

The current policy is

• Run and its child entities will be deleted 18 months after run has been created
• CL entity will be deleted if it hasn't been updated for 18 months and is no longer referenced by any runs.
• Tryjob entity will be deleted if it hasn't been updated for 18 months and is no longer referenced by any runs.

Index

• Variables
• func RegisterCrons(tqd *tq.Dispatcher, rm rm)
• type WipeoutCLsTask
  • func (*WipeoutCLsTask) Descriptor() ([]byte, []int)
  • func (x *WipeoutCLsTask) GetIds() []int64
  • func (*WipeoutCLsTask) ProtoMessage()
  • func (x *WipeoutCLsTask) ProtoReflect() protoreflect.Message
  • func (x *WipeoutCLsTask) Reset()
  • func (x *WipeoutCLsTask) String() string
• type WipeoutRunsTask
  • func (*WipeoutRunsTask) Descriptor() ([]byte, []int)
  • func (x *WipeoutRunsTask) GetIds() []string
  • func (*WipeoutRunsTask) ProtoMessage()
  • func (x *WipeoutRunsTask) ProtoReflect() protoreflect.Message
  • func (x *WipeoutRunsTask) Reset()
  • func (x *WipeoutRunsTask) String() string
• type WipeoutTryjobsTask
  • func (*WipeoutTryjobsTask) Descriptor() ([]byte, []int)
  • func (x *WipeoutTryjobsTask) GetIds() []int64
  • func (*WipeoutTryjobsTask) ProtoMessage()
  • func (x *WipeoutTryjobsTask) ProtoReflect() protoreflect.Message
  • func (x *WipeoutTryjobsTask) Reset()
  • func (x *WipeoutTryjobsTask) String() string

Variables

var File_go_chromium_org_luci_cv_internal_retention_tasks_proto protoreflect.FileDescriptor

Functions

func RegisterCrons

func RegisterCrons(tqd *tq.Dispatcher, rm rm)

RegisterCrons registers cron jobs for data retention.

Types

type WipeoutCLsTask

type WipeoutCLsTask struct {
	Ids []int64 `protobuf:"varint,1,rep,packed,name=ids,proto3" json:"ids,omitempty"`
	// contains filtered or unexported fields
}

WipeoutCLsTask wipes out given CLs that are out of the retention policy.

Queue: "data-retention".

func (*WipeoutCLsTask) Descriptor

func (*WipeoutCLsTask) Descriptor() ([]byte, []int)

Deprecated: Use WipeoutCLsTask.ProtoReflect.Descriptor instead.

func (*WipeoutCLsTask) GetIds

func (x *WipeoutCLsTask) GetIds() []int64

func (*WipeoutCLsTask) ProtoMessage

func (*WipeoutCLsTask) ProtoMessage()

func (*WipeoutCLsTask) ProtoReflect

func (x *WipeoutCLsTask) ProtoReflect() protoreflect.Message

func (*WipeoutCLsTask) Reset

func (x *WipeoutCLsTask) Reset()

func (*WipeoutCLsTask) String

func (x *WipeoutCLsTask) String() string

type WipeoutRunsTask

type WipeoutRunsTask struct {
	Ids []string `protobuf:"bytes,1,rep,name=ids,proto3" json:"ids,omitempty"`
	// contains filtered or unexported fields
}

WipeoutRunsTask wipes out given Runs and its descendent entities that are out of the retention policy.

Queue: "data-retention".

func (*WipeoutRunsTask) Descriptor

func (*WipeoutRunsTask) Descriptor() ([]byte, []int)

Deprecated: Use WipeoutRunsTask.ProtoReflect.Descriptor instead.

func (*WipeoutRunsTask) GetIds

func (x *WipeoutRunsTask) GetIds() []string

func (*WipeoutRunsTask) ProtoMessage

func (*WipeoutRunsTask) ProtoMessage()

func (*WipeoutRunsTask) ProtoReflect

func (x *WipeoutRunsTask) ProtoReflect() protoreflect.Message

func (*WipeoutRunsTask) Reset

func (x *WipeoutRunsTask) Reset()

func (*WipeoutRunsTask) String

func (x *WipeoutRunsTask) String() string

type WipeoutTryjobsTask

type WipeoutTryjobsTask struct {
	Ids []int64 `protobuf:"varint,1,rep,packed,name=ids,proto3" json:"ids,omitempty"`
	// contains filtered or unexported fields
}

WipeoutTryjobsTask wipes out given tryjobs that are out of the retention policy.

Queue: "data-retention".

func (*WipeoutTryjobsTask) Descriptor

func (*WipeoutTryjobsTask) Descriptor() ([]byte, []int)

Deprecated: Use WipeoutTryjobsTask.ProtoReflect.Descriptor instead.

func (*WipeoutTryjobsTask) GetIds

func (x *WipeoutTryjobsTask) GetIds() []int64

func (*WipeoutTryjobsTask) ProtoMessage

func (*WipeoutTryjobsTask) ProtoMessage()

func (*WipeoutTryjobsTask) ProtoReflect

func (x *WipeoutTryjobsTask) ProtoReflect() protoreflect.Message

func (*WipeoutTryjobsTask) Reset

func (x *WipeoutTryjobsTask) Reset()

func (*WipeoutTryjobsTask) String

func (x *WipeoutTryjobsTask) String() string