controllers

Documentation

Index

• Constants
• func CheckCRDExists(ctx context.Context, extensionClient apiextensionsclientset.Interface, ...) error
• type ControllerConfig
• type ControllerConstruction
• type IController
• type NewControllerFunc
• type Options
  • func NewOptions() *Options
  • func (o *Options) AddFlags(fs *pflag.FlagSet)
  • func (o *Options) Validate() error
• type Server
  • func NewServer(opts *Options, clients *kubeconfig.KubeClients, ...) *Server
  • func (s *Server) Name() string
  • func (s *Server) Run(ctx context.Context) error
  • func (s *Server) WaitReady(ctx context.Context) error

Constants

const (
	CRDAppImagesName           = "appimages.kuscia.secretflow"
	CRDClusterDomainRoutesName = "clusterdomainroutes.kuscia.secretflow"
	CRDDomainDataGrantsName    = "domaindatagrants.kuscia.secretflow"
	CRDDomainAppImagesName     = "domainappimages.kuscia.secretflow"
	CRDDomainRoutesName        = "domainroutes.kuscia.secretflow"
	CRDDomainsName             = "domains.kuscia.secretflow"
	CRDGatewaysName            = "gateways.kuscia.secretflow"
	CRDKusciaTasksName         = "kusciatasks.kuscia.secretflow"
	CRDKusciaDeploymentsName   = "kusciadeployments.kuscia.secretflow"
	CRDTaskResourcesGroupsName = "taskresourcegroups.kuscia.secretflow"
	CRDTaskResourcesName       = "taskresources.kuscia.secretflow"
	CRDKusciaJobsName          = "kusciajobs.kuscia.secretflow"
)

Functions

func CheckCRDExists

func CheckCRDExists(ctx context.Context, extensionClient apiextensionsclientset.Interface, crdNames []string) error

CheckCRDExists is used to check if crd exist.

Types

type ControllerConfig

type ControllerConfig struct {
	RunMode               common.RunModeType
	Namespace             string
	RootDir               string
	KubeClient            kubernetes.Interface
	KusciaClient          kusciaclientset.Interface
	EventRecorder         record.EventRecorder
	EnableWorkloadApprove bool
}

type ControllerConstruction

type ControllerConstruction struct {
	NewControler NewControllerFunc
	CRDNames     []string
}

type IController

type IController interface {
	Run(int) error
	Stop()
	Name() string
}

type NewControllerFunc

type NewControllerFunc func(ctx context.Context, config ControllerConfig) IController

type Options

type Options struct {
	Kubeconfig string
	MasterURL  string
	RunMode    common.RunModeType
	Namespace  string
	RootDir    string
	Workers    int
	// QPS indicates the maximum QPS to the master from this client.
	// If it's zero, the created RESTClient will use DefaultQPS: 5
	QPS float64
	// Maximum burst for throttle.
	// If it's zero, the created RESTClient will use DefaultBurst: 10.
	Burst int
	// HealthCheckPort is the port that the health check server listens on.
	HealthCheckPort int

	ControllerName string

	EnableWorkloadApprove bool
}

Options is the main context object for the domain controller.

func NewOptions

func NewOptions() *Options

NewOptions creates a new options with a default config.

func (*Options) AddFlags

func (o *Options) AddFlags(fs *pflag.FlagSet)

AddFlags adds flags for a specific server to the specified FlagSet.

func (*Options) Validate

func (o *Options) Validate() error

Validate whether the parameter is legal.

type Server

type Server struct {
	// contains filtered or unexported fields
}

Server defines detailed info which used to run server.

func NewServer

func NewServer(opts *Options, clients *kubeconfig.KubeClients, controllerConstructions []ControllerConstruction) *Server

NewServer returns a server instance.

func (*Server) Name

func (s *Server) Name() string

func (*Server) Run

func (s *Server) Run(ctx context.Context) error

Run is used to run server.

func (*Server) WaitReady

func (s *Server) WaitReady(ctx context.Context) error