Documentation ¶
Index ¶
- func CreateCrossNamespace(ctx context.Context, conf *Dependencies) error
- func CreateDefaultDomain(ctx context.Context, conf *Dependencies) error
- func EnsureDir(conf *Dependencies) error
- func GetTransportPort(configPath string) (int, error)
- func InitLogs(logConfig *nlog.LogConfig) error
- func NewShutdownHookEntry(timeout time.Duration) *shutdownHookEntry
- func RunAgentWithDestroy(conf *Dependencies)
- func RunConfManagerWithDestroy(conf *Dependencies)
- func RunContainerdWithDestroy(conf *Dependencies)
- func RunControllerWithDestroy(conf *Dependencies)
- func RunDataMeshWithDestroy(conf *Dependencies)
- func RunDomainRouteWithDestroy(conf *Dependencies)
- func RunEnvoyWithDestroy(conf *Dependencies)
- func RunInterConn(ctx context.Context, cancel context.CancelFunc, conf *Dependencies, ...)
- func RunInterConnWithDestroy(conf *Dependencies)
- func RunK3s(ctx context.Context, cancel context.CancelFunc, conf *Dependencies, ...) error
- func RunK3sWithDestroy(conf *Dependencies) error
- func RunKusciaAPIWithDestroy(conf *Dependencies)
- func RunMetricExporterWithDestroy(conf *Dependencies)
- func RunNodeExporterWithDestroy(conf *Dependencies)
- func RunOperatorsAllinOneWithDestroy(conf *Dependencies)
- func RunOperatorsInSubProcess(ctx context.Context, cancel context.CancelFunc) error
- func RunOperatorsInSubProcessWithDestroy(conf *Dependencies) error
- func RunSchedulerWithDestroy(conf *Dependencies)
- func RunSsExporterWithDestroy(conf *Dependencies)
- func RunTransportWithDestroy(conf *Dependencies)
- func SetKusciaOOMScore()
- type CorednsModule
- type Dependencies
- func (d *Dependencies) Close()
- func (d *Dependencies) Destroy()
- func (d *Dependencies) LoadCaDomainKeyAndCert() error
- func (d *Dependencies) MakeClients()
- func (d *Dependencies) RegisterDestroyFunc(destroyFunc DestroyFunc)
- func (d *Dependencies) Stop() <-chan struct{}
- func (d *Dependencies) WaitAllModulesDone(stop <-chan struct{})
- type DestroyFunc
- type EnvoyCommandLineConfig
- type Module
- func NewAgent(i *Dependencies) Module
- func NewConfManager(ctx context.Context, d *Dependencies) (Module, error)
- func NewContainerd(i *Dependencies) Module
- func NewControllersModule(i *Dependencies) Module
- func NewCoreDNS(conf *confloader.KusciaConfig) Module
- func NewDataMesh(d *Dependencies) (Module, error)
- func NewDomainRoute(i *Dependencies) Module
- func NewEnvoy(i *Dependencies) Module
- func NewInterConn(ctx context.Context, deps *Dependencies) (Module, error)
- func NewK3s(i *Dependencies) Module
- func NewKusciaAPI(d *Dependencies) (Module, error)
- func NewMetricExporter(i *Dependencies) Module
- func NewNodeExporter(i *Dependencies) Module
- func NewScheduler(i *Dependencies) Module
- func NewSsExporter(i *Dependencies) Module
- func NewTransport(i *Dependencies) Module
- func RunAgent(ctx context.Context, cancel context.CancelFunc, conf *Dependencies, ...) Module
- func RunConfManager(ctx context.Context, cancel context.CancelFunc, conf *Dependencies, ...) Module
- func RunContainerd(ctx context.Context, cancel context.CancelFunc, conf *Dependencies, ...) Module
- func RunController(ctx context.Context, cancel context.CancelFunc, conf *Dependencies, ...) Module
- func RunCoreDNS(ctx context.Context, cancel context.CancelFunc, conf *confloader.KusciaConfig, ...) Module
- func RunCoreDNSWithDestroy(conf *Dependencies) Module
- func RunDataMesh(ctx context.Context, cancel context.CancelFunc, conf *Dependencies, ...) Module
- func RunDomainRoute(ctx context.Context, cancel context.CancelFunc, conf *Dependencies, ...) Module
- func RunEnvoy(ctx context.Context, cancel context.CancelFunc, conf *Dependencies, ...) Module
- func RunKusciaAPI(ctx context.Context, cancel context.CancelFunc, conf *Dependencies, ...) Module
- func RunMetricExporter(ctx context.Context, cancel context.CancelFunc, conf *Dependencies, ...) Module
- func RunNodeExporter(ctx context.Context, cancel context.CancelFunc, conf *Dependencies, ...) Module
- func RunScheduler(ctx context.Context, cancel context.CancelFunc, conf *Dependencies, ...) Module
- func RunSsExporter(ctx context.Context, cancel context.CancelFunc, conf *Dependencies, ...) Module
- func RunTransport(ctx context.Context, cancel context.CancelFunc, conf *Dependencies, ...) Module
- type ModuleCMD
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CreateCrossNamespace ¶
func CreateCrossNamespace(ctx context.Context, conf *Dependencies) error
func CreateDefaultDomain ¶
func CreateDefaultDomain(ctx context.Context, conf *Dependencies) error
func EnsureDir ¶
func EnsureDir(conf *Dependencies) error
func GetTransportPort ¶
func NewShutdownHookEntry ¶
func RunAgentWithDestroy ¶
func RunAgentWithDestroy(conf *Dependencies)
func RunConfManagerWithDestroy ¶
func RunConfManagerWithDestroy(conf *Dependencies)
func RunContainerdWithDestroy ¶
func RunContainerdWithDestroy(conf *Dependencies)
func RunControllerWithDestroy ¶
func RunControllerWithDestroy(conf *Dependencies)
func RunDataMeshWithDestroy ¶
func RunDataMeshWithDestroy(conf *Dependencies)
func RunDomainRouteWithDestroy ¶
func RunDomainRouteWithDestroy(conf *Dependencies)
func RunEnvoyWithDestroy ¶
func RunEnvoyWithDestroy(conf *Dependencies)
func RunInterConn ¶
func RunInterConn(ctx context.Context, cancel context.CancelFunc, conf *Dependencies, shutdownEntry *shutdownHookEntry)
func RunInterConnWithDestroy ¶
func RunInterConnWithDestroy(conf *Dependencies)
func RunK3s ¶
func RunK3s(ctx context.Context, cancel context.CancelFunc, conf *Dependencies, shutdownEntry *shutdownHookEntry) error
func RunK3sWithDestroy ¶
func RunK3sWithDestroy(conf *Dependencies) error
func RunKusciaAPIWithDestroy ¶
func RunKusciaAPIWithDestroy(conf *Dependencies)
func RunMetricExporterWithDestroy ¶
func RunMetricExporterWithDestroy(conf *Dependencies)
func RunNodeExporterWithDestroy ¶
func RunNodeExporterWithDestroy(conf *Dependencies)
func RunOperatorsAllinOneWithDestroy ¶
func RunOperatorsAllinOneWithDestroy(conf *Dependencies)
TODO: The definition of this function is very ugly, we need to reconsider it later
func RunOperatorsInSubProcess ¶
func RunOperatorsInSubProcess(ctx context.Context, cancel context.CancelFunc) error
func RunOperatorsInSubProcessWithDestroy ¶
func RunOperatorsInSubProcessWithDestroy(conf *Dependencies) error
func RunSchedulerWithDestroy ¶
func RunSchedulerWithDestroy(conf *Dependencies)
func RunSsExporterWithDestroy ¶
func RunSsExporterWithDestroy(conf *Dependencies)
func RunTransportWithDestroy ¶
func RunTransportWithDestroy(conf *Dependencies)
func SetKusciaOOMScore ¶
func SetKusciaOOMScore()
Types ¶
type CorednsModule ¶
type CorednsModule struct {
// contains filtered or unexported fields
}
func (*CorednsModule) Name ¶
func (s *CorednsModule) Name() string
func (*CorednsModule) StartControllers ¶
func (s *CorednsModule) StartControllers(ctx context.Context, kubeclient kubernetes.Interface)
type Dependencies ¶
type Dependencies struct { confloader.KusciaConfig CAKey *rsa.PrivateKey CACert *x509.Certificate DomainKey *rsa.PrivateKey DomainCert *x509.Certificate Clients *kubeconfig.KubeClients ApiserverEndpoint string KubeconfigFile string ContainerdSock string TransportConfigFile string TransportPort int InterConnSchedulerPort int SsExportPort string NodeExportPort string MetricExportPort string KusciaKubeConfig string EnableContainerd bool SecretBackendHolder *secretbackend.Holder DomainCertByMasterValue atomic.Value // the value is <*x509.Certificate> LogConfig *nlog.LogConfig Logrorate confloader.LogrotateConfig // contains filtered or unexported fields }
func InitDependencies ¶
func InitDependencies(ctx context.Context, kusciaConf confloader.KusciaConfig) *Dependencies
func (*Dependencies) Close ¶
func (d *Dependencies) Close()
func (*Dependencies) Destroy ¶
func (d *Dependencies) Destroy()
func (*Dependencies) LoadCaDomainKeyAndCert ¶
func (d *Dependencies) LoadCaDomainKeyAndCert() error
func (*Dependencies) MakeClients ¶
func (d *Dependencies) MakeClients()
func (*Dependencies) RegisterDestroyFunc ¶
func (d *Dependencies) RegisterDestroyFunc(destroyFunc DestroyFunc)
func (*Dependencies) Stop ¶
func (d *Dependencies) Stop() <-chan struct{}
func (*Dependencies) WaitAllModulesDone ¶
func (d *Dependencies) WaitAllModulesDone(stop <-chan struct{})
type DestroyFunc ¶
type DestroyFunc struct { Name string DestroyFn func() DestroyCh <-chan struct{} ShutdownHookEntry *shutdownHookEntry }
type EnvoyCommandLineConfig ¶
type EnvoyCommandLineConfig struct {
Args []string `yaml:"args,omitempty"`
}
type Module ¶
type Module interface { Run(ctx context.Context) error WaitReady(ctx context.Context) error Name() string }
func NewAgent ¶
func NewAgent(i *Dependencies) Module
func NewConfManager ¶
func NewConfManager(ctx context.Context, d *Dependencies) (Module, error)
func NewContainerd ¶
func NewContainerd(i *Dependencies) Module
func NewControllersModule ¶
func NewControllersModule(i *Dependencies) Module
func NewCoreDNS ¶
func NewCoreDNS(conf *confloader.KusciaConfig) Module
func NewDataMesh ¶
func NewDataMesh(d *Dependencies) (Module, error)
func NewDomainRoute ¶
func NewDomainRoute(i *Dependencies) Module
func NewEnvoy ¶
func NewEnvoy(i *Dependencies) Module
func NewInterConn ¶
func NewInterConn(ctx context.Context, deps *Dependencies) (Module, error)
func NewK3s ¶
func NewK3s(i *Dependencies) Module
func NewKusciaAPI ¶
func NewKusciaAPI(d *Dependencies) (Module, error)
func NewMetricExporter ¶
func NewMetricExporter(i *Dependencies) Module
func NewNodeExporter ¶
func NewNodeExporter(i *Dependencies) Module
func NewScheduler ¶
func NewScheduler(i *Dependencies) Module
func NewSsExporter ¶
func NewSsExporter(i *Dependencies) Module
func NewTransport ¶
func NewTransport(i *Dependencies) Module
func RunAgent ¶
func RunAgent(ctx context.Context, cancel context.CancelFunc, conf *Dependencies, shutdownEntry *shutdownHookEntry) Module
func RunConfManager ¶
func RunConfManager(ctx context.Context, cancel context.CancelFunc, conf *Dependencies, shutdownEntry *shutdownHookEntry) Module
func RunContainerd ¶
func RunContainerd(ctx context.Context, cancel context.CancelFunc, conf *Dependencies, shutdownEntry *shutdownHookEntry) Module
func RunController ¶
func RunController(ctx context.Context, cancel context.CancelFunc, conf *Dependencies, shutdownEntry *shutdownHookEntry) Module
func RunCoreDNS ¶
func RunCoreDNS(ctx context.Context, cancel context.CancelFunc, conf *confloader.KusciaConfig, shutdownEntry *shutdownHookEntry) Module
func RunCoreDNSWithDestroy ¶
func RunCoreDNSWithDestroy(conf *Dependencies) Module
func RunDataMesh ¶
func RunDataMesh(ctx context.Context, cancel context.CancelFunc, conf *Dependencies, shutdownEntry *shutdownHookEntry) Module
func RunDomainRoute ¶
func RunDomainRoute(ctx context.Context, cancel context.CancelFunc, conf *Dependencies, shutdownEntry *shutdownHookEntry) Module
func RunEnvoy ¶
func RunEnvoy(ctx context.Context, cancel context.CancelFunc, conf *Dependencies, shutdownEntry *shutdownHookEntry) Module
func RunKusciaAPI ¶
func RunKusciaAPI(ctx context.Context, cancel context.CancelFunc, conf *Dependencies, shutdownEntry *shutdownHookEntry) Module
func RunMetricExporter ¶
func RunMetricExporter(ctx context.Context, cancel context.CancelFunc, conf *Dependencies, shutdownEntry *shutdownHookEntry) Module
func RunNodeExporter ¶
func RunNodeExporter(ctx context.Context, cancel context.CancelFunc, conf *Dependencies, shutdownEntry *shutdownHookEntry) Module
func RunScheduler ¶
func RunScheduler(ctx context.Context, cancel context.CancelFunc, conf *Dependencies, shutdownEntry *shutdownHookEntry) Module
func RunSsExporter ¶
func RunSsExporter(ctx context.Context, cancel context.CancelFunc, conf *Dependencies, shutdownEntry *shutdownHookEntry) Module
func RunTransport ¶
func RunTransport(ctx context.Context, cancel context.CancelFunc, conf *Dependencies, shutdownEntry *shutdownHookEntry) Module
type ModuleCMD ¶
type ModuleCMD struct {
// contains filtered or unexported fields
}
func (*ModuleCMD) SetOOMScore ¶
Click to show internal directories.
Click to hide internal directories.