deckhouse_release

Documentation

Index

• Variables
• func NewDeckhouseReleaseController(ctx context.Context, mgr manager.Manager, dc dependency.Container, ...) error
• type DeckhouseReleaseFetcher
  • func NewDeckhouseReleaseFetcher(cfg *DeckhouseReleaseFetcherConfig) *DeckhouseReleaseFetcher
  • func (f *DeckhouseReleaseFetcher) GetNewReleasesMetadata(ctx context.Context, actual, target *semver.Version) ([]ReleaseMetadata, error)
  • func (f *DeckhouseReleaseFetcher) GetReleaseChannel() string
  • func (f *DeckhouseReleaseFetcher) GetReleaseImageInfo(ctx context.Context, previousImageHash string) (*ReleaseImageInfo, error)
• type DeckhouseReleaseFetcherConfig
• type MetricsUpdater
• type ReleaseImageInfo
• type ReleaseMetadata
  • func (m *ReleaseMetadata) CalculateReleaseDelay(channel string, ts metav1.Time, clusterUUID string) *metav1.Time
  • func (m *ReleaseMetadata) IsCanaryRelease(channel string) bool
• type TimeResult

Variables

var ErrDeploymentContainerIsNotFound = errors.New("deployment container is not found")

var ErrImageIsNil = errors.New("image is nil")

var ErrImageNotChanged = errors.New("image not changed")

var ErrPreApplyCheckIsFailed = errors.New("pre apply check is failed")

Functions

func NewDeckhouseReleaseController

func NewDeckhouseReleaseController(ctx context.Context, mgr manager.Manager, dc dependency.Container, exts *extenders.ExtendersStack,
	moduleManager moduleManager, updateSettings *helpers.DeckhouseSettingsContainer, metricStorage metric.Storage,
	preflightCountDown *sync.WaitGroup, deckhouseVersion string, logger *log.Logger,
) error

Types

type DeckhouseReleaseFetcher

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

func NewDeckhouseReleaseFetcher

func NewDeckhouseReleaseFetcher(cfg *DeckhouseReleaseFetcherConfig) *DeckhouseReleaseFetcher

func (*DeckhouseReleaseFetcher) GetNewReleasesMetadata

func (f *DeckhouseReleaseFetcher) GetNewReleasesMetadata(ctx context.Context, actual, target *semver.Version) ([]ReleaseMetadata, error)

FetchReleasesMetadata realize step by step update

func (*DeckhouseReleaseFetcher) GetReleaseChannel

func (f *DeckhouseReleaseFetcher) GetReleaseChannel() string

func (*DeckhouseReleaseFetcher) GetReleaseImageInfo

func (f *DeckhouseReleaseFetcher) GetReleaseImageInfo(ctx context.Context, previousImageHash string) (*ReleaseImageInfo, error)

GetReleaseImageInfo get Image, Digest and release metadata using imageTag with existing registry client return error if version.json not found in metadata return ErrImageNotChanged with ReleaseImageInfo if image hash matches with previousImageHash

type DeckhouseReleaseFetcherConfig

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

type MetricsUpdater

type MetricsUpdater interface {
	UpdateReleaseMetric(string, releaseUpdater.MetricLabels)
	PurgeReleaseMetric(string)
}

type ReleaseImageInfo

type ReleaseImageInfo struct {
	Metadata *ReleaseMetadata
	Image    registryv1.Image
	Digest   registryv1.Hash
}

type ReleaseMetadata

type ReleaseMetadata struct {
	Version          string                  `json:"version"`
	Changelog        map[string]interface{}  `json:"-"`
	ModuleDefinition *moduletypes.Definition `json:"module,omitempty"`

	// TODO: review fields below. it can be useless now
	Canary       map[string]canarySettings `json:"canary"`
	Requirements map[string]string         `json:"requirements"`
	Disruptions  map[string][]string       `json:"disruptions"`
	Suspend      bool                      `json:"suspend"`
	Cooldown     *metav1.Time              `json:"-"`
}

func (*ReleaseMetadata) CalculateReleaseDelay

func (m *ReleaseMetadata) CalculateReleaseDelay(channel string, ts metav1.Time, clusterUUID string) *metav1.Time

https://github.com/deckhouse/deckhouse/issues/332

func (*ReleaseMetadata) IsCanaryRelease

func (m *ReleaseMetadata) IsCanaryRelease(channel string) bool

type TimeResult

type TimeResult struct {
	*releaseUpdater.ProcessedDeployTimeResult
	Notified bool
}