package controller

import "k8s.io/apiserver/pkg/server/options/encryptionconfig/controller"

Index ¶

• Variables
• type DynamicEncryptionConfigContent
• func NewDynamicEncryptionConfiguration( name, filePath string, dynamicTransformers *encryptionconfig.DynamicTransformers, configContentHash string, apiServerID string, ) *DynamicEncryptionConfigContent
• func (d *DynamicEncryptionConfigContent) Run(ctx context.Context)

Variables ¶

var EncryptionConfigFileChangePollDuration = time.Minute

EncryptionConfigFileChangePollDuration is exposed so that integration tests can crank up the reload speed.

Types ¶

type DynamicEncryptionConfigContent ¶

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

DynamicEncryptionConfigContent which can dynamically handle changes in encryption config file.

func NewDynamicEncryptionConfiguration ¶

func NewDynamicEncryptionConfiguration(
	name, filePath string,
	dynamicTransformers *encryptionconfig.DynamicTransformers,
	configContentHash string,
	apiServerID string,
) *DynamicEncryptionConfigContent

NewDynamicEncryptionConfiguration returns controller that dynamically reacts to changes in encryption config file.

func (*DynamicEncryptionConfigContent) Run ¶

func (d *DynamicEncryptionConfigContent) Run(ctx context.Context)

Run starts the controller and blocks until ctx is canceled.

Source Files ¶

controller.go