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) GetNewImageInfo(ctx context.Context, previousImageHash string) (*ImageInfo, error)
  • func (f *DeckhouseReleaseFetcher) GetNewReleasesMetadata(ctx context.Context, actual, target *semver.Version) ([]ReleaseMetadata, error)
  • func (f *DeckhouseReleaseFetcher) GetReleaseChannel() string
• type DeckhouseReleaseFetcherConfig
• type ImageInfo
• type MetricsUpdater
• 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,
	moduleManager moduleManager, updateSettings *helpers.DeckhouseSettingsContainer, metricStorage *metricstorage.MetricStorage,
	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) GetNewImageInfo

func (f *DeckhouseReleaseFetcher) GetNewImageInfo(ctx context.Context, previousImageHash string) (*ImageInfo, error)

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

type DeckhouseReleaseFetcherConfig

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

type ImageInfo

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

type MetricsUpdater

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

type ReleaseMetadata

type ReleaseMetadata struct {
	Version      string                    `json:"version"`
	Canary       map[string]canarySettings `json:"canary"`
	Requirements map[string]string         `json:"requirements"`
	Disruptions  map[string][]string       `json:"disruptions"`
	Suspend      bool                      `json:"suspend"`

	Changelog map[string]interface{}

	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
}