upgrader

package
v0.19.0 Latest Latest
Warning

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

Go to latest
Published: Nov 30, 2017 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func New

func New(brokerServices BrokerServices, instanceLister InstanceLister, pollingInterval int, listener Listener) upgrader

Types

type BrokerServices

type BrokerServices interface {
	UpgradeInstance(instance service.Instance) (services.UpgradeOperation, error)
	LastOperation(instance string, operationData broker.OperationData) (brokerapi.LastOperation, error)
}

type InstanceLister added in v0.18.0

type InstanceLister interface {
	Instances() ([]service.Instance, error)
}

type Listener

type Listener interface {
	Starting()
	InstancesToUpgrade(instances []service.Instance)
	InstanceUpgradeStarting(instance string, index, totalInstances int)
	InstanceUpgradeStartResult(status services.UpgradeOperationType)
	InstanceUpgraded(instance string, result string)
	WaitingFor(instance string, boshTaskId int)
	Progress(pollingInterval time.Duration, orphanCount, upgradedCount, upgradesLeftCount, deletedCount int)
	Finished(orphanCount, upgradedCount, deletedCount int)
}

func NewLoggingListener

func NewLoggingListener(logger *log.Logger) Listener

type LoggingListener

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

func (LoggingListener) Finished

func (ll LoggingListener) Finished(orphanCount, upgradedCount, deletedCount int)

func (LoggingListener) InstanceUpgradeStartResult

func (ll LoggingListener) InstanceUpgradeStartResult(resultType services.UpgradeOperationType)

func (LoggingListener) InstanceUpgradeStarting

func (ll LoggingListener) InstanceUpgradeStarting(instance string, index, totalInstances int)

func (LoggingListener) InstanceUpgraded

func (ll LoggingListener) InstanceUpgraded(instance string, result string)

func (LoggingListener) InstancesToUpgrade

func (ll LoggingListener) InstancesToUpgrade(instances []service.Instance)

func (LoggingListener) Progress

func (ll LoggingListener) Progress(pollingInterval time.Duration, orphanCount, upgradedCount, toRetryCount, deletedCount int)

func (LoggingListener) Starting

func (ll LoggingListener) Starting()

func (LoggingListener) WaitingFor

func (ll LoggingListener) WaitingFor(instance string, boshTaskId int)

Directories

Path Synopsis
Code generated by counterfeiter.
Code generated by counterfeiter.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL