Documentation ¶
Index ¶
- Constants
- Variables
- 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, old runtime.Object) error
- func ValidateProjectCreate(ctx context.Context, project *controllerv1alpha1.Project) error
- func ValidateProjectDelete(ctx context.Context, project *controllerv1alpha1.Project) error
- func ValidateProjectUpdate(ctx context.Context, project *controllerv1alpha1.Project) error
- func ValidateServiceExportConfigCreate(ctx context.Context, ...) error
- func ValidateServiceExportConfigDelete(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 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
- func ValidateWorkerSliceConfigUpdate(ctx context.Context, workerSliceConfig *workerv1alpha1.WorkerSliceConfig, ...) error
- func ValidateWorkerSliceGatewayUpdate(ctx context.Context, workerSliceGateway *workerv1alpha1.WorkerSliceGateway, ...) error
- func WithMetricsRecorder() metrics.IMetricRecorder
- type AccessControlRuleProvider
- type AccessControlService
- 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
- type ClusterService
- type IAccessControlRuleProvider
- type IAccessControlService
- type IClusterService
- type IJobService
- type INamespaceService
- type IProjectService
- type ISecretService
- type IServiceExportConfigService
- type ISliceConfigService
- type ISliceQoSConfigService
- type IWorkerServiceImportService
- type IWorkerSliceConfigService
- type IWorkerSliceGatewayRecyclerService
- type IWorkerSliceGatewayService
- type IndividualCertPairRequest
- type JobService
- type NamespaceService
- type ProjectService
- type SecretService
- type ServiceExportConfigService
- 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
- type SliceConfigService
- type SliceQoSConfigService
- type WorkerServiceImportService
- 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
- 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
- type WorkerSliceGatewayRecyclerService
- 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)
- type WorkerSliceGatewayService
- 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)
Constants ¶
const ( AccessTypeAnnotationLabel = "access-type" AccessTypeClusterReadWrite = "cluster-read-write" AccessTypeReadOnly = "read-only" AccessTypeReadWrite = "read-write" )
Access Types
const ( ProjectFinalizer = "controller.kubeslice.io/project-finalizer" ClusterFinalizer = "controller.kubeslice.io/cluster-finalizer" ClusterDeregisterFinalizer = "worker.kubeslice.io/cluster-deregister-finalizer" SliceConfigFinalizer = "controller.kubeslice.io/slice-configuration-finalizer" WorkerSliceConfigFinalizer = "worker.kubeslice.io/worker-slice-configuration-finalizer" WorkerSliceGatewayFinalizer = "worker.kubeslice.io/worker-slice-gateway-finalizer" WorkerServiceImportFinalizer = "worker.kubeslice.io/worker-service-import-finalizer" SliceQoSConfigFinalizer = "controller.kubeslice.io/slice-qos-config-finalizer" )
Finalizers
const (
ControllerNamespace = "kubeslice-controller"
)
ControllerNamespace Controller Namespace
const (
KubesliceWorkerDeleteRequeueTime = 3
)
const (
RequeueTime = time.Duration(30000000000)
)
Request Timeout
const (
ResourceStatusSuffix = "/status"
)
Resources
const (
StandardQoSProfileLabel = "standard-qos-profile"
)
StandardQoSProfileLabel name
Variables ¶
var ( RoleBindingWorkerCluster = "kubeslice-worker-%s" RoleBindingReadOnlyUser = "kubeslice-ro-%s" RoleBindingReadWriteUser = "kubeslice-rw-%s" )
RoleBinding Names
var ( ServiceAccountWorkerCluster = "kubeslice-worker-%s" ServiceAccountReadOnlyUser = "kubeslice-ro-%s" ServiceAccountReadWriteUser = "kubeslice-rw-%s" )
ServiceAccount Names
var ( // Job Image JobImage = "aveshasystems/gateway-certs-generator:latest" JobCredential = "" JobServiceAccount = "kubeslice-controller-ovpn-manager" )
var (
ControllerEndpoint = "https://controller.cisco.com:6443/"
)
ControllerEndpoint
var (
MetricPort = "18080"
)
var (
ProjectNamespacePrefix = "kubeslice-controller-project-"
)
Project Namespace prefix. Customer can over ride this.
var RbacResourcePrefix = "kubeslice"
Functions ¶
func RemoveWorkerFinalizers ¶
func RemoveWorkerFinalizers(ctx context.Context, object client.Object, workerFinalizerName string) ctrl.Result
RemoveWorkerFinalizers removes the finalizer specified by workerFinalizerName from the object's finalizers list. If the workerFinalizerName is not found in the initial finalizers list, all finalizers are removed and the function returns the reconciliation result for no-requeue. If the finalizers list is empty after the removal, the function returns the reconciliation result for no-requeue. If the finalizers list is non-empty after the removal, the function returns the reconciliation result for delayed requeue.
func ValidateClusterCreate ¶
func ValidateClusterCreate(ctx context.Context, c *controllerv1alpha1.Cluster) error
ValidateClusterCreate is a function to validate the creation of cluster
func ValidateClusterDelete ¶
func ValidateClusterDelete(ctx context.Context, c *controllerv1alpha1.Cluster) error
ValidateClusterDelete is a function to validate the deletion of cluster
func ValidateClusterUpdate ¶
func ValidateClusterUpdate(ctx context.Context, c *controllerv1alpha1.Cluster, old runtime.Object) error
ValidateClusterUpdate is a function to validate to the update of specification of cluster
func ValidateProjectCreate ¶
func ValidateProjectCreate(ctx context.Context, project *controllerv1alpha1.Project) error
ValidateProjectCreate is a function to validate the creation of project
func ValidateProjectDelete ¶ added in v0.2.1
func ValidateProjectDelete(ctx context.Context, project *controllerv1alpha1.Project) error
func ValidateProjectUpdate ¶
func ValidateProjectUpdate(ctx context.Context, project *controllerv1alpha1.Project) error
ValidateProjectUpdate is a function to verify the project - service account, role binding, service account names
func ValidateServiceExportConfigCreate ¶
func ValidateServiceExportConfigCreate(ctx context.Context, serviceExportConfig *controllerv1alpha1.ServiceExportConfig) error
ValidateServiceExportConfigCreate is a function to validate the create process of service export config
func ValidateServiceExportConfigDelete ¶ added in v0.10.1
func ValidateServiceExportConfigDelete(ctx context.Context, serviceExportConfig *controllerv1alpha1.ServiceExportConfig) error
ValidateServiceExportConfigDelete is a function to validate the delete process of service export config
func ValidateServiceExportConfigUpdate ¶
func ValidateServiceExportConfigUpdate(ctx context.Context, serviceExportConfig *controllerv1alpha1.ServiceExportConfig) error
ValidateServiceExportConfigUpdate is a function to validate the update process of service export config
func ValidateSliceConfigCreate ¶
func ValidateSliceConfigCreate(ctx context.Context, sliceConfig *controllerv1alpha1.SliceConfig) error
ValidateSliceConfigCreate is a function to verify the creation of slice config
func ValidateSliceConfigDelete ¶
func ValidateSliceConfigDelete(ctx context.Context, sliceConfig *controllerv1alpha1.SliceConfig) error
ValidateSliceConfigDelete is function to validate the deletion of sliceConfig
func ValidateSliceConfigUpdate ¶
func ValidateSliceConfigUpdate(ctx context.Context, sliceConfig *controllerv1alpha1.SliceConfig, old runtime.Object) error
ValidateSliceConfigUpdate is function to verify the update of slice config
func ValidateSliceQosConfigCreate ¶ added in v0.2.1
func ValidateSliceQosConfigCreate(ctx context.Context, sliceQoSConfig *controllerv1alpha1.SliceQoSConfig) error
ValidateSliceQosConfigCreate is a function to validate the creation of SliceQosConfig
func ValidateSliceQosConfigDelete ¶ added in v0.2.1
func ValidateSliceQosConfigDelete(ctx context.Context, sliceQoSConfig *controllerv1alpha1.SliceQoSConfig) error
ValidateSliceQosConfigDelete is a function to validate the deletion of SliceQosConfig
func ValidateSliceQosConfigUpdate ¶ added in v0.2.1
func ValidateSliceQosConfigUpdate(ctx context.Context, sliceQoSConfig *controllerv1alpha1.SliceQoSConfig) error
ValidateSliceQosConfigUpdate is a function to validate the update of SliceQosConfig
func ValidateWorkerSliceConfigUpdate ¶
func ValidateWorkerSliceConfigUpdate(ctx context.Context, workerSliceConfig *workerv1alpha1.WorkerSliceConfig, old runtime.Object) error
ValidateWorkerSliceConfigUpdate is a function to verify the update of config of workerslice
func ValidateWorkerSliceGatewayUpdate ¶
func ValidateWorkerSliceGatewayUpdate(ctx context.Context, workerSliceGateway *workerv1alpha1.WorkerSliceGateway, old runtime.Object) error
ValidateWorkerSliceGatewayUpdate is function to validate the update of gateways
func WithMetricsRecorder ¶ added in v0.9.0
func WithMetricsRecorder() metrics.IMetricRecorder
Types ¶
type AccessControlRuleProvider ¶ added in v0.5.2
type AccessControlRuleProvider struct { }
func (*AccessControlRuleProvider) ReadOnlyRoleRules ¶ added in v0.5.2
func (k *AccessControlRuleProvider) ReadOnlyRoleRules() []rbacv1.PolicyRule
func (*AccessControlRuleProvider) ReadWriteRoleRules ¶ added in v0.5.2
func (k *AccessControlRuleProvider) ReadWriteRoleRules() []rbacv1.PolicyRule
func (*AccessControlRuleProvider) WorkerClusterRoleRules ¶ added in v0.5.2
func (k *AccessControlRuleProvider) WorkerClusterRoleRules() []rbacv1.PolicyRule
type AccessControlService ¶
type AccessControlService struct {
// contains filtered or unexported fields
}
func (*AccessControlService) ReconcileReadOnlyRole ¶
func (a *AccessControlService) ReconcileReadOnlyRole(ctx context.Context, namespace string, owner client.Object) (ctrl.Result, error)
ReconcileReadOnlyRole reconciles the read only role for the project users
func (*AccessControlService) ReconcileReadOnlyUserServiceAccountAndRoleBindings ¶
func (a *AccessControlService) ReconcileReadOnlyUserServiceAccountAndRoleBindings(ctx context.Context, namespace string, names []string, owner client.Object) (ctrl.Result, error)
ReconcileReadOnlyUserServiceAccountAndRoleBindings reconciles the service account and role bindings for read only users
func (*AccessControlService) ReconcileReadWriteRole ¶
func (a *AccessControlService) ReconcileReadWriteRole(ctx context.Context, namespace string, owner client.Object) (ctrl.Result, error)
ReconcileReadWriteRole reconciles the read write role binding for project users
func (*AccessControlService) ReconcileReadWriteUserServiceAccountAndRoleBindings ¶
func (a *AccessControlService) ReconcileReadWriteUserServiceAccountAndRoleBindings(ctx context.Context, namespace string, names []string, owner client.Object) (ctrl.Result, error)
ReconcileReadWriteUserServiceAccountAndRoleBindings reconciles the service account and role bindings for read write users
func (*AccessControlService) ReconcileWorkerClusterRole ¶
func (a *AccessControlService) ReconcileWorkerClusterRole(ctx context.Context, namespace string, owner client.Object) (ctrl.Result, error)
ReconcileWorkerClusterRole reconciles the worker cluster role
func (*AccessControlService) ReconcileWorkerClusterServiceAccountAndRoleBindings ¶
func (a *AccessControlService) ReconcileWorkerClusterServiceAccountAndRoleBindings(ctx context.Context, clusterName, namespace string, owner client.Object) (ctrl.Result, error)
ReconcileWorkerClusterServiceAccountAndRoleBindings reconciles the service account and role bindings for worker cluster
func (*AccessControlService) RemoveWorkerClusterServiceAccountAndRoleBindings ¶
func (a *AccessControlService) RemoveWorkerClusterServiceAccountAndRoleBindings(ctx context.Context, clusterName, namespace string, owner client.Object) (ctrl.Result, error)
RemoveWorkerClusterServiceAccountAndRoleBindings remove the service account and role bindings for worker cluster
type CertPairRequestMap ¶
type CertPairRequestMap struct { SliceName string `json:"sliceName,omitempty"` Pairs []IndividualCertPairRequest `json:"pairs,omitempty"` }
type ClusterService ¶
type ClusterService struct {
// contains filtered or unexported fields
}
ClusterService struct implements different service interfaces
func (*ClusterService) DeleteClusters ¶
DeleteClusters is function to delete the clusters
func (*ClusterService) ReconcileCluster ¶
func (c *ClusterService) ReconcileCluster(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
ReconcileCluster is function to reconcile cluster
type IAccessControlRuleProvider ¶ added in v0.5.2
type IAccessControlRuleProvider interface { WorkerClusterRoleRules() []rbacv1.PolicyRule ReadOnlyRoleRules() []rbacv1.PolicyRule ReadWriteRoleRules() []rbacv1.PolicyRule }
func WithAccessControlRuleProvider ¶ added in v0.5.2
func WithAccessControlRuleProvider() IAccessControlRuleProvider
type IAccessControlService ¶
type IAccessControlService interface { ReconcileWorkerClusterRole(ctx context.Context, namespace string, owner client.Object) (ctrl.Result, error) ReconcileReadOnlyRole(ctx context.Context, namespace string, owner client.Object) (ctrl.Result, error) ReconcileReadWriteRole(ctx context.Context, namespace string, owner client.Object) (ctrl.Result, error) ReconcileReadOnlyUserServiceAccountAndRoleBindings(ctx context.Context, namespace string, names []string, owner client.Object) (ctrl.Result, error) ReconcileReadWriteUserServiceAccountAndRoleBindings(ctx context.Context, namespace string, names []string, owner client.Object) (ctrl.Result, error) ReconcileWorkerClusterServiceAccountAndRoleBindings(ctx context.Context, clusterName, namespace string, owner client.Object) (ctrl.Result, error) RemoveWorkerClusterServiceAccountAndRoleBindings(ctx context.Context, clusterName, namespace string, owner client.Object) (ctrl.Result, error) }
func WithAccessControlService ¶
func WithAccessControlService(ruleProvider IAccessControlRuleProvider, mf metrics.IMetricRecorder) IAccessControlService
bootstrapping accesscontrol service
type IClusterService ¶
type IClusterService interface { ReconcileCluster(ctx context.Context, req ctrl.Request) (ctrl.Result, error) DeleteClusters(ctx context.Context, namespace string) (ctrl.Result, error) }
func WithClusterService ¶
func WithClusterService( ns INamespaceService, acs IAccessControlService, sgws IWorkerSliceGatewayService, mf metrics.IMetricRecorder, ) IClusterService
bootstrapping cluster service
type IJobService ¶
type INamespaceService ¶
type INamespaceService interface { ReconcileProjectNamespace(ctx context.Context, namespace string, owner client.Object) (ctrl.Result, error) DeleteNamespace(ctx context.Context, namespace string) (ctrl.Result, error) }
func WithNameSpaceService ¶
func WithNameSpaceService(mf metrics.IMetricRecorder) INamespaceService
bootstrapping namespace service
type IProjectService ¶
type IProjectService interface {
ReconcileProject(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
}
func WithProjectService ¶
func WithProjectService( ns INamespaceService, acs IAccessControlService, c IClusterService, sc ISliceConfigService, se IServiceExportConfigService, q ISliceQoSConfigService, mf metrics.IMetricRecorder, ) IProjectService
bootstrapping Project services
type ISecretService ¶
type ISecretService interface {
DeleteSecret(ctx context.Context, namespace string, secretName string) (ctrl.Result, error)
}
func WithSecretService ¶
func WithSecretService(mf metrics.IMetricRecorder) ISecretService
bootstrapping secret service
type IServiceExportConfigService ¶
type IServiceExportConfigService interface { ReconcileServiceExportConfig(ctx context.Context, req ctrl.Request) (ctrl.Result, error) DeleteServiceExportConfigs(ctx context.Context, namespace string) (ctrl.Result, error) DeleteServiceExportConfigByParticipatingSliceConfig(ctx context.Context, sliceName string, namespace string) error }
func WithServiceExportConfigService ¶
func WithServiceExportConfigService(ses IWorkerServiceImportService, mf metrics.IMetricRecorder) IServiceExportConfigService
bootstrapping service export config service
type ISliceConfigService ¶
type ISliceConfigService interface { ReconcileSliceConfig(ctx context.Context, req ctrl.Request) (ctrl.Result, error) DeleteSliceConfigs(ctx context.Context, namespace string) (ctrl.Result, error) }
func WithSliceConfigService ¶
func WithSliceConfigService( ns INamespaceService, acs IAccessControlService, sgs IWorkerSliceGatewayService, ms IWorkerSliceConfigService, si IWorkerServiceImportService, se IServiceExportConfigService, wsgrs IWorkerSliceGatewayRecyclerService, mf metrics.IMetricRecorder, ) ISliceConfigService
bootstrapping slice config service
type ISliceQoSConfigService ¶ added in v0.2.1
type ISliceQoSConfigService interface { ReconcileSliceQoSConfig(ctx context.Context, req ctrl.Request) (ctrl.Result, error) DeleteSliceQoSConfig(ctx context.Context, namespace string) (ctrl.Result, error) }
func WithSliceQoSConfigService ¶ added in v0.2.1
func WithSliceQoSConfigService(wsc IWorkerSliceConfigService, mf metrics.IMetricRecorder) ISliceQoSConfigService
bootstrapping slice qos config service
type IWorkerServiceImportService ¶
type IWorkerServiceImportService interface { ReconcileWorkerServiceImport(ctx context.Context, req ctrl.Request) (ctrl.Result, error) CreateMinimalWorkerServiceImport(ctx context.Context, clusters []string, namespace string, label map[string]string, serviceName string, serviceNamespace string, sliceName string, aliases []string) error DeleteWorkerServiceImportByLabel(ctx context.Context, label map[string]string, namespace string) error ListWorkerServiceImport(ctx context.Context, ownerLabel map[string]string, namespace string) ([]workerv1alpha1.WorkerServiceImport, error) ForceReconciliation(ctx context.Context, list []workerv1alpha1.WorkerServiceImport) error LookupServiceExportForService(ctx context.Context, serviceExportList *controllerv1alpha1.ServiceExportConfigList, namespace, serviceName, serviceNamespace, sliceName string) error }
func WithWorkerServiceImportService ¶
func WithWorkerServiceImportService(mf metrics.IMetricRecorder) IWorkerServiceImportService
bootstrapping worker service import service
type IWorkerSliceConfigService ¶
type IWorkerSliceConfigService interface { ReconcileWorkerSliceConfig(ctx context.Context, req ctrl.Request) (ctrl.Result, error) DeleteWorkerSliceConfigByLabel(ctx context.Context, label map[string]string, namespace string) error ListWorkerSliceConfigs(ctx context.Context, ownerLabel map[string]string, namespace string) ([]workerv1alpha1.WorkerSliceConfig, error) ComputeClusterMap(clusterNames []string, workerSliceConfigs []workerv1alpha1.WorkerSliceConfig) map[string]int CreateMinimalWorkerSliceConfig(ctx context.Context, clusters []string, namespace string, label map[string]string, name, sliceSubnet string, clusterCidr string) (map[string]int, error) }
func WithWorkerSliceConfigService ¶
func WithWorkerSliceConfigService(mf metrics.IMetricRecorder) IWorkerSliceConfigService
bootstrapping worker slice config service
type IWorkerSliceGatewayRecyclerService ¶ added in v0.6.8
type IWorkerSliceGatewayRecyclerService interface { ListWorkerSliceGatewayRecyclers(ctx context.Context, ownerLabel map[string]string, namespace string) ([]v1alpha1.WorkerSliceGwRecycler, error) DeleteWorkerSliceGatewayRecyclersByLabel(ctx context.Context, label map[string]string, namespace string) error }
func WithWorkerSliceGatewayRecyclerService ¶ added in v0.6.8
func WithWorkerSliceGatewayRecyclerService() IWorkerSliceGatewayRecyclerService
WithWorkerSliceGatewayRecyclerService bootstraps slice gateway_recycler service
type IWorkerSliceGatewayService ¶
type IWorkerSliceGatewayService interface { ReconcileWorkerSliceGateways(ctx context.Context, req ctrl.Request) (ctrl.Result, error) CreateMinimumWorkerSliceGateways(ctx context.Context, sliceName string, clusterNames []string, namespace string, label map[string]string, clusterMap map[string]int, sliceSubnet string, clusterCidr string) (ctrl.Result, error) ListWorkerSliceGateways(ctx context.Context, ownerLabel map[string]string, namespace string) ([]v1alpha1.WorkerSliceGateway, error) DeleteWorkerSliceGatewaysByLabel(ctx context.Context, label map[string]string, namespace string) error NodeIpReconciliationOfWorkerSliceGateways(ctx context.Context, cluster *controllerv1alpha1.Cluster, namespace string) error }
func WithWorkerSliceGatewayService ¶
func WithWorkerSliceGatewayService( js IJobService, sscs IWorkerSliceConfigService, sc ISecretService, mf metrics.IMetricRecorder, ) IWorkerSliceGatewayService
bootstrapping slice gateway service
type IndividualCertPairRequest ¶
type IndividualCertPairRequest struct { VpnFqdn string `json:"vpnFqdn,omitempty"` // The NSM server network. NsmServerNetwork string `json:"nsmServerNetwork,omitempty"` // The NSM client network. NsmClientNetwork string `json:"nsmClientNetwork,omitempty"` // The NSM mask. NsmMask string `json:"nsmMask,omitempty"` // VPN's IP address to client. VpnIpToClient string `json:"vpnIpToClient,omitempty"` // VPN's network IP. VpnNetwork string `json:"vpnNetwork,omitempty"` // VPN's IP mask. VpnMask string `json:"vpnMask,omitempty"` // The client gateway ID. ClientId string `json:"clientId,omitempty"` // The server gateway ID. ServerId string `json:"serverId,omitempty"` }
IndividualCertPairRequest Parameters for individual certificate pair generations.
type JobService ¶
type JobService struct{}
type NamespaceService ¶
type NamespaceService struct {
// contains filtered or unexported fields
}
func (*NamespaceService) DeleteNamespace ¶
func (n *NamespaceService) DeleteNamespace(ctx context.Context, namespace string) (ctrl.Result, error)
DeleteNamespace is a function deletes the namespace
type ProjectService ¶
type ProjectService struct {
// contains filtered or unexported fields
}
ProjectService implements different service interfaces
func (*ProjectService) CleanUpProjectResources ¶
func (*ProjectService) ReconcileProject ¶
func (t *ProjectService) ReconcileProject(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
ReconcileProject is a function to reconcile the projects includes reconciliation of roles, clusters, project namespaces etc.
type SecretService ¶
type SecretService struct {
// contains filtered or unexported fields
}
func (*SecretService) DeleteSecret ¶
func (s *SecretService) DeleteSecret(ctx context.Context, namespace string, secretName string) (ctrl.Result, error)
DeleteSecret is a function to delete the secret
type ServiceExportConfigService ¶
type ServiceExportConfigService struct {
// contains filtered or unexported fields
}
func (*ServiceExportConfigService) DeleteServiceExportConfigByParticipatingSliceConfig ¶
func (s *ServiceExportConfigService) DeleteServiceExportConfigByParticipatingSliceConfig(ctx context.Context, sliceName string, namespace string) error
DeleteServiceExportConfigByParticipatingSliceConfig is a function to delete the export config which are in slice
func (*ServiceExportConfigService) DeleteServiceExportConfigs ¶
func (s *ServiceExportConfigService) DeleteServiceExportConfigs(ctx context.Context, namespace string) (ctrl.Result, error)
DeleteServiceExportConfigs is a function to delete the export configs
func (*ServiceExportConfigService) ListServiceExportConfigs ¶
func (s *ServiceExportConfigService) ListServiceExportConfigs(ctx context.Context, namespace string) ([]controllerv1alpha1.ServiceExportConfig, error)
func (*ServiceExportConfigService) ReconcileServiceExportConfig ¶
func (s *ServiceExportConfigService) ReconcileServiceExportConfig(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
ReconcileServiceExportConfig is a function to reconcile the service export config
type Services ¶
type Services struct { ProjectService IProjectService ClusterService IClusterService SliceConfigService ISliceConfigService ServiceExportConfigService IServiceExportConfigService WorkerSliceConfigService IWorkerSliceConfigService WorkerSliceGatewayService IWorkerSliceGatewayService WorkerServiceImportService IWorkerServiceImportService SliceQoSConfigService ISliceQoSConfigService WorkerSliceGatewayRecyclerService IWorkerSliceGatewayRecyclerService }
func WithServices ¶
func WithServices( wscs IWorkerSliceConfigService, ps IProjectService, cs IClusterService, scs ISliceConfigService, secs IServiceExportConfigService, wsgs IWorkerSliceGatewayService, wsis IWorkerServiceImportService, sqcs ISliceQoSConfigService, wsgrs IWorkerSliceGatewayRecyclerService, ) *Services
bootstrapping Services
type SliceConfigService ¶
type SliceConfigService struct {
// contains filtered or unexported fields
}
SliceConfigService implements different interfaces -
func (*SliceConfigService) DeleteSliceConfigs ¶
func (s *SliceConfigService) DeleteSliceConfigs(ctx context.Context, namespace string) (ctrl.Result, error)
DeleteSliceConfigs is a function to delete the sliceconfigs
func (*SliceConfigService) ReconcileSliceConfig ¶
func (s *SliceConfigService) ReconcileSliceConfig(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
ReconcileSliceConfig is a function to reconcile the sliceconfig
type SliceQoSConfigService ¶ added in v0.2.1
type SliceQoSConfigService struct {
// contains filtered or unexported fields
}
SliceQoSConfigService implements different service interfaces
func (*SliceQoSConfigService) DeleteSliceQoSConfig ¶ added in v0.11.0
func (q *SliceQoSConfigService) DeleteSliceQoSConfig(ctx context.Context, namespace string) (ctrl.Result, error)
DeleteSliceQoSConfig is a function to delete the slice qos config
func (*SliceQoSConfigService) ReconcileSliceQoSConfig ¶ added in v0.2.1
func (q *SliceQoSConfigService) ReconcileSliceQoSConfig(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
ReconcileSliceQoSConfig is a function to reconcile the qos_profile
type WorkerServiceImportService ¶
type WorkerServiceImportService struct {
// contains filtered or unexported fields
}
func (*WorkerServiceImportService) CreateMinimalWorkerServiceImport ¶
func (s *WorkerServiceImportService) CreateMinimalWorkerServiceImport(ctx context.Context, clusters []string, namespace string, label map[string]string, serviceName string, serviceNamespace string, sliceName string, aliases []string) error
CreateMinimalWorkerServiceImport is a function to create the service import on worker object/cluster
func (*WorkerServiceImportService) DeleteWorkerServiceImportByLabel ¶
func (s *WorkerServiceImportService) DeleteWorkerServiceImportByLabel(ctx context.Context, label map[string]string, namespace string) error
DeleteWorkerServiceImportByLabel is function to delete the service import from worker cluster/object
func (*WorkerServiceImportService) ForceReconciliation ¶
func (s *WorkerServiceImportService) ForceReconciliation(ctx context.Context, list []workerv1alpha1.WorkerServiceImport) error
ForceReconciliation is a function to update the worker service import
func (*WorkerServiceImportService) ListWorkerServiceImport ¶
func (s *WorkerServiceImportService) ListWorkerServiceImport(ctx context.Context, ownerLabel map[string]string, namespace string) ([]workerv1alpha1.WorkerServiceImport, error)
ListWorkerServiceImport is a function to list down the serviceImport
func (*WorkerServiceImportService) LookupServiceExportForService ¶
func (s *WorkerServiceImportService) LookupServiceExportForService(ctx context.Context, serviceExportList *controllerv1alpha1.ServiceExportConfigList, namespace, serviceName, serviceNamespace, sliceName string) error
LookupServiceExportForService Returns a list of non-deleted ServiceExport for the service configuration
func (*WorkerServiceImportService) ReconcileWorkerServiceImport ¶
func (s *WorkerServiceImportService) ReconcileWorkerServiceImport(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
ReconcileWorkerServiceImport is a function to reconcile the service import for worker object
type WorkerSliceConfigService ¶
type WorkerSliceConfigService struct {
// contains filtered or unexported fields
}
WorkerSliceConfigService implements the IWorkerSliceConfigService interface
func (*WorkerSliceConfigService) ComputeClusterMap ¶
func (s *WorkerSliceConfigService) ComputeClusterMap(clusterNames []string, workerSliceConfigs []workerv1alpha1.WorkerSliceConfig) map[string]int
ComputeClusterMap - function assigns a numerical value to the cluster. The value will be from 1 to n, where n is the number of clusters in the slice.
func (*WorkerSliceConfigService) CreateMinimalWorkerSliceConfig ¶
func (s *WorkerSliceConfigService) CreateMinimalWorkerSliceConfig(ctx context.Context, clusters []string, namespace string, label map[string]string, name, sliceSubnet string, clusterCidr string) (map[string]int, error)
CreateMinimalWorkerSliceConfig CreateWorkerSliceConfig is a function to create the worker slice configs with minimum number of fields. More fields are added in reconciliation loop.
func (*WorkerSliceConfigService) DeleteWorkerSliceConfigByLabel ¶
func (s *WorkerSliceConfigService) DeleteWorkerSliceConfigByLabel(ctx context.Context, label map[string]string, namespace string) error
DeleteWorkerSliceConfigByLabel is a function to delete configs of workerslice by label
func (*WorkerSliceConfigService) ListWorkerSliceConfigs ¶
func (s *WorkerSliceConfigService) ListWorkerSliceConfigs(ctx context.Context, ownerLabel map[string]string, namespace string) ([]workerv1alpha1.WorkerSliceConfig, error)
ListWorkerSliceConfigs
func (*WorkerSliceConfigService) ReconcileWorkerSliceConfig ¶
func (s *WorkerSliceConfigService) ReconcileWorkerSliceConfig(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
ReconcileWorkerSliceConfig is a function to reconcile the config of worker slice
type WorkerSliceGatewayNetworkAddresses ¶
type WorkerSliceGatewayNetworkAddresses struct { ServerNetwork string ClientNetwork string ServerSubnet string ClientSubnet string ServerVpnNetwork string ServerVpnAddress string ClientVpnAddress string }
WorkerSliceGatewayNetworkAddresses is a schema for WorkerSlice gateway network parameters
type WorkerSliceGatewayRecyclerService ¶ added in v0.6.8
type WorkerSliceGatewayRecyclerService struct{}
WorkerSliceGatewayRecyclerService is a schema for interfaces JobService, WorkerSliceConfigService, SecretService
func (*WorkerSliceGatewayRecyclerService) DeleteWorkerSliceGatewayRecyclersByLabel ¶ added in v0.6.8
func (s *WorkerSliceGatewayRecyclerService) DeleteWorkerSliceGatewayRecyclersByLabel(ctx context.Context, label map[string]string, namespace string) error
DeleteWorkerSliceGatewayRecyclersByLabel is a function to delete worker slice gateway by label
func (*WorkerSliceGatewayRecyclerService) ListWorkerSliceGatewayRecyclers ¶ added in v0.6.8
func (s *WorkerSliceGatewayRecyclerService) ListWorkerSliceGatewayRecyclers(ctx context.Context, ownerLabel map[string]string, namespace string) ([]v1alpha1.WorkerSliceGwRecycler, error)
ListWorkerSliceGatewayRecyclers is a function to list down the established gateways
type WorkerSliceGatewayService ¶
type WorkerSliceGatewayService struct {
// contains filtered or unexported fields
}
WorkerSliceGatewayService is a schema for interfaces JobService, WorkerSliceConfigService, SecretService
func (*WorkerSliceGatewayService) CreateMinimumWorkerSliceGateways ¶
func (s *WorkerSliceGatewayService) CreateMinimumWorkerSliceGateways(ctx context.Context, sliceName string, clusterNames []string, namespace string, label map[string]string, clusterMap map[string]int, sliceSubnet string, clusterCidr string) (ctrl.Result, error)
CreateMinimumWorkerSliceGateways is a function to create gateways with minimum specification
func (*WorkerSliceGatewayService) DeleteWorkerSliceGatewaysByLabel ¶
func (s *WorkerSliceGatewayService) DeleteWorkerSliceGatewaysByLabel(ctx context.Context, label map[string]string, namespace string) error
DeleteWorkerSliceGatewaysByLabel is a function to delete worker slice gateway by label
func (*WorkerSliceGatewayService) ListWorkerSliceGateways ¶
func (s *WorkerSliceGatewayService) ListWorkerSliceGateways(ctx context.Context, ownerLabel map[string]string, namespace string) ([]v1alpha1.WorkerSliceGateway, error)
ListWorkerSliceGateways is a function to list down the established gateways
func (*WorkerSliceGatewayService) NodeIpReconciliationOfWorkerSliceGateways ¶
func (s *WorkerSliceGatewayService) NodeIpReconciliationOfWorkerSliceGateways(ctx context.Context, cluster *controllerv1alpha1.Cluster, namespace string) error
NodeIpReconciliationOfWorkerSliceGateways is a function to update the NodeIP of local gateway
func (*WorkerSliceGatewayService) ReconcileWorkerSliceGateways ¶
func (s *WorkerSliceGatewayService) ReconcileWorkerSliceGateways(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
ReconcileWorkerSliceGateways is a function to reconcile/restore the worker slice gateways
Source Files ¶
- access_control_service.go
- bootstrap.go
- cluster_service.go
- cluster_webhook_validation.go
- doc.go
- job_service.go
- kube_slice_resource_names.go
- namespace_service.go
- project_service.go
- project_webhook_validation.go
- secret_service.go
- service_export_config_service.go
- service_export_config_webhook_validation.go
- service_helper.go
- slice_config_service.go
- slice_config_webhook_validation.go
- slice_qos_config_service.go
- slice_qos_config_webhook_validation.go
- worker_service_import_service.go
- worker_slice_config_service.go
- worker_slice_config_webhook_validation.go
- worker_slice_gateway_recycler_service.go
- worker_slice_gateway_service.go
- worker_slice_gateway_webhook_validation.go