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 RunInterConn(ctx context.Context, cancel context.CancelFunc, conf *Dependencies)
- func RunK3s(ctx context.Context, cancel context.CancelFunc, conf *Dependencies) error
- func RunOperatorsAllinOne(runctx context.Context, cancel context.CancelFunc, conf *Dependencies, ...) error
- func RunOperatorsInSubProcess(ctx context.Context, cancel context.CancelFunc) error
- type CorednsModule
- type Dependencies
- 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 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
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 RunInterConn ¶
func RunInterConn(ctx context.Context, cancel context.CancelFunc, conf *Dependencies)
func RunK3s ¶
func RunK3s(ctx context.Context, cancel context.CancelFunc, conf *Dependencies) error
func RunOperatorsAllinOne ¶
func RunOperatorsAllinOne(runctx context.Context, cancel context.CancelFunc, conf *Dependencies, startAgent bool) error
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
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
}
func InitDependencies ¶
func InitDependencies(ctx context.Context, kusciaConf confloader.KusciaConfig) *Dependencies
func (*Dependencies) Close ¶
func (d *Dependencies) Close()
func (*Dependencies) LoadCaDomainKeyAndCert ¶
func (d *Dependencies) LoadCaDomainKeyAndCert() error
func (*Dependencies) MakeClients ¶
func (d *Dependencies) MakeClients()
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) Module
func RunConfManager ¶
func RunConfManager(ctx context.Context, cancel context.CancelFunc, conf *Dependencies) Module
func RunContainerd ¶
func RunContainerd(ctx context.Context, cancel context.CancelFunc, conf *Dependencies) Module
func RunController ¶
func RunController(ctx context.Context, cancel context.CancelFunc, conf *Dependencies) Module
func RunCoreDNS ¶
func RunCoreDNS(ctx context.Context, cancel context.CancelFunc, conf *confloader.KusciaConfig) Module
func RunDataMesh ¶
func RunDataMesh(ctx context.Context, cancel context.CancelFunc, conf *Dependencies) Module
func RunDomainRoute ¶
func RunDomainRoute(ctx context.Context, cancel context.CancelFunc, conf *Dependencies) Module
func RunEnvoy ¶
func RunEnvoy(ctx context.Context, cancel context.CancelFunc, conf *Dependencies) Module
func RunKusciaAPI ¶
func RunKusciaAPI(ctx context.Context, cancel context.CancelFunc, conf *Dependencies) Module
func RunMetricExporter ¶
func RunMetricExporter(ctx context.Context, cancel context.CancelFunc, conf *Dependencies) Module
func RunNodeExporter ¶
func RunNodeExporter(ctx context.Context, cancel context.CancelFunc, conf *Dependencies) Module
func RunScheduler ¶
func RunScheduler(ctx context.Context, cancel context.CancelFunc, conf *Dependencies) Module
func RunSsExporter ¶
func RunSsExporter(ctx context.Context, cancel context.CancelFunc, conf *Dependencies) Module
func RunTransport ¶
func RunTransport(ctx context.Context, cancel context.CancelFunc, conf *Dependencies) Module
Source Files
Click to show internal directories.
Click to hide internal directories.