client

package
v1.3.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 16, 2022 License: MIT Imports: 17 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func AnnotationsAreEqual added in v1.1.0 

func AnnotationsAreEqual(a, b map[string]string) bool

func CopyAnnotations added in v1.1.0 

func CopyAnnotations(m map[string]string) map[string]string

func IsManagedBy added in v1.1.0 

func IsManagedBy(secret *v1.Secret) bool

func Manage added in v1.3.0 

func Manage(m map[string]string) map[string]string

func OwnerReference added in v1.3.0 

func OwnerReference(rule *typesv1.SecretSyncRule) metav1.OwnerReference

func PrepareSecret added in v1.1.0 

func PrepareSecret(rule *typesv1.SecretSyncRule, namespace *v1.Namespace, secret *v1.Secret) *v1.Secret

func SecretsAreEqual added in v1.1.0 

func SecretsAreEqual(a, b *v1.Secret) bool

func SyncSecrets 

func SyncSecrets(config *SyncConfig) (err error)

SyncSecrets syncs Secrets across all selected Namespaces

Types

type Client added in v1.0.0 

type Client struct {
	SyncConfig    *SyncConfig
	ClusterConfig *rest.Config
	Context       context.Context
	StartTime     time.Time

	DefaultClientset        kubernetes.Interface
	KubeSecretSyncClientset *kssclientset.KubeSecretSyncClientset

	SecretWatcher         watch.Interface
	NamespaceWatcher      watch.Interface
	SecretSyncRuleWatcher watch.Interface
	SignalChannel         chan os.Signal
}

func (*Client) AddedNamespaceHandler added in v1.0.0 

func (client *Client) AddedNamespaceHandler(namespace *v1.Namespace) error

func (*Client) AddedSecretHandler added in v1.0.0 

func (client *Client) AddedSecretHandler(secret *v1.Secret) error

func (*Client) AddedSecretSyncRuleHandler added in v1.0.0 

func (client *Client) AddedSecretSyncRuleHandler(rule *typesv1.SecretSyncRule) error

func (*Client) CreateSecret added in v1.0.0 

func (client *Client) CreateSecret(rule *typesv1.SecretSyncRule, namespace *v1.Namespace, secret *v1.Secret) error

func (*Client) CreateUpdateSecret added in v1.0.0 

func (client *Client) CreateUpdateSecret(rule *typesv1.SecretSyncRule, namespace *v1.Namespace, secret *v1.Secret) error

func (*Client) DeleteSecret added in v1.0.0 

func (client *Client) DeleteSecret(namespace *v1.Namespace, secret *v1.Secret) (err error)

func (*Client) DeletedSecretHandler added in v1.0.0 

func (client *Client) DeletedSecretHandler(secret *v1.Secret) error

func (*Client) DeletedSecretSyncRuleHandler added in v1.0.0 

func (client *Client) DeletedSecretSyncRuleHandler(rule *typesv1.SecretSyncRule) error

func (*Client) GetSecret added in v1.0.0 

func (client *Client) GetSecret(namespace, name string) (secret *v1.Secret, err error)

func (*Client) Initialize added in v1.0.0 

func (client *Client) Initialize(config *SyncConfig) error

func (*Client) InitializeClientsets added in v1.0.0 

func (client *Client) InitializeClientsets() error

func (*Client) InitializeClusterConfig added in v1.0.0 

func (client *Client) InitializeClusterConfig() (err error)

func (*Client) InitializeDefault added in v1.0.0 

func (client *Client) InitializeDefault() (err error)

func (*Client) InitializeKubeSecretSync added in v1.0.0 

func (client *Client) InitializeKubeSecretSync() (err error)

func (*Client) InitializeSignalChannel added in v1.0.0 

func (client *Client) InitializeSignalChannel()

func (*Client) InitializeWatchers added in v1.0.0 

func (client *Client) InitializeWatchers() (err error)

func (*Client) ListNamespaces added in v1.0.0 

func (client *Client) ListNamespaces() (namespaces *v1.NamespaceList, err error)

func (*Client) ListSecretSyncRules added in v1.0.0 

func (client *Client) ListSecretSyncRules() (rules *typesv1.SecretSyncRuleList, err error)

func (*Client) ListSecrets added in v1.0.0 

func (client *Client) ListSecrets(namespace string) (list *v1.SecretList, err error)

func (*Client) ModifiedSecretHandler added in v1.0.0 

func (client *Client) ModifiedSecretHandler(secret *v1.Secret) error

func (*Client) ModifiedSecretSyncRuleHandler added in v1.0.0 

func (client *Client) ModifiedSecretSyncRuleHandler(rule *typesv1.SecretSyncRule) error

modifiedSecretSyncRuleHandler handles syncing secrets after a SecretSyncRule has been modified

Due to the event watcher only providing the new state of the modified resource, it is impossible to know the previous state. (The exception to this is potentially "applied" changes and parsing the last-applied-configuration annotation) In coping with this limitation, a modified SecretSyncRule will simply attempt to resync the rule across all applicable namespaces.

func (*Client) NamespaceEventHandler added in v1.0.0 

func (client *Client) NamespaceEventHandler(event watch.Event) error

func (*Client) SecretEventHandler added in v1.0.0 

func (client *Client) SecretEventHandler(event watch.Event) error

func (*Client) SecretSyncRuleEventHandler added in v1.0.0 

func (client *Client) SecretSyncRuleEventHandler(event watch.Event) error

func (*Client) StartNamespaceWatcher added in v1.0.0 

func (client *Client) StartNamespaceWatcher() (err error)

func (*Client) StartSecretSyncRuleWatcher added in v1.0.0 

func (client *Client) StartSecretSyncRuleWatcher() (err error)

func (*Client) StartSecretWatcher added in v1.0.0 

func (client *Client) StartSecretWatcher() (err error)

func (*Client) SyncAddedModifiedSecret added in v1.0.0 

func (client *Client) SyncAddedModifiedSecret(secret *v1.Secret) error

func (*Client) SyncDeletedSecret added in v1.0.0 

func (client *Client) SyncDeletedSecret(rules typesv1.Rules, namespace *v1.Namespace, secret *v1.Secret) error

func (*Client) SyncNamespace added in v1.0.0 

func (client *Client) SyncNamespace(namespace *v1.Namespace) error

func (*Client) SyncSecretToNamespace added in v1.0.0 

func (client *Client) SyncSecretToNamespace(rule *typesv1.SecretSyncRule, namespace *v1.Namespace) error

func (*Client) UpdateSecret added in v1.0.0 

func (client *Client) UpdateSecret(rule *typesv1.SecretSyncRule, namespace *v1.Namespace, secret *v1.Secret) (err error)

type SyncConfig 

type SyncConfig struct {
	PodNamespace string

	OutOfCluster bool
	KubeConfig   string
}

SyncConfig contains the configuration options for the SyncSecrets operation.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.
OSZAR »