Documentation
¶
Index ¶
- Constants
- type NamespaceReconciler
- func (n *NamespaceReconciler) GetPollInterval() func() time.Duration
- func (n *NamespaceReconciler) GetPublisher() (string, websocket.Publisher)
- func (n *NamespaceReconciler) ListNamespaces(ctx context.Context) *algorithms.Pager[*console.ManagedNamespaceEdgeFragment]
- func (n *NamespaceReconciler) Poll(ctx context.Context) error
- func (n *NamespaceReconciler) Queue() workqueue.TypedRateLimitingInterface[string]
- func (n *NamespaceReconciler) Reconcile(ctx context.Context, id string) (reconcile.Result, error)
- func (n *NamespaceReconciler) Restart()
- func (n *NamespaceReconciler) Shutdown()
- func (n *NamespaceReconciler) ShutdownQueue()
- func (n *NamespaceReconciler) UpsertNamespace(ctx context.Context, fragment *console.ManagedNamespaceFragment) error
- func (n *NamespaceReconciler) WipeCache()
Constants ¶
View Source
const (
Identifier = "Namespace Controller"
)
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type NamespaceReconciler ¶
type NamespaceReconciler struct {
// contains filtered or unexported fields
}
func NewNamespaceReconciler ¶
func NewNamespaceReconciler(consoleClient client.Client, k8sClient ctrlclient.Client, refresh, pollInterval time.Duration) *NamespaceReconciler
func (*NamespaceReconciler) GetPollInterval ¶
func (n *NamespaceReconciler) GetPollInterval() func() time.Duration
func (*NamespaceReconciler) GetPublisher ¶
func (n *NamespaceReconciler) GetPublisher() (string, websocket.Publisher)
func (*NamespaceReconciler) ListNamespaces ¶
func (n *NamespaceReconciler) ListNamespaces(ctx context.Context) *algorithms.Pager[*console.ManagedNamespaceEdgeFragment]
func (*NamespaceReconciler) Queue ¶
func (n *NamespaceReconciler) Queue() workqueue.TypedRateLimitingInterface[string]
func (*NamespaceReconciler) Restart ¶
func (n *NamespaceReconciler) Restart()
func (*NamespaceReconciler) Shutdown ¶
func (n *NamespaceReconciler) Shutdown()
func (*NamespaceReconciler) ShutdownQueue ¶
func (n *NamespaceReconciler) ShutdownQueue()
func (*NamespaceReconciler) UpsertNamespace ¶
func (n *NamespaceReconciler) UpsertNamespace(ctx context.Context, fragment *console.ManagedNamespaceFragment) error
func (*NamespaceReconciler) WipeCache ¶
func (n *NamespaceReconciler) WipeCache()
Click to show internal directories.
Click to hide internal directories.