config

Documentation

Index

• Variables
• type Management
  • func (m *Management) GetEntClient() *ent.Client
  • func (m *Management) SetEntClient(client *ent.Client)
  • func (m *Management) Start(threads int) error
• type Options
• type Scaled
  • func ScaledWithContext(ctx context.Context) *Scaled
  • func SetupScaled(ctx context.Context, restConfig *rest.Config, opts *generic.FactoryOptions) (context.Context, *Scaled, error)
  • func (s *Scaled) Start(threads int) error

Variables

var (
	AddToScheme = localSchemeBuilder.AddToScheme
	Scheme      = runtime.NewScheme()
)

Types

type Management

type Management struct {
	Ctx       context.Context
	ClientSet *kubernetes.Clientset
	Apply     apply.Apply
	EntClient *ent.Client

	CoreFactory    *corev1.Factory
	AppsFactory    *appsv1.Factory
	RbacFactory    *rbacv1.Factory
	BatchFactory   *batchv1.Factory
	StorageFactory *storagev1.Factory
	MgmtFactory    *ctlmgmtv1.Factory
	UpgradeFactory *upgrade.Factory
	LLMFactory     *ctlmlv1.Factory
	KubeRayFactory *kuberayv1.Factory
	NvidiaFactory  *nvidiav1.Factory
	RookFactory    *rookv1.Factory
	HelmFactory    *helmv1.Factory
	// contains filtered or unexported fields
}

func (*Management) GetEntClient

func (m *Management) GetEntClient() *ent.Client

func (*Management) SetEntClient

func (m *Management) SetEntClient(client *ent.Client)

func (*Management) Start

func (m *Management) Start(threads int) error

type Options

type Options struct {
	Context         context.Context
	HTTPListenPort  int
	HTTPSListenPort int
	Threadiness     int
	config.CommonOptions
}

Options define the api server options

type Scaled

type Scaled struct {
	Ctx        context.Context
	ClientSet  *kubernetes.Clientset
	Management *Management

	CoreFactory *corev1.Factory
	MgmtFactory *ctlmgmtv1.Factory
	// contains filtered or unexported fields
}

func ScaledWithContext

func ScaledWithContext(ctx context.Context) *Scaled

func SetupScaled

func SetupScaled(ctx context.Context, restConfig *rest.Config, opts *generic.FactoryOptions) (
	context.Context, *Scaled, error)

func (*Scaled) Start

func (s *Scaled) Start(threads int) error