Documentation
¶
Index ¶
- Constants
- func FetchSecret(ctx context.Context, cli client.Client, name types.NamespacedName) (*v1.Secret, error)
- type DestSyncer
- type KubernetesSecretSource
- type NamespacesDest
- type SecretMirrorBackend
- 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
- type VaultSecretSource
Constants ¶
View Source
const (
DefaultWorkerPoolSize = 100
)
Variables ¶
This section is empty.
Functions ¶
Types ¶
type DestSyncer ¶
type KubernetesSecretSource ¶
type KubernetesSecretSource struct {
client.Client
Name types.NamespacedName
}
type NamespacesDest ¶
type NamespacesDest struct {
client.Client
record.EventRecorder
// contains filtered or unexported fields
}
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 ¶
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)
type SourceRetriever ¶
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
}
type VaultSecretSource ¶
type VaultSecretSource struct {
client.Client
record.EventRecorder
// contains filtered or unexported fields
}
Click to show internal directories.
Click to hide internal directories.