upgrader

Documentation

Index

• func New(brokerServices BrokerServices, pollingInterval int, listener Listener) upgrader
• type BrokerServices
• type Listener
  • func NewLoggingListener(logger *log.Logger) Listener
• type LoggingListener
  • func (ll LoggingListener) Finished(orphanCount, upgradedCount, deletedCount int)
  • func (ll LoggingListener) InstanceUpgradeStartResult(resultType services.UpgradeOperationType)
  • func (ll LoggingListener) InstanceUpgradeStarting(instance string, index, totalInstances int)
  • func (ll LoggingListener) InstanceUpgraded(instance string, result string)
  • func (ll LoggingListener) InstancesToUpgrade(instances []string)
  • func (ll LoggingListener) Progress(pollingInterval time.Duration, ...)
  • func (ll LoggingListener) Starting()
  • func (ll LoggingListener) WaitingFor(instance string, boshTaskId int)

Functions

func New

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

Types

type BrokerServices

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

type Listener

type Listener interface {
	Starting()
	InstancesToUpgrade(instances []string)
	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 []string)

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)