controllers

Documentation

Overview

Copyright © 2022 MicroShift Contributors Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Copyright © 2024 MicroShift Contributors

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Copyright © 2021 MicroShift Contributors

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Copyright © 2021 MicroShift Contributors

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Copyright © 2021 MicroShift Contributors

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Copyright © 2021 MicroShift Contributors

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Copyright © 2021 MicroShift Contributors

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Copyright © 2023 MicroShift Contributors

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Copyright © 2021 MicroShift Contributors

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Copyright © 2021 MicroShift Contributors

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Copyright © 2021 MicroShift Contributors

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Copyright © 2022 MicroShift Contributors

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Index

• Variables
• func ApplyDefaultSCCs(ctx context.Context, cfg *config.Config) error
• func GetKubeControllerManagerArgs(config map[string]interface{}) []string
• type ClusterID
  • func NewClusterID(cfg *config.Config) *ClusterID
  • func (s *ClusterID) Dependencies() []string
  • func (s *ClusterID) Name() string
  • func (s *ClusterID) Run(ctx context.Context, ready chan<- struct{}, stopped chan<- struct{}) error
• type ClusterPolicyController
  • func NewClusterPolicyController(cfg *config.Config) *ClusterPolicyController
  • func (s *ClusterPolicyController) Dependencies() []string
  • func (s *ClusterPolicyController) Name() string
  • func (s *ClusterPolicyController) Run(ctx context.Context, ready chan<- struct{}, stopped chan<- struct{}) error
• type EtcdService
  • func NewEtcd(cfg *config.Config) *EtcdService
  • func (s *EtcdService) Dependencies() []string
  • func (s *EtcdService) Name() string
  • func (s *EtcdService) Run(ctx context.Context, ready chan<- struct{}, stopped chan<- struct{}) error
• type InfrastructureServicesManager
  • func NewInfrastructureServices(cfg *config.Config) *InfrastructureServicesManager
  • func (s *InfrastructureServicesManager) Dependencies() []string
  • func (s *InfrastructureServicesManager) Name() string
  • func (s *InfrastructureServicesManager) Run(ctx context.Context, ready chan<- struct{}, stopped chan<- struct{}) error
• type KubeAPIServer
  • func NewKubeAPIServer(cfg *config.Config) *KubeAPIServer
  • func (s *KubeAPIServer) Dependencies() []string
  • func (s *KubeAPIServer) Name() string
  • func (s *KubeAPIServer) Run(ctx context.Context, ready chan<- struct{}, stopped chan<- struct{}) error
• type KubeControllerManager
  • func NewKubeControllerManager(ctx context.Context, cfg *config.Config) *KubeControllerManager
  • func (s *KubeControllerManager) Dependencies() []string
  • func (s *KubeControllerManager) Name() string
  • func (s *KubeControllerManager) Run(ctx context.Context, ready chan<- struct{}, stopped chan<- struct{}) error
• type KubeScheduler
  • func NewKubeScheduler(cfg *config.Config) *KubeScheduler
  • func (s *KubeScheduler) Dependencies() []string
  • func (s *KubeScheduler) Name() string
  • func (s *KubeScheduler) Run(ctx context.Context, ready chan<- struct{}, stopped chan<- struct{}) error
• type KubeStorageVersionMigrator
  • func NewKubeStorageVersionMigrator(cfg *config.Config) *KubeStorageVersionMigrator
  • func (s *KubeStorageVersionMigrator) Dependencies() []string
  • func (s *KubeStorageVersionMigrator) Name() string
  • func (s *KubeStorageVersionMigrator) Run(ctx context.Context, ready chan<- struct{}, stopped chan<- struct{}) error
• type OCPRouteControllerManager
  • func NewRouteControllerManager(cfg *config.Config) *OCPRouteControllerManager
  • func (s *OCPRouteControllerManager) Dependencies() []string
  • func (s *OCPRouteControllerManager) Name() string
  • func (s *OCPRouteControllerManager) Run(ctx context.Context, ready chan<- struct{}, stopped chan<- struct{}) error
• type OpenShiftCRDManager
  • func NewOpenShiftCRDManager(cfg *config.Config) *OpenShiftCRDManager
  • func (s *OpenShiftCRDManager) Dependencies() []string
  • func (s *OpenShiftCRDManager) Name() string
  • func (s *OpenShiftCRDManager) Run(ctx context.Context, ready chan<- struct{}, stopped chan<- struct{}) error
• type OpenShiftDefaultSCCManager
  • func NewOpenShiftDefaultSCCManager(cfg *config.Config) *OpenShiftDefaultSCCManager
  • func (s *OpenShiftDefaultSCCManager) Dependencies() []string
  • func (s *OpenShiftDefaultSCCManager) Name() string
  • func (s *OpenShiftDefaultSCCManager) Run(ctx context.Context, ready chan<- struct{}, stopped chan<- struct{}) error
• type VersionManager
  • func NewVersionManager(cfg *config.Config) *VersionManager
  • func (s *VersionManager) Dependencies() []string
  • func (s *VersionManager) Name() string
  • func (s *VersionManager) Run(ctx context.Context, ready chan<- struct{}, stopped chan<- struct{}) error

Variables

var (
	HealthCheckRetries = 10
	HealthCheckWait    = 3 * time.Second
)

Functions

func ApplyDefaultSCCs

func ApplyDefaultSCCs(ctx context.Context, cfg *config.Config) error

func GetKubeControllerManagerArgs

func GetKubeControllerManagerArgs(config map[string]interface{}) []string

This is a straight copy from KCM operator repo

Types

type ClusterID

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

func NewClusterID

func NewClusterID(cfg *config.Config) *ClusterID

func (*ClusterID) Dependencies

func (s *ClusterID) Dependencies() []string

func (*ClusterID) Name

func (s *ClusterID) Name() string

func (*ClusterID) Run

func (s *ClusterID) Run(ctx context.Context, ready chan<- struct{}, stopped chan<- struct{}) error

type ClusterPolicyController

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

func NewClusterPolicyController

func NewClusterPolicyController(cfg *config.Config) *ClusterPolicyController

func (*ClusterPolicyController) Dependencies

func (s *ClusterPolicyController) Dependencies() []string

func (*ClusterPolicyController) Name

func (s *ClusterPolicyController) Name() string

func (*ClusterPolicyController) Run

func (s *ClusterPolicyController) Run(ctx context.Context, ready chan<- struct{}, stopped chan<- struct{}) error

type EtcdService

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

func NewEtcd

func NewEtcd(cfg *config.Config) *EtcdService

func (*EtcdService) Dependencies

func (s *EtcdService) Dependencies() []string

func (*EtcdService) Name

func (s *EtcdService) Name() string

func (*EtcdService) Run

func (s *EtcdService) Run(ctx context.Context, ready chan<- struct{}, stopped chan<- struct{}) error

type InfrastructureServicesManager

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

func NewInfrastructureServices

func NewInfrastructureServices(cfg *config.Config) *InfrastructureServicesManager

func (*InfrastructureServicesManager) Dependencies

func (s *InfrastructureServicesManager) Dependencies() []string

func (*InfrastructureServicesManager) Name

func (s *InfrastructureServicesManager) Name() string

func (*InfrastructureServicesManager) Run

func (s *InfrastructureServicesManager) Run(ctx context.Context, ready chan<- struct{}, stopped chan<- struct{}) error

type KubeAPIServer

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

func NewKubeAPIServer

func NewKubeAPIServer(cfg *config.Config) *KubeAPIServer

func (*KubeAPIServer) Dependencies

func (s *KubeAPIServer) Dependencies() []string

func (*KubeAPIServer) Name

func (s *KubeAPIServer) Name() string

func (*KubeAPIServer) Run

func (s *KubeAPIServer) Run(ctx context.Context, ready chan<- struct{}, stopped chan<- struct{}) error

type KubeControllerManager

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

func NewKubeControllerManager

func NewKubeControllerManager(ctx context.Context, cfg *config.Config) *KubeControllerManager

func (*KubeControllerManager) Dependencies

func (s *KubeControllerManager) Dependencies() []string

func (*KubeControllerManager) Name

func (s *KubeControllerManager) Name() string

func (*KubeControllerManager) Run

func (s *KubeControllerManager) Run(ctx context.Context, ready chan<- struct{}, stopped chan<- struct{}) error

type KubeScheduler

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

func NewKubeScheduler

func NewKubeScheduler(cfg *config.Config) *KubeScheduler

func (*KubeScheduler) Dependencies

func (s *KubeScheduler) Dependencies() []string

func (*KubeScheduler) Name

func (s *KubeScheduler) Name() string

func (*KubeScheduler) Run

func (s *KubeScheduler) Run(ctx context.Context, ready chan<- struct{}, stopped chan<- struct{}) error

type KubeStorageVersionMigrator

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

func NewKubeStorageVersionMigrator

func NewKubeStorageVersionMigrator(cfg *config.Config) *KubeStorageVersionMigrator

func (*KubeStorageVersionMigrator) Dependencies

func (s *KubeStorageVersionMigrator) Dependencies() []string

func (*KubeStorageVersionMigrator) Name

func (s *KubeStorageVersionMigrator) Name() string

func (*KubeStorageVersionMigrator) Run

func (s *KubeStorageVersionMigrator) Run(ctx context.Context, ready chan<- struct{}, stopped chan<- struct{}) error

type OCPRouteControllerManager

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

func NewRouteControllerManager

func NewRouteControllerManager(cfg *config.Config) *OCPRouteControllerManager

func (*OCPRouteControllerManager) Dependencies

func (s *OCPRouteControllerManager) Dependencies() []string

func (*OCPRouteControllerManager) Name

func (s *OCPRouteControllerManager) Name() string

func (*OCPRouteControllerManager) Run

func (s *OCPRouteControllerManager) Run(ctx context.Context, ready chan<- struct{}, stopped chan<- struct{}) error

type OpenShiftCRDManager

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

func NewOpenShiftCRDManager

func NewOpenShiftCRDManager(cfg *config.Config) *OpenShiftCRDManager

func (*OpenShiftCRDManager) Dependencies

func (s *OpenShiftCRDManager) Dependencies() []string

func (*OpenShiftCRDManager) Name

func (s *OpenShiftCRDManager) Name() string

func (*OpenShiftCRDManager) Run

func (s *OpenShiftCRDManager) Run(ctx context.Context, ready chan<- struct{}, stopped chan<- struct{}) error

type OpenShiftDefaultSCCManager

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

func NewOpenShiftDefaultSCCManager

func NewOpenShiftDefaultSCCManager(cfg *config.Config) *OpenShiftDefaultSCCManager

func (*OpenShiftDefaultSCCManager) Dependencies

func (s *OpenShiftDefaultSCCManager) Dependencies() []string

func (*OpenShiftDefaultSCCManager) Name

func (s *OpenShiftDefaultSCCManager) Name() string

func (*OpenShiftDefaultSCCManager) Run

func (s *OpenShiftDefaultSCCManager) Run(ctx context.Context, ready chan<- struct{}, stopped chan<- struct{}) error

type VersionManager

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

func NewVersionManager

func NewVersionManager(cfg *config.Config) *VersionManager

func (*VersionManager) Dependencies

func (s *VersionManager) Dependencies() []string

func (*VersionManager) Name

func (s *VersionManager) Name() string

func (*VersionManager) Run

func (s *VersionManager) Run(ctx context.Context, ready chan<- struct{}, stopped chan<- struct{}) error