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