service

Dec 11, 2024

Changes in this version

+ const NamespaceAndClusterFormat

+ func DefaultSliceOperations(ctx context.Context, req ctrl.Request, logger *zap.SugaredLogger, ...) (ctrl.Result, error)

+ func DeregisterClusterFromDefaultSlice(ctx context.Context, req ctrl.Request, logger *zap.SugaredLogger, ...) (ctrl.Result, error)

Jul 4, 2024

Changes in this version

type IWorkerSliceConfigService

+ CreateMinimalWorkerSliceConfigForNoNetworkSlice func(ctx context.Context, clusters []string, namespace string, ...) error

type WorkerSliceConfigService

+ func (s *WorkerSliceConfigService) CreateMinimalWorkerSliceConfigForNoNetworkSlice(ctx context.Context, clusters []string, namespace string, ...) error

Jul 19, 2023

Changes in this version

+ const VPNKeyRotationConfigFinalizer

+ func ValidateVpnKeyRotationCreate(ctx context.Context, r *controllerv1alpha1.VpnKeyRotation) error

+ func ValidateVpnKeyRotationDelete(ctx context.Context, r *controllerv1alpha1.VpnKeyRotation) error

+ type IVpnKeyRotationService interface

+ CreateMinimalVpnKeyRotationConfig func(ctx context.Context, sliceName, namespace string, r int) error

+ ReconcileClusters func(ctx context.Context, sliceName, namespace string, clusters []string) (*controllerv1alpha1.VpnKeyRotation, error)

+ ReconcileVpnKeyRotation func(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

+ func WithVpnKeyRotationService(w IWorkerSliceGatewayService, ws IWorkerSliceConfigService) IVpnKeyRotationService

type IWorkerSliceGatewayService

+ BuildNetworkAddresses func(sliceSubnet, sourceClusterName, destinationClusterName string, ...) util.WorkerSliceGatewayNetworkAddresses

+ GenerateCerts func(ctx context.Context, sliceName string, namespace string, ...) error

+ type JobStatus int

+ const JobNotCreated

+ const JobStatusComplete

+ const JobStatusError

+ const JobStatusListError

+ const JobStatusRunning

+ const JobStatusSuspended

+ func (status JobStatus) String() string

type Services

+ VpnKeyRotationService IVpnKeyRotationService

+ type VpnKeyRotationService struct

+ func (v *VpnKeyRotationService) CreateMinimalVpnKeyRotationConfig(ctx context.Context, sliceName, namespace string, r int) error

+ func (v *VpnKeyRotationService) ReconcileClusters(ctx context.Context, sliceName, namespace string, clusters []string) (*controllerv1alpha1.VpnKeyRotation, error)

+ func (v *VpnKeyRotationService) ReconcileVpnKeyRotation(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

type WorkerSliceGatewayService

+ func (s *WorkerSliceGatewayService) BuildNetworkAddresses(sliceSubnet, sourceClusterName, destinationClusterName string, ...) util.WorkerSliceGatewayNetworkAddresses

+ func (s *WorkerSliceGatewayService) GenerateCerts(ctx context.Context, sliceName string, namespace string, ...) error

Jun 1, 2023

Changes in this version

type ISliceQoSConfigService

+ DeleteSliceQoSConfig func(ctx context.Context, namespace string) (ctrl.Result, error)

type SliceQoSConfigService

+ func (q *SliceQoSConfigService) DeleteSliceQoSConfig(ctx context.Context, namespace string) (ctrl.Result, error)

May 19, 2023

Changes in this version

+ func ValidateServiceExportConfigDelete(ctx context.Context, ...) error

May 9, 2023

Changes in this version

+ const ClusterDeregisterFinalizer

+ var MetricPort = "18080"

+ func WithMetricsRecorder() metrics.IMetricRecorder

Mar 10, 2023

Changes in this version

+ const ControllerNamespace

Jan 30, 2023

Changes in this version

+ type IWorkerSliceGatewayRecyclerService interface

+ DeleteWorkerSliceGatewayRecyclersByLabel func(ctx context.Context, label map[string]string, namespace string) error

+ ListWorkerSliceGatewayRecyclers func(ctx context.Context, ownerLabel map[string]string, namespace string) ([]v1alpha1.WorkerSliceGwRecycler, error)

+ func WithWorkerSliceGatewayRecyclerService() IWorkerSliceGatewayRecyclerService

type Services

+ WorkerSliceGatewayRecyclerService IWorkerSliceGatewayRecyclerService

+ type WorkerSliceGatewayRecyclerService struct

+ func (s *WorkerSliceGatewayRecyclerService) DeleteWorkerSliceGatewayRecyclersByLabel(ctx context.Context, label map[string]string, namespace string) error

+ func (s *WorkerSliceGatewayRecyclerService) ListWorkerSliceGatewayRecyclers(ctx context.Context, ownerLabel map[string]string, namespace string) ([]v1alpha1.WorkerSliceGwRecycler, error)

Aug 12, 2022

Changes in this version

+ const ResourceStatusSuffix

+ type AccessControlRuleProvider struct

+ func (k *AccessControlRuleProvider) ReadOnlyRoleRules() []rbacv1.PolicyRule

+ func (k *AccessControlRuleProvider) ReadWriteRoleRules() []rbacv1.PolicyRule

+ func (k *AccessControlRuleProvider) WorkerClusterRoleRules() []rbacv1.PolicyRule

+ type IAccessControlRuleProvider interface

+ ReadOnlyRoleRules func() []rbacv1.PolicyRule

+ ReadWriteRoleRules func() []rbacv1.PolicyRule

+ WorkerClusterRoleRules func() []rbacv1.PolicyRule

+ func WithAccessControlRuleProvider() IAccessControlRuleProvider

Jul 12, 2022

Changes in this version

+ func MutateClusterSpec(ctx context.Context, r *controllerv1alpha1.Cluster, req v1.AdmissionRequest) admission.Response

Aug 1, 2022

Changes in this version

+ const SliceQoSConfigFinalizer

+ const StandardQoSProfileLabel

+ func ValidateProjectDelete(ctx context.Context, project *controllerv1alpha1.Project) error

+ func ValidateSliceQosConfigCreate(ctx context.Context, sliceQoSConfig *controllerv1alpha1.SliceQoSConfig) error

+ func ValidateSliceQosConfigDelete(ctx context.Context, sliceQoSConfig *controllerv1alpha1.SliceQoSConfig) error

+ func ValidateSliceQosConfigUpdate(ctx context.Context, sliceQoSConfig *controllerv1alpha1.SliceQoSConfig) error

+ type ISliceQoSConfigService interface

+ ReconcileSliceQoSConfig func(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

+ func WithSliceQoSConfigService() ISliceQoSConfigService

type Services

+ SliceQoSConfigService ISliceQoSConfigService

+ type SliceQoSConfigService struct

+ func (q *SliceQoSConfigService) ReconcileSliceQoSConfig(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

May 18, 2022

Changes in this version

+ const AccessTypeAnnotationLabel

+ const AccessTypeClusterReadWrite

+ const AccessTypeReadOnly

+ const AccessTypeReadWrite

+ const ClusterFinalizer

+ const KubesliceWorkerDeleteRequeueTime

+ const ProjectFinalizer

+ const RequeueTime

+ const SliceConfigFinalizer

+ const WorkerServiceImportFinalizer

+ const WorkerSliceConfigFinalizer

+ const WorkerSliceGatewayFinalizer

+ var ControllerEndpoint = "https://controller.cisco.com:6443/"

+ var JobCredential = ""

+ var JobImage = "aveshasystems/gateway-certs-generator:latest"

+ var JobServiceAccount = "kubeslice-controller-ovpn-manager"

+ var ProjectNamespacePrefix = "kubeslice-controller-project-"

+ var RbacResourcePrefix = "kubeslice"

+ var RoleBindingReadOnlyUser = "kubeslice-ro-%s"

+ var RoleBindingReadWriteUser = "kubeslice-rw-%s"

+ var RoleBindingWorkerCluster = "kubeslice-worker-%s"

+ var ServiceAccountReadOnlyUser = "kubeslice-ro-%s"

+ var ServiceAccountReadWriteUser = "kubeslice-rw-%s"

+ var ServiceAccountWorkerCluster = "kubeslice-worker-%s"

+ func RemoveWorkerFinalizers(ctx context.Context, object client.Object, workerFinalizerName string) ctrl.Result

+ func ValidateClusterCreate(ctx context.Context, c *controllerv1alpha1.Cluster) error

+ func ValidateClusterDelete(ctx context.Context, c *controllerv1alpha1.Cluster) error

+ func ValidateClusterUpdate(ctx context.Context, c *controllerv1alpha1.Cluster) error

+ func ValidateProjectCreate(ctx context.Context, project *controllerv1alpha1.Project) error

+ func ValidateProjectUpdate(ctx context.Context, project *controllerv1alpha1.Project) error

+ func ValidateServiceExportConfigCreate(ctx context.Context, ...) error

+ func ValidateServiceExportConfigUpdate(ctx context.Context, ...) error

+ func ValidateSliceConfigCreate(ctx context.Context, sliceConfig *controllerv1alpha1.SliceConfig) error

+ func ValidateSliceConfigDelete(ctx context.Context, sliceConfig *controllerv1alpha1.SliceConfig) error

+ func ValidateSliceConfigUpdate(ctx context.Context, sliceConfig *controllerv1alpha1.SliceConfig) error

+ func ValidateWorkerSliceConfigUpdate(ctx context.Context, workerSliceConfig *workerv1alpha1.WorkerSliceConfig) error

+ func ValidateWorkerSliceGatewayUpdate(ctx context.Context, workerSliceGateway *workerv1alpha1.WorkerSliceGateway) error

+ type AccessControlService struct

+ func (a *AccessControlService) ReconcileReadOnlyRole(ctx context.Context, namespace string, owner client.Object) (ctrl.Result, error)

+ func (a *AccessControlService) ReconcileReadOnlyUserServiceAccountAndRoleBindings(ctx context.Context, namespace string, names []string, owner client.Object) (ctrl.Result, error)

+ func (a *AccessControlService) ReconcileReadWriteRole(ctx context.Context, namespace string, owner client.Object) (ctrl.Result, error)

+ func (a *AccessControlService) ReconcileReadWriteUserServiceAccountAndRoleBindings(ctx context.Context, namespace string, names []string, owner client.Object) (ctrl.Result, error)

+ func (a *AccessControlService) ReconcileWorkerClusterRole(ctx context.Context, namespace string, owner client.Object) (ctrl.Result, error)

+ func (a *AccessControlService) ReconcileWorkerClusterServiceAccountAndRoleBindings(ctx context.Context, clusterName, namespace string, owner client.Object) (ctrl.Result, error)

+ func (a *AccessControlService) RemoveWorkerClusterServiceAccountAndRoleBindings(ctx context.Context, clusterName, namespace string, owner client.Object) (ctrl.Result, error)

+ type CertPairRequestMap struct

+ Pairs []IndividualCertPairRequest

+ SliceName string

+ type ClusterService struct

+ func (c *ClusterService) DeleteClusters(ctx context.Context, namespace string) (ctrl.Result, error)

+ func (c *ClusterService) ReconcileCluster(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

+ type IAccessControlService interface

+ ReconcileReadOnlyRole func(ctx context.Context, namespace string, owner client.Object) (ctrl.Result, error)

+ ReconcileReadOnlyUserServiceAccountAndRoleBindings func(ctx context.Context, namespace string, names []string, owner client.Object) (ctrl.Result, error)

+ ReconcileReadWriteRole func(ctx context.Context, namespace string, owner client.Object) (ctrl.Result, error)

+ ReconcileReadWriteUserServiceAccountAndRoleBindings func(ctx context.Context, namespace string, names []string, owner client.Object) (ctrl.Result, error)

+ ReconcileWorkerClusterRole func(ctx context.Context, namespace string, owner client.Object) (ctrl.Result, error)

+ ReconcileWorkerClusterServiceAccountAndRoleBindings func(ctx context.Context, clusterName, namespace string, owner client.Object) (ctrl.Result, error)

+ RemoveWorkerClusterServiceAccountAndRoleBindings func(ctx context.Context, clusterName, namespace string, owner client.Object) (ctrl.Result, error)

+ func WithAccessControlService() IAccessControlService

+ type IClusterService interface

+ DeleteClusters func(ctx context.Context, namespace string) (ctrl.Result, error)

+ ReconcileCluster func(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

+ func WithClusterService() IClusterService

+ type IJobService interface

+ CreateJob func(ctx context.Context, namespace string, jobImage string, ...) (ctrl.Result, error)

+ func WithJobService() IJobService

+ type INamespaceService interface

+ DeleteNamespace func(ctx context.Context, namespace string) (ctrl.Result, error)

+ ReconcileProjectNamespace func(ctx context.Context, namespace string, owner client.Object) (ctrl.Result, error)

+ func WithNameSpaceService() INamespaceService

+ type IProjectService interface

+ ReconcileProject func(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

+ func WithProjectService() IProjectService

+ type ISecretService interface

+ DeleteSecret func(ctx context.Context, namespace string, secretName string) (ctrl.Result, error)

+ func WithSecretService() ISecretService

+ type IServiceExportConfigService interface

+ DeleteServiceExportConfigByParticipatingSliceConfig func(ctx context.Context, sliceName string, namespace string) error

+ DeleteServiceExportConfigs func(ctx context.Context, namespace string) (ctrl.Result, error)

+ ReconcileServiceExportConfig func(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

+ func WithServiceExportConfigService() IServiceExportConfigService

+ type ISliceConfigService interface

+ DeleteSliceConfigs func(ctx context.Context, namespace string) (ctrl.Result, error)

+ ReconcileSliceConfig func(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

+ func WithSliceConfigService() ISliceConfigService

+ type IWorkerServiceImportService interface

+ CreateMinimalWorkerServiceImport func(ctx context.Context, clusters []string, namespace string, ...) error

+ DeleteWorkerServiceImportByLabel func(ctx context.Context, label map[string]string, namespace string) error

+ ForceReconciliation func(ctx context.Context, list []workerv1alpha1.WorkerServiceImport) error

+ ListWorkerServiceImport func(ctx context.Context, ownerLabel map[string]string, namespace string) ([]workerv1alpha1.WorkerServiceImport, error)

+ LookupServiceExportForService func(ctx context.Context, ...) error

+ ReconcileWorkerServiceImport func(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

+ func WithWorkerServiceImportService() IWorkerServiceImportService

+ type IWorkerSliceConfigService interface

+ ComputeClusterMap func(clusterNames []string, workerSliceConfigs []workerv1alpha1.WorkerSliceConfig) map[string]int

+ CreateMinimalWorkerSliceConfig func(ctx context.Context, clusters []string, namespace string, ...) (map[string]int, error)

+ DeleteWorkerSliceConfigByLabel func(ctx context.Context, label map[string]string, namespace string) error

+ ListWorkerSliceConfigs func(ctx context.Context, ownerLabel map[string]string, namespace string) ([]workerv1alpha1.WorkerSliceConfig, error)

+ ReconcileWorkerSliceConfig func(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

+ func WithWorkerSliceConfigService() IWorkerSliceConfigService

+ type IWorkerSliceGatewayService interface

+ CreateMinimumWorkerSliceGateways func(ctx context.Context, sliceName string, clusterNames []string, namespace string, ...) (ctrl.Result, error)

+ DeleteWorkerSliceGatewaysByLabel func(ctx context.Context, label map[string]string, namespace string) error

+ ListWorkerSliceGateways func(ctx context.Context, ownerLabel map[string]string, namespace string) ([]v1alpha1.WorkerSliceGateway, error)

+ NodeIpReconciliationOfWorkerSliceGateways func(ctx context.Context, cluster *controllerv1alpha1.Cluster, namespace string) error

+ ReconcileWorkerSliceGateways func(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

+ func WithWorkerSliceGatewayService() IWorkerSliceGatewayService

+ type IndividualCertPairRequest struct

+ ClientId string

+ NsmClientNetwork string

+ NsmMask string

+ NsmServerNetwork string

+ ServerId string

+ VpnFqdn string

+ VpnIpToClient string

+ VpnMask string

+ VpnNetwork string

+ type JobService struct

+ func (j *JobService) CreateJob(ctx context.Context, namespace string, jobImage string, ...) (ctrl.Result, error)

+ type NamespaceService struct

+ func (n *NamespaceService) DeleteNamespace(ctx context.Context, namespace string) (ctrl.Result, error)

+ func (n *NamespaceService) ReconcileProjectNamespace(ctx context.Context, namespace string, owner client.Object) (ctrl.Result, error)

+ type ProjectService struct

+ func (t *ProjectService) CleanUpProjectResources(ctx context.Context, namespace string) (ctrl.Result, error)

+ func (t *ProjectService) ReconcileProject(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

+ type SecretService struct

+ func (s SecretService) DeleteSecret(ctx context.Context, namespace string, secretName string) (ctrl.Result, error)

+ type ServiceExportConfigService struct

+ func (s *ServiceExportConfigService) DeleteServiceExportConfigByParticipatingSliceConfig(ctx context.Context, sliceName string, namespace string) error

+ func (s *ServiceExportConfigService) DeleteServiceExportConfigs(ctx context.Context, namespace string) (ctrl.Result, error)

+ func (s *ServiceExportConfigService) ListServiceExportConfigs(ctx context.Context, namespace string) ([]controllerv1alpha1.ServiceExportConfig, error)

+ func (s *ServiceExportConfigService) ReconcileServiceExportConfig(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

+ type Services struct

+ ClusterService IClusterService

+ ProjectService IProjectService

+ ServiceExportConfigService IServiceExportConfigService

+ SliceConfigService ISliceConfigService

+ WorkerServiceImportService IWorkerServiceImportService

+ WorkerSliceConfigService IWorkerSliceConfigService

+ WorkerSliceGatewayService IWorkerSliceGatewayService

+ func WithServices() *Services

+ type SliceConfigService struct

+ func (s *SliceConfigService) DeleteSliceConfigs(ctx context.Context, namespace string) (ctrl.Result, error)

+ func (s SliceConfigService) ReconcileSliceConfig(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

+ type WorkerServiceImportService struct

+ func (s *WorkerServiceImportService) CreateMinimalWorkerServiceImport(ctx context.Context, clusters []string, namespace string, ...) error

+ func (s *WorkerServiceImportService) DeleteWorkerServiceImportByLabel(ctx context.Context, label map[string]string, namespace string) error

+ func (s *WorkerServiceImportService) ForceReconciliation(ctx context.Context, list []workerv1alpha1.WorkerServiceImport) error

+ func (s *WorkerServiceImportService) ListWorkerServiceImport(ctx context.Context, ownerLabel map[string]string, namespace string) ([]workerv1alpha1.WorkerServiceImport, error)

+ func (s *WorkerServiceImportService) LookupServiceExportForService(ctx context.Context, ...) error

+ func (s *WorkerServiceImportService) ReconcileWorkerServiceImport(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

+ type WorkerSliceConfigService struct

+ func (s *WorkerSliceConfigService) ComputeClusterMap(clusterNames []string, workerSliceConfigs []workerv1alpha1.WorkerSliceConfig) map[string]int

+ func (s *WorkerSliceConfigService) CreateMinimalWorkerSliceConfig(ctx context.Context, clusters []string, namespace string, ...) (map[string]int, error)

+ func (s *WorkerSliceConfigService) DeleteWorkerSliceConfigByLabel(ctx context.Context, label map[string]string, namespace string) error

+ func (s *WorkerSliceConfigService) ListWorkerSliceConfigs(ctx context.Context, ownerLabel map[string]string, namespace string) ([]workerv1alpha1.WorkerSliceConfig, error)

+ func (s *WorkerSliceConfigService) ReconcileWorkerSliceConfig(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

+ type WorkerSliceGatewayNetworkAddresses struct

+ ClientNetwork string

+ ClientSubnet string

+ ClientVpnAddress string

+ ServerNetwork string

+ ServerSubnet string

+ ServerVpnAddress string

+ ServerVpnNetwork string

+ type WorkerSliceGatewayService struct

+ func (s *WorkerSliceGatewayService) CreateMinimumWorkerSliceGateways(ctx context.Context, sliceName string, clusterNames []string, namespace string, ...) (ctrl.Result, error)

+ func (s *WorkerSliceGatewayService) DeleteWorkerSliceGatewaysByLabel(ctx context.Context, label map[string]string, namespace string) error

+ func (s *WorkerSliceGatewayService) ListWorkerSliceGateways(ctx context.Context, ownerLabel map[string]string, namespace string) ([]v1alpha1.WorkerSliceGateway, error)

+ func (s *WorkerSliceGatewayService) NodeIpReconciliationOfWorkerSliceGateways(ctx context.Context, cluster *controllerv1alpha1.Cluster, namespace string) error

+ func (s *WorkerSliceGatewayService) ReconcileWorkerSliceGateways(ctx context.Context, req ctrl.Request) (ctrl.Result, error)