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