Documentation
¶
Index ¶
- Constants
- type LateSubmission
- type NexusResourceCache
- type RequestScheduler
- func (scheduler *RequestScheduler) CancelRun(requestId string, algorithmName string, initiator string, reason string, ...) (exists bool, err error)
- func (scheduler *RequestScheduler) Init(_ context.Context) (*RequestScheduler, error)
- func (scheduler *RequestScheduler) OnEvent(obj interface{})
- func (scheduler *RequestScheduler) ResolveParent(parentRequestId string, clusterName string) (*metav1.OwnerReference, error)
- func (scheduler *RequestScheduler) Start(ctx context.Context)
Constants ¶
View Source
const ( ComponentName = "scheduler" ComponentKey = "app.kubernetes.io/component" DryRunUID = "dry-run" )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type LateSubmission ¶
type LateSubmission struct {
Checkpoint *coremodels.CheckpointedRequest
BufferedEntry *coremodels.SubmissionBufferEntry
}
type NexusResourceCache ¶
type NexusResourceCache struct {
// contains filtered or unexported fields
}
func NewNexusResourceCache ¶
func NewNexusResourceCache(client nexuscore.Interface, resourceNamespace string, logger klog.Logger, resyncPeriod *time.Duration) *NexusResourceCache
NewNexusResourceCache creates a new cache for Nexus resources
func (*NexusResourceCache) GetAlgorithmConfiguration ¶
func (c *NexusResourceCache) GetAlgorithmConfiguration(algorithmName string) (*v1.NexusAlgorithmTemplate, error)
GetAlgorithmConfiguration retrieves a cached NexusAlgorithmTemplate resource from informer cache
func (*NexusResourceCache) GetWorkgroupConfiguration ¶
func (c *NexusResourceCache) GetWorkgroupConfiguration(workgroupName string) (*v1.NexusAlgorithmWorkgroup, error)
GetWorkgroupConfiguration retrieves a cached NexusAlgorithmTemplate resource from informer cache
type RequestScheduler ¶
type RequestScheduler struct {
LateSubmissionActor *pipeline.DefaultPipelineStageActor[*LateSubmission, *coremodels.CheckpointedRequest]
SchedulerActor *pipeline.DefaultPipelineStageActor[*request.BufferOutput, *coremodels.CheckpointedRequest]
CommitActor *pipeline.DefaultPipelineStageActor[*coremodels.CheckpointedRequest, string]
// contains filtered or unexported fields
}
func NewRequestScheduler ¶
func NewRequestScheduler(workerConfig *models.PipelineWorkerConfig, kubeClient kubernetes.Interface, shardClients []*shards.ShardClient, buffer request.Buffer, resourceNamespace string, logger klog.Logger, resyncPeriod *time.Duration) *RequestScheduler
func (*RequestScheduler) CancelRun ¶ added in v1.1.6
func (scheduler *RequestScheduler) CancelRun(requestId string, algorithmName string, initiator string, reason string, policy metav1.DeletionPropagation) (exists bool, err error)
func (*RequestScheduler) Init ¶
func (scheduler *RequestScheduler) Init(_ context.Context) (*RequestScheduler, error)
func (*RequestScheduler) OnEvent ¶
func (scheduler *RequestScheduler) OnEvent(obj interface{})
func (*RequestScheduler) ResolveParent ¶ added in v1.1.6
func (scheduler *RequestScheduler) ResolveParent(parentRequestId string, clusterName string) (*metav1.OwnerReference, error)
func (*RequestScheduler) Start ¶
func (scheduler *RequestScheduler) Start(ctx context.Context)
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.