routines

package

v0.0.0-...-da22ec3 Latest Latest Go to latest Published: Dec 16, 2015 License: Apache-2.0 Imports: 8 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Event struct {
	//http status code: 0 means does not affect status code
	Status  int
	Message string
}

type RCScheduler struct {
	Client       *kclient.Client
	Namespace    string
	ReplicaCount int
	// contains filtered or unexported fields
}

func (rcs *RCScheduler) Cleanup() error

func (rcs *RCScheduler) Init() error

func (rcs *RCScheduler) Poll() error

type Routine struct {
	Events <-chan *Event
	// contains filtered or unexported fields
}

func NewRoutine(client *kclient.Client,
	pollInterval time.Duration,
	podTTL time.Duration,
	handler RoutineHandler,
) *Routine

func (r *Routine) SignalTerminate()

func (r *Routine) Start() error

type RoutineHandler interface {
	Init() error
	Poll() error
	Cleanup() error
}