Documentation
¶
Index ¶
- Constants
- type RestoreReconciler
- func (s *RestoreReconciler) GetPollInterval() func() time.Duration
- func (s *RestoreReconciler) GetPublisher() (string, websocket.Publisher)
- func (s *RestoreReconciler) Poll(ctx context.Context) error
- func (s *RestoreReconciler) Queue() workqueue.TypedRateLimitingInterface[string]
- func (s *RestoreReconciler) Reconcile(ctx context.Context, id string) (result reconcile.Result, err error)
- func (s *RestoreReconciler) Restart()
- func (s *RestoreReconciler) Shutdown()
- func (s *RestoreReconciler) ShutdownQueue()
- func (s *RestoreReconciler) UpdateErrorStatus(ctx context.Context, id string)
- func (s *RestoreReconciler) WipeCache()
Constants ¶
View Source
const (
Identifier = "Restore Controller"
)
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type RestoreReconciler ¶
type RestoreReconciler struct {
// contains filtered or unexported fields
}
func NewRestoreReconciler ¶
func NewRestoreReconciler(consoleClient client.Client, k8sClient ctrlclient.Client, refresh, pollInterval time.Duration, namespace string) *RestoreReconciler
func (*RestoreReconciler) GetPollInterval ¶
func (s *RestoreReconciler) GetPollInterval() func() time.Duration
func (*RestoreReconciler) GetPublisher ¶
func (s *RestoreReconciler) GetPublisher() (string, websocket.Publisher)
func (*RestoreReconciler) Queue ¶
func (s *RestoreReconciler) Queue() workqueue.TypedRateLimitingInterface[string]
func (*RestoreReconciler) Restart ¶
func (s *RestoreReconciler) Restart()
func (*RestoreReconciler) Shutdown ¶
func (s *RestoreReconciler) Shutdown()
func (*RestoreReconciler) ShutdownQueue ¶
func (s *RestoreReconciler) ShutdownQueue()
func (*RestoreReconciler) UpdateErrorStatus ¶
func (s *RestoreReconciler) UpdateErrorStatus(ctx context.Context, id string)
func (*RestoreReconciler) WipeCache ¶
func (s *RestoreReconciler) WipeCache()
Source Files
Click to show internal directories.
Click to hide internal directories.