backend

Documentation

Index

• Constants
• func FetchSecret(ctx context.Context, cli client.Client, name types.NamespacedName) (*v1.Secret, error)
• type DestSyncer
• type KubernetesSecretSource
  • func (s *KubernetesSecretSource) Retrieve(ctx context.Context) (*v1.Secret, error)
  • func (s *KubernetesSecretSource) Setup(ctx context.Context) error
• type NamespacesDest
  • func (d *NamespacesDest) Cleanup(ctx context.Context) error
  • func (d *NamespacesDest) Setup(ctx context.Context) error
  • func (d *NamespacesDest) Sync(ctx context.Context, secret *v1.Secret) error
• type SecretMirrorBackend
  • func MakeSecretMirrorBackend(cli client.Client, recorder record.EventRecorder, nsKeeper *nskeeper.NSKeeper, ...) (*SecretMirrorBackend, error)
  • func (b *SecretMirrorBackend) Cleanup()
  • func (b *SecretMirrorBackend) Init(ctx context.Context, name types.NamespacedName) (*SecretMirrorContext, error)
  • func (b *SecretMirrorBackend) SetupWithManager(mgr ctrl.Manager) (*ctrl.Builder, error)
• type SecretMirrorContext
  • func (c *SecretMirrorContext) Init(ctx context.Context, name types.NamespacedName) error
  • func (c *SecretMirrorContext) SetStatus(ctx context.Context, status mirrorsv1alpha2.MirrorStatus) error
  • func (c *SecretMirrorContext) SetupOrRunFinalizer(ctx context.Context) (bool, error)
  • func (c *SecretMirrorContext) Sync(ctx context.Context) error
• type SourceRetriever
• type VaultBackend
• type VaultBackendMakerFunc
• type VaultSecretDest
  • func (d *VaultSecretDest) Cleanup(ctx context.Context) error
  • func (d *VaultSecretDest) Setup(ctx context.Context) error
  • func (d *VaultSecretDest) Sync(ctx context.Context, secret *v1.Secret) error
• type VaultSecretSource
  • func (s *VaultSecretSource) Retrieve(ctx context.Context) (*v1.Secret, error)
  • func (s *VaultSecretSource) Setup(ctx context.Context) error

Constants

const (
	DefaultWorkerPoolSize = 100
)

Functions

func FetchSecret

func FetchSecret(ctx context.Context, cli client.Client, name types.NamespacedName) (*v1.Secret, error)

Types

type DestSyncer

type DestSyncer interface {
	Setup(ctx context.Context) error
	Sync(ctx context.Context, secret *v1.Secret) error
	Cleanup(ctx context.Context) error
}

type KubernetesSecretSource

type KubernetesSecretSource struct {
	client.Client
	Name types.NamespacedName
}

func (*KubernetesSecretSource) Retrieve

func (s *KubernetesSecretSource) Retrieve(ctx context.Context) (*v1.Secret, error)

func (*KubernetesSecretSource) Setup

func (s *KubernetesSecretSource) Setup(ctx context.Context) error

type NamespacesDest

type NamespacesDest struct {
	client.Client
	record.EventRecorder
	// contains filtered or unexported fields
}

func (*NamespacesDest) Cleanup

func (d *NamespacesDest) Cleanup(ctx context.Context) error

func (*NamespacesDest) Setup

func (d *NamespacesDest) Setup(ctx context.Context) error

func (*NamespacesDest) Sync

func (d *NamespacesDest) Sync(ctx context.Context, secret *v1.Secret) error

type SecretMirrorBackend

type SecretMirrorBackend struct {
	client.Client
	Recorder record.EventRecorder
	// contains filtered or unexported fields
}

func MakeSecretMirrorBackend

func MakeSecretMirrorBackend(cli client.Client, recorder record.EventRecorder, nsKeeper *nskeeper.NSKeeper, vaultBackendMaker VaultBackendMakerFunc) (*SecretMirrorBackend, error)

func (*SecretMirrorBackend) Cleanup

func (b *SecretMirrorBackend) Cleanup()

func (*SecretMirrorBackend) Init

func (b *SecretMirrorBackend) Init(ctx context.Context, name types.NamespacedName) (*SecretMirrorContext, error)

func (*SecretMirrorBackend) SetupWithManager

func (b *SecretMirrorBackend) SetupWithManager(mgr ctrl.Manager) (*ctrl.Builder, error)

type SecretMirrorContext

type SecretMirrorContext struct {
	SecretMirror *mirrorsv1alpha2.SecretMirror
	// contains filtered or unexported fields
}

func (*SecretMirrorContext) Init

func (c *SecretMirrorContext) Init(ctx context.Context, name types.NamespacedName) error

func (*SecretMirrorContext) SetStatus

func (c *SecretMirrorContext) SetStatus(ctx context.Context, status mirrorsv1alpha2.MirrorStatus) error

func (*SecretMirrorContext) SetupOrRunFinalizer

func (c *SecretMirrorContext) SetupOrRunFinalizer(ctx context.Context) (bool, error)

SetupOrRunFinalizer returns (stopReconciliation, error)

func (*SecretMirrorContext) Sync

func (c *SecretMirrorContext) Sync(ctx context.Context) error

type SourceRetriever

type SourceRetriever interface {
	Setup(ctx context.Context) error
	Retrieve(ctx context.Context) (*v1.Secret, error)
}

type VaultBackend

type VaultBackend interface {
	Addr() string
	Token() string
	SetToken(token string)
	LoginAppRole(appRolePath, roleID, secretID string) error
	ReadSecret(path string) (*vault.Secret, error)
	RetrieveData(path string) (map[string]interface{}, error)
	WriteData(path string, data map[string]interface{}) error
	RenewLease(leaseId string, increment int) (*vault.Secret, error)
}

type VaultBackendMakerFunc

type VaultBackendMakerFunc func(addr string) (VaultBackend, error)

type VaultSecretDest

type VaultSecretDest struct {
	client.Client
	record.EventRecorder
	// contains filtered or unexported fields
}

func (*VaultSecretDest) Cleanup

func (d *VaultSecretDest) Cleanup(ctx context.Context) error

func (*VaultSecretDest) Setup

func (d *VaultSecretDest) Setup(ctx context.Context) error

func (*VaultSecretDest) Sync

func (d *VaultSecretDest) Sync(ctx context.Context, secret *v1.Secret) error

type VaultSecretSource

type VaultSecretSource struct {
	client.Client
	record.EventRecorder
	// contains filtered or unexported fields
}

func (*VaultSecretSource) Retrieve

func (s *VaultSecretSource) Retrieve(ctx context.Context) (*v1.Secret, error)

func (*VaultSecretSource) Setup

func (s *VaultSecretSource) Setup(ctx context.Context) error