batch

Documentation

Index

• func NewPriorityManager(config PriorityManagerConfig) (manage.ResourceManager, error)
• type PriorityManagerConfig

Functions

func NewPriorityManager

func NewPriorityManager(config PriorityManagerConfig) (manage.ResourceManager, error)

NewPriorityManager returns a batch func that batches the resources by priority. If priorities enabled (default), batchManager will manage `apply` state resources (not on `deletes`) in sorted batches of priority, priorities can be set using group configuration.

Types

type PriorityManagerConfig

type PriorityManagerConfig struct {
	// DisablePriorities will disable batching by priorities.
	DisablePriorities bool
	// Manager is the original manager used to apply and delete.
	Manager         manage.ResourceManager
	GroupRepository storage.GroupRepository
	Logger          log.Logger
}

PriorityManagerConfig is the configuration of the priority batch manager.