base

package
v1.5.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 18, 2018 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	BASE_DELAY               = 5 * time.Second
	MAX_DELAY                = 300 * time.Second
	KLUSTER_RECHECK_INTERVAL = 5 * time.Minute
)

Variables

View Source 
var ErrUnkownKluster = errors.New("unknown kluster")
View Source 
var RECONCILLIATION_COUNTER = 0

Functions

This section is empty.

Types

type Controller 

type Controller interface {
	Run(int, <-chan struct{}, *sync.WaitGroup)
}

func NewController 

func NewController(factories config.Factories, clients config.Clients, reconciler Reconciler, logger log.Logger) Controller

type InstrumentingReconciler 

type InstrumentingReconciler struct {
	Reconciler

	Latency    *prometheus.SummaryVec
	Total      *prometheus.CounterVec
	Successful *prometheus.CounterVec
	Failed     *prometheus.CounterVec
}

func (*InstrumentingReconciler) Reconcile 

func (ir *InstrumentingReconciler) Reconcile(kluster *v1.Kluster) (requeue bool, err error)

type LoggingReconciler 

type LoggingReconciler struct {
	Reconciler Reconciler
	Logger     log.Logger
}

func (*LoggingReconciler) Reconcile 

func (r *LoggingReconciler) Reconcile(kluster *v1.Kluster) (requeue bool, err error)

type Reconciler 

type Reconciler interface {
	Reconcile(kluster *v1.Kluster) (bool, error)
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.