scheduler

package

v0.13.0 Latest Latest Go to latest Published: Mar 2, 2026 License: Apache-2.0 Imports: 21 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type SchedulerForConfig struct {
	BaseResourceName string
	// contains filtered or unexported fields
}

func (s *SchedulerForConfig) DesiredState(
	ctx context.Context, readerClient client.Reader, kaiConfig *kaiv1.Config,
) ([]client.Object, error)

func (s *SchedulerForConfig) HasMissingDependencies(context.Context, client.Reader, *kaiv1.Config) (string, error)

func (s *SchedulerForConfig) IsAvailable(ctx context.Context, readerClient client.Reader) (bool, error)

func (s *SchedulerForConfig) IsDeployed(ctx context.Context, readerClient client.Reader) (bool, error)

func (s *SchedulerForConfig) Monitor(ctx context.Context, runtimeReader client.Reader, kaiConfig *kaiv1.Config) error

func (s *SchedulerForConfig) Name() string

type SchedulerForShard struct {
	BaseResourceName string
	// contains filtered or unexported fields
}

func NewSchedulerForShard(schedulingShard *kaiv1.SchedulingShard) *SchedulerForShard

func (s *SchedulerForShard) DesiredState(
	ctx context.Context, readerClient client.Reader, kaiConfig *kaiv1.Config,
) ([]client.Object, error)

func (s *SchedulerForShard) HasMissingDependencies(context.Context, client.Reader, *kaiv1.Config) (string, error)

func (s *SchedulerForShard) IsAvailable(ctx context.Context, readerClient client.Reader) (bool, error)

func (s *SchedulerForShard) IsDeployed(ctx context.Context, readerClient client.Reader) (bool, error)

func (s *SchedulerForShard) Monitor(ctx context.Context, runtimeReader client.Reader, kaiConfig *kaiv1.Config) error

func (s *SchedulerForShard) Name() string