Documentation
¶
Index ¶
- Constants
- func GetRunResourceName(run *console.StackRunMinimalFragment) string
- type StackReconciler
- func (r *StackReconciler) GetPollInterval() func() time.Duration
- func (r *StackReconciler) GetPublisher() (string, websocket.Publisher)
- func (r *StackReconciler) GetRunResourceNamespace(jobSpec *batchv1.JobSpec) (namespace string)
- func (r *StackReconciler) ListStacks(ctx context.Context) *algorithms.Pager[*console.MinimalStackRunEdgeFragment]
- func (r *StackReconciler) Poll(ctx context.Context) error
- func (r *StackReconciler) Queue() workqueue.TypedRateLimitingInterface[string]
- func (r *StackReconciler) Reconcile(ctx context.Context, id string) (reconcile.Result, error)
- func (r *StackReconciler) Restart()
- func (r *StackReconciler) Shutdown()
- func (r *StackReconciler) ShutdownQueue()
- func (r *StackReconciler) WipeCache()
Constants ¶
View Source
const (
Identifier = "Stack Controller"
)
Variables ¶
This section is empty.
Functions ¶
func GetRunResourceName ¶
func GetRunResourceName(run *console.StackRunMinimalFragment) string
GetRunResourceName returns a resource name used for a job and a secret connected to a given run.
Types ¶
type StackReconciler ¶
type StackReconciler struct {
// contains filtered or unexported fields
}
func NewStackReconciler ¶
func NewStackReconciler(consoleClient client.Client, k8sClient ctrlclient.Client, scheme *runtime.Scheme, refresh, pollInterval time.Duration, namespace, consoleURL, deployToken string) *StackReconciler
func (*StackReconciler) GetPollInterval ¶
func (r *StackReconciler) GetPollInterval() func() time.Duration
func (*StackReconciler) GetPublisher ¶
func (r *StackReconciler) GetPublisher() (string, websocket.Publisher)
func (*StackReconciler) GetRunResourceNamespace ¶
func (r *StackReconciler) GetRunResourceNamespace(jobSpec *batchv1.JobSpec) (namespace string)
GetRunResourceNamespace returns a resource namespace used for a job and a secret connected to a given run.
func (*StackReconciler) ListStacks ¶
func (r *StackReconciler) ListStacks(ctx context.Context) *algorithms.Pager[*console.MinimalStackRunEdgeFragment]
func (*StackReconciler) Queue ¶
func (r *StackReconciler) Queue() workqueue.TypedRateLimitingInterface[string]
func (*StackReconciler) Restart ¶
func (r *StackReconciler) Restart()
func (*StackReconciler) Shutdown ¶
func (r *StackReconciler) Shutdown()
func (*StackReconciler) ShutdownQueue ¶
func (r *StackReconciler) ShutdownQueue()
func (*StackReconciler) WipeCache ¶
func (r *StackReconciler) WipeCache()
Source Files
Click to show internal directories.
Click to hide internal directories.