controllers

Documentation

Index

• type AssetConfig
• type AssetGroupConfig
• type AssetGroupReconciler
  • func NewAssetGroup(config AssetGroupConfig, log logr.Logger, mgr ctrl.Manager, ...) *AssetGroupReconciler
  • func (r *AssetGroupReconciler) Reconcile(req ctrl.Request) (ctrl.Result, error)
  • func (r *AssetGroupReconciler) SetupWithManager(mgr ctrl.Manager) error
• type AssetReconciler
  • func NewAsset(config AssetConfig, log logr.Logger, di *Container) *AssetReconciler
  • func (r *AssetReconciler) Reconcile(request ctrl.Request) (ctrl.Result, error)
  • func (r *AssetReconciler) SetupWithManager(mgr ctrl.Manager) error
• type BucketConfig
• type BucketReconciler
  • func NewBucket(config BucketConfig, log logr.Logger, di *Container) *BucketReconciler
  • func (r *BucketReconciler) Reconcile(request ctrl.Request) (ctrl.Result, error)
  • func (r *BucketReconciler) SetupWithManager(mgr ctrl.Manager) error
• type ClusterAssetConfig
• type ClusterAssetGroupConfig
• type ClusterAssetGroupReconciler
  • func NewClusterAssetGroup(config ClusterAssetGroupConfig, log logr.Logger, mgr ctrl.Manager, ...) *ClusterAssetGroupReconciler
  • func (r *ClusterAssetGroupReconciler) Reconcile(req ctrl.Request) (ctrl.Result, error)
  • func (r *ClusterAssetGroupReconciler) SetupWithManager(mgr ctrl.Manager) error
• type ClusterAssetReconciler
  • func NewClusterAsset(config ClusterAssetConfig, log logr.Logger, di *Container) *ClusterAssetReconciler
  • func (r *ClusterAssetReconciler) Reconcile(request ctrl.Request) (ctrl.Result, error)
  • func (r *ClusterAssetReconciler) SetupWithManager(mgr ctrl.Manager) error
• type ClusterBucketConfig
• type ClusterBucketReconciler
  • func NewClusterBucket(config ClusterBucketConfig, log logr.Logger, di *Container) *ClusterBucketReconciler
  • func (r *ClusterBucketReconciler) Reconcile(request ctrl.Request) (ctrl.Result, error)
  • func (r *ClusterBucketReconciler) SetupWithManager(mgr ctrl.Manager) error
• type Container

Types

type AssetConfig

type AssetConfig struct {
	MaxConcurrentReconciles int           `envconfig:"default=1"`
	RelistInterval          time.Duration `envconfig:"default=30s"`
}

type AssetGroupConfig

type AssetGroupConfig struct {
	RelistInterval time.Duration `envconfig:"default=5m"`
	BucketRegion   string        `envconfig:"-"`
}

type AssetGroupReconciler

type AssetGroupReconciler struct {
	client.Client
	Log logr.Logger
	// contains filtered or unexported fields
}

AssetGroupReconciler reconciles a AssetGroup object

func NewAssetGroup

func NewAssetGroup(config AssetGroupConfig, log logr.Logger, mgr ctrl.Manager, webhookConfigSvc webhookconfig.AssetWebhookConfigService) *AssetGroupReconciler

func (*AssetGroupReconciler) Reconcile

func (r *AssetGroupReconciler) Reconcile(req ctrl.Request) (ctrl.Result, error)

func (*AssetGroupReconciler) SetupWithManager

func (r *AssetGroupReconciler) SetupWithManager(mgr ctrl.Manager) error

type AssetReconciler

type AssetReconciler struct {
	client.Client
	Log logr.Logger
	// contains filtered or unexported fields
}

AssetReconciler reconciles a Asset object

func NewAsset

func NewAsset(config AssetConfig, log logr.Logger, di *Container) *AssetReconciler

func (*AssetReconciler) Reconcile

func (r *AssetReconciler) Reconcile(request ctrl.Request) (ctrl.Result, error)

func (*AssetReconciler) SetupWithManager

func (r *AssetReconciler) SetupWithManager(mgr ctrl.Manager) error

type BucketConfig

type BucketConfig struct {
	MaxConcurrentReconciles int           `envconfig:"default=1"`
	RelistInterval          time.Duration `envconfig:"default=30s"`
	ExternalEndpoint        string        `envconfig:"-"`
}

type BucketReconciler

type BucketReconciler struct {
	client.Client
	Log logr.Logger
	// contains filtered or unexported fields
}

BucketReconciler reconciles a Bucket object

func NewBucket

func NewBucket(config BucketConfig, log logr.Logger, di *Container) *BucketReconciler

func (*BucketReconciler) Reconcile

func (r *BucketReconciler) Reconcile(request ctrl.Request) (ctrl.Result, error)

func (*BucketReconciler) SetupWithManager

func (r *BucketReconciler) SetupWithManager(mgr ctrl.Manager) error

type ClusterAssetConfig

type ClusterAssetConfig struct {
	MaxConcurrentReconciles int           `envconfig:"default=1"`
	RelistInterval          time.Duration `envconfig:"default=30s"`
}

type ClusterAssetGroupConfig

type ClusterAssetGroupConfig struct {
	RelistInterval time.Duration `envconfig:"default=5m"`
	BucketRegion   string        `envconfig:"-"`
}

type ClusterAssetGroupReconciler

type ClusterAssetGroupReconciler struct {
	client.Client
	Log logr.Logger
	// contains filtered or unexported fields
}

ClusterAssetGroupReconciler reconciles a ClusterAssetGroup object

func NewClusterAssetGroup

func NewClusterAssetGroup(config ClusterAssetGroupConfig, log logr.Logger, mgr ctrl.Manager, webhookConfigSvc webhookconfig.AssetWebhookConfigService) *ClusterAssetGroupReconciler

func (*ClusterAssetGroupReconciler) Reconcile

func (r *ClusterAssetGroupReconciler) Reconcile(req ctrl.Request) (ctrl.Result, error)

func (*ClusterAssetGroupReconciler) SetupWithManager

func (r *ClusterAssetGroupReconciler) SetupWithManager(mgr ctrl.Manager) error

type ClusterAssetReconciler

type ClusterAssetReconciler struct {
	client.Client
	Log logr.Logger
	// contains filtered or unexported fields
}

ClusterAssetReconciler reconciles a ClusterAsset object

func NewClusterAsset

func NewClusterAsset(config ClusterAssetConfig, log logr.Logger, di *Container) *ClusterAssetReconciler

func (*ClusterAssetReconciler) Reconcile

func (r *ClusterAssetReconciler) Reconcile(request ctrl.Request) (ctrl.Result, error)

func (*ClusterAssetReconciler) SetupWithManager

func (r *ClusterAssetReconciler) SetupWithManager(mgr ctrl.Manager) error

type ClusterBucketConfig

type ClusterBucketConfig struct {
	MaxConcurrentReconciles int           `envconfig:"default=1"`
	RelistInterval          time.Duration `envconfig:"default=30s"`
	ExternalEndpoint        string        `envconfig:"-"`
}

type ClusterBucketReconciler

type ClusterBucketReconciler struct {
	client.Client
	Log logr.Logger
	// contains filtered or unexported fields
}

ClusterBucketReconciler reconciles a ClusterBucket object

func NewClusterBucket

func NewClusterBucket(config ClusterBucketConfig, log logr.Logger, di *Container) *ClusterBucketReconciler

func (*ClusterBucketReconciler) Reconcile

func (r *ClusterBucketReconciler) Reconcile(request ctrl.Request) (ctrl.Result, error)

func (*ClusterBucketReconciler) SetupWithManager

func (r *ClusterBucketReconciler) SetupWithManager(mgr ctrl.Manager) error

type Container

type Container struct {
	Manager   ctrl.Manager
	Store     store.Store
	Loader    loader.Loader
	Validator assethook.Validator
	Mutator   assethook.Mutator
	Extractor assethook.MetadataExtractor
}