resourcesynccontroller

Documentation

Index

• func CombineCABundleConfigMaps(destinationConfigMap ResourceLocation, lister corev1listers.ConfigMapLister, ...) (*corev1.ConfigMap, error)
• func NewDebugHandler(controller *ResourceSyncController) http.Handler
• type ControllerSyncRules
• type ResourceLocation
• type ResourceSyncController
  • func NewResourceSyncController(operatorConfigClient v1helpers.OperatorClient, ...) *ResourceSyncController
  • func (c *ResourceSyncController) Run(workers int, stopCh <-chan struct{})
  • func (c *ResourceSyncController) SyncConfigMap(destination, source ResourceLocation) error
  • func (c *ResourceSyncController) SyncSecret(destination, source ResourceLocation) error
• type ResourceSyncRule
• type ResourceSyncRuleList
  • func (l ResourceSyncRuleList) Len() int
  • func (l ResourceSyncRuleList) Less(i, j int) bool
  • func (l ResourceSyncRuleList) Swap(i, j int)
• type ResourceSyncer

Functions

func CombineCABundleConfigMaps

func CombineCABundleConfigMaps(destinationConfigMap ResourceLocation, lister corev1listers.ConfigMapLister, inputConfigMaps ...ResourceLocation) (*corev1.ConfigMap, error)

func NewDebugHandler

func NewDebugHandler(controller *ResourceSyncController) http.Handler

Types

type ControllerSyncRules

type ControllerSyncRules struct {
	Secrets ResourceSyncRuleList `json:"secrets"`
	Configs ResourceSyncRuleList `json:"configs"`
}

type ResourceLocation

type ResourceLocation struct {
	Namespace string `json:"namespace"`
	Name      string `json:"name"`
}

ResourceLocation describes coordinates for a resource to be synced

type ResourceSyncController

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

ResourceSyncController is a controller that will copy source configmaps and secrets to their destinations. It will also mirror deletions by deleting destinations.

func NewResourceSyncController

func NewResourceSyncController(
	operatorConfigClient v1helpers.OperatorClient,
	kubeInformersForNamespaces v1helpers.KubeInformersForNamespaces,
	secretsGetter corev1client.SecretsGetter,
	configMapsGetter corev1client.ConfigMapsGetter,
	eventRecorder events.Recorder,
) *ResourceSyncController

NewResourceSyncController creates ResourceSyncController.

func (*ResourceSyncController) Run

func (c *ResourceSyncController) Run(workers int, stopCh <-chan struct{})

func (*ResourceSyncController) SyncConfigMap

func (c *ResourceSyncController) SyncConfigMap(destination, source ResourceLocation) error

func (*ResourceSyncController) SyncSecret

func (c *ResourceSyncController) SyncSecret(destination, source ResourceLocation) error

type ResourceSyncRule

type ResourceSyncRule struct {
	Source      ResourceLocation `json:"source"`
	Destination ResourceLocation `json:"destination"`
}

type ResourceSyncRuleList

type ResourceSyncRuleList []ResourceSyncRule

func (ResourceSyncRuleList) Len

func (l ResourceSyncRuleList) Len() int

func (ResourceSyncRuleList) Less

func (l ResourceSyncRuleList) Less(i, j int) bool

func (ResourceSyncRuleList) Swap

func (l ResourceSyncRuleList) Swap(i, j int)

type ResourceSyncer

type ResourceSyncer interface {
	// SyncConfigMap indicates that a configmap should be copied from the source to the destination.  It will also
	// mirror a deletion from the source.  If the source is a zero object the destination will be deleted.
	SyncConfigMap(destination, source ResourceLocation) error
	// SyncSecret indicates that a secret should be copied from the source to the destination.  It will also
	// mirror a deletion from the source.  If the source is a zero object the destination will be deleted.
	SyncSecret(destination, source ResourceLocation) error
}

ResourceSyncer allows changes to syncing rules by this controller