reconciliation

Documentation

Index

• type Job
• type JobProvider
• type ReconcileHandler
• type Reconciler
  • func NewReconciler(p JobProvider, olderThan time.Duration) Reconciler
• type Scheduler
  • func NewScheduler(r Reconciler) Scheduler
• type Type

Types

type Job

type Job struct {
	Type        Type      `gson:"type"`
	Guid        string    `gson:"guid"`
	LastUpdated time.Time `gson:"lastUpdated" json:"lastUpdated"`
}

type JobProvider

type JobProvider interface {
	AcceptReconcileJob(olderThan time.Duration) (Job, bool)
}

type ReconcileHandler

type ReconcileHandler func(j Job) error

type Reconciler

type Reconciler interface {
	Run() (bool, error)
	Handler(t Type, f ReconcileHandler)
}

func NewReconciler

func NewReconciler(p JobProvider, olderThan time.Duration) Reconciler

type Scheduler

type Scheduler interface {
	Run(n int, d time.Duration) error
}

func NewScheduler

func NewScheduler(r Reconciler) Scheduler

type Type

type Type string