cleaner

Documentation

Index

• func RecycleOne(client RecycleBoskosClient, res *common.Resource)
• type Cleaner
  • func NewCleaner(cleanerCount int, client boskosClient, waitPeriod time.Duration, ...) *Cleaner
  • func (c *Cleaner) Start()
  • func (c *Cleaner) Stop()
• type RecycleBoskosClient

Functions

func RecycleOne

func RecycleOne(client RecycleBoskosClient, res *common.Resource)

Types

type Cleaner

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

Cleaner looks for ToBeDeleted resources and mark them as Tombstone. It also releases resource hold by dynamic resources if any.

func NewCleaner

func NewCleaner(cleanerCount int, client boskosClient, waitPeriod time.Duration, s cleanerStorage) *Cleaner

NewCleaner creates and initialized a new Cleaner object In: cleanerCount - Number of cleaning threads

client            - boskos client
waitPeriod        - time to wait before a new boskos operation (acquire mostly)

Out: A Pointer to a Cleaner Object

func (*Cleaner) Start

func (c *Cleaner) Start()

Start Cleaner

func (*Cleaner) Stop

func (c *Cleaner) Stop()

Stop Cleaner

type RecycleBoskosClient

type RecycleBoskosClient interface {
	AcquireByState(state, dest string, names []string) ([]common.Resource, error)
	ReleaseOne(name, dest string) error
	UpdateOne(name, state string, userData *common.UserData) error
}