controller

Documentation

Index

• type IntegrityController
  • func NewIntegrityController(repositories []*conf.Repository) *IntegrityController
  • func (c *IntegrityController) GetIntegrityReport(repositoryName string) (IntegrityReport, error)
  • func (c *IntegrityController) RunCheck(repository *conf.Repository) func()
  • func (c *IntegrityController) Start() error
• type IntegrityReport
• type RetentionController
  • func NewRetentionController(repositories []*conf.Repository) *RetentionController
  • func (c *RetentionController) GetRetentionReport(repositoryName string) (RetentionReport, error)
  • func (c *RetentionController) RunForget(repository *conf.Repository) func()
  • func (c *RetentionController) Start() error
• type RetentionReport

Types

type IntegrityController

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

IntegrityController represents an instance of the integrity controller

func NewIntegrityController

func NewIntegrityController(repositories []*conf.Repository) *IntegrityController

NewIntegrityController creates a new IntegrityController

func (*IntegrityController) GetIntegrityReport

func (c *IntegrityController) GetIntegrityReport(repositoryName string) (IntegrityReport, error)

GetIntegrityReport returns an integrity report

func (*IntegrityController) RunCheck

func (c *IntegrityController) RunCheck(repository *conf.Repository) func()

RunCheck runs an integrity check

func (*IntegrityController) Start

func (c *IntegrityController) Start() error

Start runs integrity checks in the background

type IntegrityReport

type IntegrityReport struct {
	Time    *time.Time
	Healthy bool
}

IntegrityReport represents an integrity report

type RetentionController

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

RetentionController represents an instance of the retention controller

func NewRetentionController

func NewRetentionController(repositories []*conf.Repository) *RetentionController

NewRetentionController creates a new retention controller

func (*RetentionController) GetRetentionReport

func (c *RetentionController) GetRetentionReport(repositoryName string) (RetentionReport, error)

GetRetentionReport returns a retention report

func (*RetentionController) RunForget

func (c *RetentionController) RunForget(repository *conf.Repository) func()

RunForget runs a forget action

func (*RetentionController) Start

func (c *RetentionController) Start() error

Start applies retention policy periodically checks in the background

type RetentionReport

type RetentionReport struct {
	Time    *time.Time
	Kept    int
	Removed int
}

RetentionReport represents a report about a forget action