release

Documentation

Index

• func ApplyChanges(rc *ReleaseContext, updates []*update.ControllerUpdate, logger log.Logger) error
• func Release(rc *ReleaseContext, changes Changes, logger log.Logger) (results update.Result, err error)
• type Changes
• type ReleaseContext
  • func NewReleaseContext(c cluster.Cluster, m cluster.Manifests, reg registry.Registry, ...) *ReleaseContext
  • func (rc *ReleaseContext) FindDefinedServices() (map[flux.ResourceID]*update.ControllerUpdate, error)
  • func (rc *ReleaseContext) Manifests() cluster.Manifests
  • func (rc *ReleaseContext) Registry() registry.Registry
  • func (rc *ReleaseContext) SelectServices(results update.Result, prefilters, postfilters []update.ControllerFilter) ([]*update.ControllerUpdate, error)
  • func (rc *ReleaseContext) ServicesWithPolicies() (policy.ResourceMap, error)
  • func (rc *ReleaseContext) WriteUpdates(updates []*update.ControllerUpdate) error

Functions

func ApplyChanges

func ApplyChanges(rc *ReleaseContext, updates []*update.ControllerUpdate, logger log.Logger) error

func Release

func Release(rc *ReleaseContext, changes Changes, logger log.Logger) (results update.Result, err error)

Types

type Changes

type Changes interface {
	CalculateRelease(update.ReleaseContext, log.Logger) ([]*update.ControllerUpdate, update.Result, error)
	ReleaseKind() update.ReleaseKind
	ReleaseType() update.ReleaseType
	CommitMessage() string
}

type ReleaseContext

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

func NewReleaseContext

func NewReleaseContext(c cluster.Cluster, m cluster.Manifests, reg registry.Registry, repo *git.Checkout) *ReleaseContext

func (*ReleaseContext) FindDefinedServices

func (rc *ReleaseContext) FindDefinedServices() (map[flux.ResourceID]*update.ControllerUpdate, error)

func (*ReleaseContext) Manifests

func (rc *ReleaseContext) Manifests() cluster.Manifests

func (*ReleaseContext) Registry

func (rc *ReleaseContext) Registry() registry.Registry

func (*ReleaseContext) SelectServices

func (rc *ReleaseContext) SelectServices(results update.Result, prefilters, postfilters []update.ControllerFilter) ([]*update.ControllerUpdate, error)

SelectServices finds the services that exist both in the definition files and the running platform. `ControllerFilter`s can be provided to filter the controllers so found, either before (`prefilters`) or after (`postfilters`) consulting the cluster.

func (*ReleaseContext) ServicesWithPolicies

func (rc *ReleaseContext) ServicesWithPolicies() (policy.ResourceMap, error)

Shortcut for this

func (*ReleaseContext) WriteUpdates

func (rc *ReleaseContext) WriteUpdates(updates []*update.ControllerUpdate) error