generator

Documentation

Overview

generator creates operations for container processing

Index

• type ContainerOperation
  • func NewContainerOperation(logger lager.Logger, traceID string, lrpProcessor internal.LRPProcessor, ...) *ContainerOperation
  • func (o *ContainerOperation) Execute()
  • func (o *ContainerOperation) Key() string
• type Generator
  • func New(cellID string, availabilityZone string, stackPathMap rep.StackPathMap, ...) Generator
• type ResidualEvacuatingLRPOperation
  • func NewResidualEvacuatingLRPOperation(logger lager.Logger, traceID string, bbsClient bbs.InternalClient, ...) *ResidualEvacuatingLRPOperation
  • func (o *ResidualEvacuatingLRPOperation) Execute()
  • func (o *ResidualEvacuatingLRPOperation) Key() string
• type ResidualInstanceLRPOperation
  • func NewResidualInstanceLRPOperation(logger lager.Logger, traceID string, bbsClient bbs.InternalClient, ...) *ResidualInstanceLRPOperation
  • func (o *ResidualInstanceLRPOperation) Execute()
  • func (o *ResidualInstanceLRPOperation) Key() string
• type ResidualJointLRPOperation
  • func NewResidualJointLRPOperation(logger lager.Logger, traceID string, bbsClient bbs.InternalClient, ...) *ResidualJointLRPOperation
  • func (o *ResidualJointLRPOperation) Execute()
  • func (o *ResidualJointLRPOperation) Key() string
• type ResidualTaskOperation
  • func NewResidualTaskOperation(logger lager.Logger, traceID string, taskGuid string, cellId string, ...) *ResidualTaskOperation
  • func (o *ResidualTaskOperation) Execute()
  • func (o *ResidualTaskOperation) Key() string

Types

type ContainerOperation

type ContainerOperation struct {
	Guid string
	// contains filtered or unexported fields
}

ContainerOperation acquires the current state of a container and performs any bbs or container operations necessary to harmonize the state of the world.

func NewContainerOperation

func NewContainerOperation(
	logger lager.Logger,
	traceID string,
	lrpProcessor internal.LRPProcessor,
	taskProcessor internal.TaskProcessor,
	containerDelegate internal.ContainerDelegate,
	guid string,
) *ContainerOperation

func (*ContainerOperation) Execute

func (o *ContainerOperation) Execute()

func (*ContainerOperation) Key

func (o *ContainerOperation) Key() string

type Generator

type Generator interface {
	// BatchOperations creates a set of operations across all containers the Rep is managing.
	BatchOperations(lager.Logger) (map[string]operationq.Operation, error)

	// OperationStream creates an operation every time a container lifecycle event is observed.
	OperationStream(lager.Logger) (<-chan operationq.Operation, error)
}

Generator encapsulates operation creation in the Rep.

func New

func New(
	cellID string,
	availabilityZone string,
	stackPathMap rep.StackPathMap,
	layeringMode string,
	bbs bbs.InternalClient,
	executorClient executor.Client,
	metronClient loggingclient.IngressClient,
	evacuationReporter evacuation_context.EvacuationReporter,
) Generator

type ResidualEvacuatingLRPOperation

type ResidualEvacuatingLRPOperation struct {
	models.ActualLRPKey
	models.ActualLRPInstanceKey
	// contains filtered or unexported fields
}

ResidualEvacuatingLRPOperation processes an evacuating ActualLRP with no matching container.

func NewResidualEvacuatingLRPOperation

func NewResidualEvacuatingLRPOperation(logger lager.Logger,
	traceID string,
	bbsClient bbs.InternalClient,
	containerDelegate internal.ContainerDelegate,
	lrpKey models.ActualLRPKey,
	instanceKey models.ActualLRPInstanceKey,
) *ResidualEvacuatingLRPOperation

func (*ResidualEvacuatingLRPOperation) Execute

func (o *ResidualEvacuatingLRPOperation) Execute()

func (*ResidualEvacuatingLRPOperation) Key

func (o *ResidualEvacuatingLRPOperation) Key() string

type ResidualInstanceLRPOperation

type ResidualInstanceLRPOperation struct {
	models.ActualLRPKey
	models.ActualLRPInstanceKey
	// contains filtered or unexported fields
}

ResidualInstanceLRPOperation processes an instance ActualLRP with no matching container.

func NewResidualInstanceLRPOperation

func NewResidualInstanceLRPOperation(logger lager.Logger,
	traceID string,
	bbsClient bbs.InternalClient,
	containerDelegate internal.ContainerDelegate,
	lrpKey models.ActualLRPKey,
	instanceKey models.ActualLRPInstanceKey,
) *ResidualInstanceLRPOperation

func (*ResidualInstanceLRPOperation) Execute

func (o *ResidualInstanceLRPOperation) Execute()

func (*ResidualInstanceLRPOperation) Key

func (o *ResidualInstanceLRPOperation) Key() string

type ResidualJointLRPOperation

type ResidualJointLRPOperation struct {
	models.ActualLRPKey
	models.ActualLRPInstanceKey
	// contains filtered or unexported fields
}

ResidualJointLRPOperation processes an evacuating ActualLRP with no matching container.

func NewResidualJointLRPOperation

func NewResidualJointLRPOperation(logger lager.Logger,
	traceID string,
	bbsClient bbs.InternalClient,
	containerDelegate internal.ContainerDelegate,
	lrpKey models.ActualLRPKey,
	instanceKey models.ActualLRPInstanceKey,
) *ResidualJointLRPOperation

func (*ResidualJointLRPOperation) Execute

func (o *ResidualJointLRPOperation) Execute()

func (*ResidualJointLRPOperation) Key

func (o *ResidualJointLRPOperation) Key() string

type ResidualTaskOperation

type ResidualTaskOperation struct {
	TaskGuid string
	CellId   string
	// contains filtered or unexported fields
}

ResidualTaskOperation processes a Task with no matching container.

func NewResidualTaskOperation

func NewResidualTaskOperation(
	logger lager.Logger,
	traceID string,
	taskGuid string,
	cellId string,
	bbsClient bbs.InternalClient,
	containerDelegate internal.ContainerDelegate,
) *ResidualTaskOperation

func (*ResidualTaskOperation) Execute

func (o *ResidualTaskOperation) Execute()

func (*ResidualTaskOperation) Key

func (o *ResidualTaskOperation) Key() string