globalhubcontroller

Documentation

Index

• Constants
• func AddControllers(dynamicClient dynamic.Interface, stopChan <-chan struct{})
• func InstallGlobalHubCRDs(dynamicClient dynamic.Interface) error
• type ClusterSummary
• type ComplianceSummary
• type GenericController
  • func NewGenericController(stopChannel <-chan struct{}, client dynamic.Interface, ...) *GenericController
  • func (c *GenericController) Run(numThreads int)
• type IController
  • func NewPlacementBindingController(dynamicClient dynamic.Interface) IController
  • func NewPlacementRuleController(dynamicClient dynamic.Interface) IController
  • func NewPolicyController(dynamicClient dynamic.Interface) IController
• type IGenericController

Constants

const GlobalHubPolicyNamespaceLabel = "global-hub.open-cluster-management.io/original-namespace"

Functions

func AddControllers

func AddControllers(dynamicClient dynamic.Interface, stopChan <-chan struct{})

func InstallGlobalHubCRDs

func InstallGlobalHubCRDs(dynamicClient dynamic.Interface) error

Types

type ClusterSummary

type ClusterSummary struct {
	Name         string `json:"name,omitempty"`
	Compliant    uint32 `json:"compliant,omitempty"`
	NonCompliant uint32 `json:"noncompliant,omitempty"`
}

type ComplianceSummary

type ComplianceSummary struct {
	Compliant    uint32           `json:"compliant,omitempty"`
	NonCompliant uint32           `json:"noncompliant,omitempty"`
	Summaries    []ClusterSummary `json:"summaries,omitempty"`
}

ComplianceSummary ComplianceSummary `json:"complianceSummary,omitempty"` // used by global policy

type GenericController

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

func NewGenericController

func NewGenericController(stopChannel <-chan struct{}, client dynamic.Interface, informerFactory dynamicinformer.DynamicSharedInformerFactory, controller IController) *GenericController

func (*GenericController) Run

func (c *GenericController) Run(numThreads int)

type IController

type IController interface {
	GetName() string
	GetGVR() schema.GroupVersionResource
	CreateInstanceFunc() func() client.Object
	ReconcileFunc() func(stopCh <-chan struct{}, obj interface{}) error
}

func NewPlacementBindingController

func NewPlacementBindingController(dynamicClient dynamic.Interface) IController

func NewPlacementRuleController

func NewPlacementRuleController(dynamicClient dynamic.Interface) IController

func NewPolicyController

func NewPolicyController(dynamicClient dynamic.Interface) IController

type IGenericController

type IGenericController interface {
	// Start starts N worker processes processing work items.
	Run(numThreads int)
}