source

Documentation

Index

• Variables
• func RegisterController(runtimeManager manager.Manager, mm moduleManager, dc dependency.Container, ...) error
• type ModuleReleaseFetcher
  • func NewDeckhouseReleaseFetcher(cfg *ModuleReleaseFetcherConfig) *ModuleReleaseFetcher
• type ModuleReleaseFetcherConfig

Variables

var ErrSettingsNotChanged = errors.New("settings not changed")

Functions

func RegisterController

func RegisterController(
	runtimeManager manager.Manager,
	mm moduleManager,
	dc dependency.Container,
	metricStorage metric.Storage,
	embeddedPolicy *helpers.ModuleUpdatePolicySpecContainer,
	logger *log.Logger,
) error

Types

type ModuleReleaseFetcher

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

func NewDeckhouseReleaseFetcher

func NewDeckhouseReleaseFetcher(cfg *ModuleReleaseFetcherConfig) *ModuleReleaseFetcher

type ModuleReleaseFetcherConfig

type ModuleReleaseFetcherConfig struct {
	K8sClient                 client.Client
	RegistryClientTagFetcher  cr.Client
	RegistryClientMetaFetcher cr.Client
	Clock                     clockwork.Clock
	ModuleDownloader          *downloader.ModuleDownloader

	ModuleName        string
	TargetReleaseMeta *downloader.ModuleDownloadResult

	Source           *v1alpha1.ModuleSource
	UpdatePolicyName string

	MetricStorage     metric.Storage
	MetricModuleGroup string

	Logger *log.Logger
}