scheduler

Documentation

Index

• func FulfillSchedulerSpec(clusterInstance *hwameistoriov1alpha1.Cluster) *hwameistoriov1alpha1.Cluster
• func InstallSchedulerConfigMap(cli client.Client, targetNamespace string) error
• func SetScheduler(clusterInstance *hwameistoriov1alpha1.Cluster)
• type SchedulerConfigMapMaintainer
  • func NewSchedulerConfigMapMaintainer(cli client.Client, clusterInstance *hwameistoriov1alpha1.Cluster) *SchedulerConfigMapMaintainer
  • func (m *SchedulerConfigMapMaintainer) Ensure() error
  • func (m *SchedulerConfigMapMaintainer) Uninstall() error
• type SchedulerMaintainer
  • func NewSchedulerMaintainer(cli client.Client, clusterInstance *hwameistoriov1alpha1.Cluster) *SchedulerMaintainer
  • func (m *SchedulerMaintainer) Ensure() (*hwameistoriov1alpha1.Cluster, error)

Functions

func FulfillSchedulerSpec

func FulfillSchedulerSpec(clusterInstance *hwameistoriov1alpha1.Cluster) *hwameistoriov1alpha1.Cluster

func InstallSchedulerConfigMap

func InstallSchedulerConfigMap(cli client.Client, targetNamespace string) error

func SetScheduler

func SetScheduler(clusterInstance *hwameistoriov1alpha1.Cluster)

Types

type SchedulerConfigMapMaintainer

type SchedulerConfigMapMaintainer struct {
	Client          client.Client
	ClusterInstance *hwameistoriov1alpha1.Cluster
}

func NewSchedulerConfigMapMaintainer

func NewSchedulerConfigMapMaintainer(cli client.Client, clusterInstance *hwameistoriov1alpha1.Cluster) *SchedulerConfigMapMaintainer

func (*SchedulerConfigMapMaintainer) Ensure

func (m *SchedulerConfigMapMaintainer) Ensure() error

func (*SchedulerConfigMapMaintainer) Uninstall

func (m *SchedulerConfigMapMaintainer) Uninstall() error

type SchedulerMaintainer

type SchedulerMaintainer struct {
	Client          client.Client
	ClusterInstance *hwameistoriov1alpha1.Cluster
}

func NewSchedulerMaintainer

func NewSchedulerMaintainer(cli client.Client, clusterInstance *hwameistoriov1alpha1.Cluster) *SchedulerMaintainer

func (*SchedulerMaintainer) Ensure

func (m *SchedulerMaintainer) Ensure() (*hwameistoriov1alpha1.Cluster, error)