Versions in this module Expand all Collapse all v1 v1.0.1 Apr 21, 2026 Changes in this version + const TransformBase64Decode + const TransformJSONExpand + const TransformPrefix + const TransformRename + const TransformSuffix + var ConnectionReady = prometheus.NewGaugeVec(prometheus.GaugeOpts{ ... }, []string{ ... }) + var LastSyncTimestamp = prometheus.NewGaugeVec(prometheus.GaugeOpts{ ... }, []string{ ... }) + var SyncDuration = prometheus.NewHistogramVec(prometheus.HistogramOpts{ ... }, []string{ ... }) + var SyncErrors = prometheus.NewCounterVec(prometheus.CounterOpts{ ... }, []string{ ... }) + func ApplyTransforms(input map[string]string, transforms []ffv1alpha1.SecretTransform) (map[string]string, error) + func DeleteConnectionReady(namespace, name string) + func DeleteLastSyncTimestamp(namespace, name string) + func IncSyncError(reason string) + func ObserveReconcile(begin time.Time, result string) + func SetConnectionReady(namespace, name string, ready bool) + func SetLastSyncTimestamp(namespace, name string) + type ClientFactory func(baseURL, token string) (ferrflowClient, error) + type FerrFlowConnectionReconciler struct + Broker *TokenBroker + Scheme *runtime.Scheme + func (r *FerrFlowConnectionReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error) + func (r *FerrFlowConnectionReconciler) SetupWithManager(mgr ctrl.Manager) error + type FerrFlowSecretReconciler struct + Broker *TokenBroker + ClientFactory ClientFactory + DefaultRefreshInterval time.Duration + Scheme *runtime.Scheme + func (r *FerrFlowSecretReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error) + func (r *FerrFlowSecretReconciler) SetupWithManager(mgr ctrl.Manager) error + type TokenBroker struct + Client client.Client + Exchange oidcExchanger + ReadToken tokenReader + func NewTokenBroker(c client.Client) *TokenBroker + func (b *TokenBroker) Invalidate(namespace, name string) + func (b *TokenBroker) TokenFor(ctx context.Context, conn *ffv1alpha1.FerrFlowConnection) (string, error) + type TransformError struct + Index int + Msg string + Type string + func (e *TransformError) Error() string