status

func NewKubernetesManager ¶

func NewKubernetesManager(ctx context.Context, name, namespace, cmkey, instance string, cacheExpiration, resyncPeriod time.Duration, kc client.Client, log *zap.SugaredLogger) status.Manager

Returns a kubernetes status manager object. Parameters are: - name, namespace and key for the ConfigMap where the status will be written to. - identifier for this broker instance. - cache expiration that will force a new status write operation - resync period that check for pending changes and writes to the ConfigMap if any. - kubernetes client - logger