k8s

Documentation

Index

• func NoTTLAnnotationFilter(id string, annotations map[string]string, created time.Time, log *logrus.Entry) bool
• func TTLExpiredFilter(id string, annotations map[string]string, created time.Time, log *logrus.Entry) bool
• type Filter
• type K8SMarker
  • func NewK8SMarker(ctx context.Context, cfg *config.Kubernetes, logger *logrus.Logger, ...) (*K8SMarker, error)
  • func (k *K8SMarker) FilterK8SObject(f filterable)
  • func (k *K8SMarker) GetMarkSchedule() string
  • func (k *K8SMarker) GetName() string
  • func (k *K8SMarker) GetNotifySchedule() string
  • func (k *K8SMarker) GetSweepSchedule() string
  • func (k *K8SMarker) GetType() mark.MarkerType
  • func (k *K8SMarker) Mark()
  • func (k *K8SMarker) Sweep()

Functions

func NoTTLAnnotationFilter

func NoTTLAnnotationFilter(id string, annotations map[string]string, created time.Time, log *logrus.Entry) bool

func TTLExpiredFilter

func TTLExpiredFilter(id string, annotations map[string]string, created time.Time, log *logrus.Entry) bool

Types

type Filter

type Filter func(id string, annotations map[string]string, created time.Time, log *logrus.Entry) bool

type K8SMarker

type K8SMarker struct {
	Config *config.Kubernetes
	Logger *logrus.Entry
	Cache  cache.Cache
	Ctx    context.Context
	// contains filtered or unexported fields
}

func NewK8SMarker

func NewK8SMarker(ctx context.Context, cfg *config.Kubernetes, logger *logrus.Logger, cache cache.Cache) (*K8SMarker, error)

func (*K8SMarker) FilterK8SObject

func (k *K8SMarker) FilterK8SObject(f filterable)

func (*K8SMarker) GetMarkSchedule

func (k *K8SMarker) GetMarkSchedule() string

func (*K8SMarker) GetName

func (k *K8SMarker) GetName() string

func (*K8SMarker) GetNotifySchedule

func (k *K8SMarker) GetNotifySchedule() string

func (*K8SMarker) GetSweepSchedule

func (k *K8SMarker) GetSweepSchedule() string

func (*K8SMarker) GetType

func (k *K8SMarker) GetType() mark.MarkerType

func (*K8SMarker) Mark

func (k *K8SMarker) Mark()

func (*K8SMarker) Sweep

func (k *K8SMarker) Sweep()