cluster

package

Go to main page

Versions in this module

v0

v0.3.6

Jul 28, 2023

v0.3.5

Jul 14, 2023

Changes in this version

+ type CaBundleList struct

+ Default string

+ Gitlab string

type ClusterRegistration

+ CaBundleList CaBundleList

type ClusterRegistrationParam

+ CaBundleList CaBundleList

v0.3.4

Jul 4, 2023

v0.3.3

Jun 21, 2023

v0.3.1

Jun 9, 2023

Changes in this version

type ClusterRegistration

+ func (cr *ClusterRegistration) GetClsuter(tenantLocalPath, clusterName string) (*resourcev1alpha1.Cluster, error)

+ func (cr *ClusterRegistration) GetClsuters(tenantLocalPath string) ([]*resourcev1alpha1.Cluster, error)

type ClusterRegistrationOperator

+ GetClsuter func(tenantLocalPath, clusterName string) (*resourcev1alpha1.Cluster, error)

+ GetClsuters func(tenantLocalPath string) ([]*resourcev1alpha1.Cluster, error)

type MockClusterRegistrationOperator

+ func (m *MockClusterRegistrationOperator) GetClsuter(tenantLocalPath, clusterName string) (*v1alpha1.Cluster, error)

+ func (m *MockClusterRegistrationOperator) GetClsuters(tenantLocalPath string) ([]*v1alpha1.Cluster, error)

type MockClusterRegistrationOperatorMockRecorder

+ func (mr *MockClusterRegistrationOperatorMockRecorder) GetClsuter(tenantLocalPath, clusterName interface{}) *gomock.Call

+ func (mr *MockClusterRegistrationOperatorMockRecorder) GetClsuters(tenantLocalPath interface{}) *gomock.Call

v0.3.0

May 27, 2023

Changes in this version

+ func GetArgoCDHost(param *ClusterRegistrationParam, apiServer string) (string, error)

+ func GetHostClusterFromTenantConfigFile(tenantConfigRepoLocalPath, hostClusterName, tenantName string) (*resourcev1alpha1.Cluster, error)

+ func GetTektonHost(param *ClusterRegistrationParam, apiServer string) (string, error)

+ func IsPhysical(cluster *resourcev1alpha1.Cluster) bool

+ func IsPhysicalDeploymentRuntime(cluster *resourcev1alpha1.Cluster) bool

+ func IsPhysicalProjectPipelineRuntime(cluster *resourcev1alpha1.Cluster) bool

+ func IsVirtual(cluster *resourcev1alpha1.Cluster) bool

+ func IsVirtualDeploymentRuntime(cluster *resourcev1alpha1.Cluster) bool

+ func IsVirtualProjectPipelineRuntime(cluster *resourcev1alpha1.Cluster) bool

+ func OverlayTemplateDirectoryPlaceholder(nodes *nodestree.Node, placeholder string, replaceValue string)

+ func ReplaceTemplatePathWithTenantRepositoryPath(filePath, oldDir, newDir string) (newPath string)

+ type ArgocdConfig struct

+ Host string

+ Project string

+ URL string

+ func GetArgocdConfig(cr *ClusterRegistration, cluster *resourcev1alpha1.Cluster, ...) (*ArgocdConfig, error)

+ type ClusterFileIgnoreConfig struct

+ Common CommonConfig

+ Remove Remove

+ Save Save

+ func NewClusterFileIgnoreConfig(dir string) (*ClusterFileIgnoreConfig, error)

+ func (c *ClusterFileIgnoreConfig) GetRemoveHostClusterConfig() (ignorePath, ignoreFile []string)

+ func (c *ClusterFileIgnoreConfig) GetRemovePhysicalDeploymentRuntimeConfig() (ignorePath, ignoreFile []string)

+ func (c *ClusterFileIgnoreConfig) GetRemovePhysicalProjectPipelineRuntimeConfig() (ignorePath, ignoreFile []string)

+ func (c *ClusterFileIgnoreConfig) GetRemoveVirtualDeploymentRuntimeConfig() (ignorePath, ignoreFile []string)

+ func (c *ClusterFileIgnoreConfig) GetRemoveVirtualProjectPipelineRuntimeConfig() (ignorePath, ignoreFile []string)

+ func (c *ClusterFileIgnoreConfig) GetSaveHostClusterConfig() (ignorePath, ignoreFile []string)

+ func (c *ClusterFileIgnoreConfig) GetSavePhysicalDeploymentRuntimeConfig() (ignorePath, ignoreFile []string)

+ func (c *ClusterFileIgnoreConfig) GetSavePhysicalProjectPipelineRuntimeConfig() (ignorePath, ignoreFile []string)

+ func (c *ClusterFileIgnoreConfig) GetSaveVirtualDeploymentRuntimeConfig() (ignorePath, ignoreFile []string)

+ func (c *ClusterFileIgnoreConfig) GetSaveVirtualProjectPipelineRuntimeConfig() (ignorePath, ignoreFile []string)

type ClusterRegistration

+ func (cr *ClusterRegistration) AddProjectPipelineItem()

+ func (cr *ClusterRegistration) CleanHostClusterAppSet() error

+ func (cr *ClusterRegistration) CleanVclusterAppSet() error

+ func (cr *ClusterRegistration) CleanupAppSetIfEmpty() error

+ func (cr *ClusterRegistration) DeleteClusterToNautes() error

+ func (cr *ClusterRegistration) FilterDeletedClusters() error

+ func (cr *ClusterRegistration) FilterDeletedProjectPipelineItem() error

+ func (cr *ClusterRegistration) GetTektonOAuthURL() (string, error)

+ func (cr *ClusterRegistration) GetTraefikNodePortToRuntime(tenantLocalPath, clusterName string) (int, error)

+ func (cr *ClusterRegistration) InitializeClusterConfig(param *ClusterRegistrationParam) error

+ func (cr *ClusterRegistration) ReplaceTemplatePathWithTenantRepositoryPath(nodes *nodestree.Node)

+ func (cr *ClusterRegistration) SaveClusterConfig(nodes *nodestree.Node) error

+ func (cr *ClusterRegistration) SaveClusterToNautes() error

type ClusterRegistrationOperator

+ GetTektonOAuthURL func() (string, error)

+ InitializeClusterConfig func(param *ClusterRegistrationParam) error

type ClusterRegistrationParam

+ TektonHost string

type HostCluster

+ Host string

+ OAuthURL string

+ PrimaryDomain string

+ ProjectPipelineItems []*ProjectPipelineItem

+ type Ingress struct

+ ApiVersion string

+ Kind string

+ Metadata struct{ ... }

+ Spec struct{ ... }

type MockClusterRegistrationOperator

+ func (m *MockClusterRegistrationOperator) GetTektonOAuthURL() (string, error)

+ func (m *MockClusterRegistrationOperator) InitializeClusterConfig(param *ClusterRegistrationParam) error

type MockClusterRegistrationOperatorMockRecorder

+ func (mr *MockClusterRegistrationOperatorMockRecorder) GetTektonOAuthURL() *gomock.Call

+ func (mr *MockClusterRegistrationOperatorMockRecorder) InitializeClusterConfig(param interface{}) *gomock.Call

+ type ProjectPipelineItem struct

+ HostClusterName string

+ Name string

+ TektonConfig *TektonConfig

+ func ConvertProjectPipeline(ingresses []Ingress, hostClusterName string, httpsNodePort int) []*ProjectPipelineItem

+ func DeleteProjectPipelineItems(itmes []*ProjectPipelineItem, clustrName string) []*ProjectPipelineItem

type Remove

+ PhysicalDeploymentRuntime RuntimeConfig

+ PhysicalProjectPipelineRuntime RuntimeConfig

+ VirtualDeploymentRuntime RuntimeConfig

+ VirtualProjectPipelineRuntime RuntimeConfig

type Runtime

+ ArgocdConfig *ArgocdConfig

+ ClusterName string

+ OAuthURL string

+ PrimaryDomain string

+ ProjectPipelineItem *ProjectPipelineItem

+ TektonConfig *TektonConfig

type Save

+ PhysicalDeploymentRuntime RuntimeConfig

+ PhysicalProjectPipelineRuntime RuntimeConfig

+ VirtualDeploymentRuntime RuntimeConfig

+ VirtualProjectPipelineRuntime RuntimeConfig

+ type TektonConfig struct

+ Host string

+ HttpsNodePort int

+ URL string

+ func GetTektonConfig(cr *ClusterRegistration, cluster *resourcev1alpha1.Cluster, ...) (*TektonConfig, error)

type Vcluster

+ TLSSan string

v0.2.1

Apr 18, 2023

v0.2.0

Apr 15, 2023

Changes in this version

+ const ClusterfilterFileName

+ func AddIfNotExists(list []string, item string) []string

+ func DeleteSpecifyDir(dir string) error

+ func DeleteSpecifyFile(filename string) error

+ func GenerateNodePort(usedPorts []int) int

+ func GetApplicationSetElements(data []byte) ([]string, error)

+ func GetClustersDir(dir string) string

+ func GetHostClusterAppsetFilePath(dir string) string

+ func GetHostClusterNames(filePath string) (hostClusterNames []string, err error)

+ func GetHostClustesrDir(dir string) string

+ func GetRuntimesDir(dir string) string

+ func GetTenantProductionDir(dir string) string

+ func GetVclusterNames(filePath string) (vclusterNames []string, err error)

+ func GetVclustersDir(dir, subDir string) string

+ func IsHostCluser(cluster *resourcev1alpha1.Cluster) bool

+ func IsPhysicalRuntime(cluster *resourcev1alpha1.Cluster) bool

+ func IsValidRuntimeAppSetFilename(filename string) bool

+ func IsVirtualRuntime(cluster *resourcev1alpha1.Cluster) bool

+ func RemoveStringFromArray(arr []string, target string) []string

+ func ReplaceFilePath(filePath, oldDir, newDir string) (newPath string)

+ func ReplacePlaceholders(data string, placeholder, value string) string

+ func WriteConfigFile(filePath, content string) error

+ type Argocd struct

+ Host string

+ URL string

+ type ClusterRegistration struct

+ CaBundle string

+ Cluster *resourcev1alpha1.Cluster

+ ClusterResouceFiles []string

+ ClusterTemplateRepoLocalPath string

+ GitConfigs nautesconfigs.GitRepo

+ HostCluster *HostCluster

+ HostClusterNames []string

+ NautesConfigs nautesconfigs.Nautes

+ OauthConfigs nautesconfigs.OAuth

+ RepoURL string

+ Runtime *Runtime

+ RuntimeNameAndApiServers []*RuntimeNameAndApiServer

+ SecretConfigs nautesconfigs.SecretRepo

+ TenantConfigRepoLocalPath string

+ Traefik *Traefik

+ Usage ClusterUsage

+ Vcluster *Vcluster

+ VclusterNames []string

+ func (r *ClusterRegistration) CheckHostClusterDirExists() error

+ func (r *ClusterRegistration) DeleteCluster() error

+ func (r *ClusterRegistration) DeleteClusterByType(config *Config) (*nodestree.Node, error)

+ func (r *ClusterRegistration) DeleteClusterToKustomization() (err error)

+ func (r *ClusterRegistration) DeleteFileIfAppSetHasNoElements() error

+ func (r *ClusterRegistration) DeleteHostCluster(nodes *nodestree.Node) error

+ func (r *ClusterRegistration) DeleteHostClusterAppSet() error

+ func (r *ClusterRegistration) DeleteRuntime(nodes *nodestree.Node) error

+ func (r *ClusterRegistration) DeleteRuntimeAppSet() error

+ func (r *ClusterRegistration) DeleteVclusterAppSet() error

+ func (r *ClusterRegistration) Execute(nodes *nodestree.Node) error

+ func (r *ClusterRegistration) GetAndDeleteHostClusterNames() error

+ func (r *ClusterRegistration) GetAndDeleteVclusterNames() error

+ func (r *ClusterRegistration) GetAndMergeHostClusterNames() error

+ func (r *ClusterRegistration) GetAndMergeVclusterNames() error

+ func (r *ClusterRegistration) GetArgocdURL() (string, error)

+ func (r *ClusterRegistration) GetTraefikNodePortToHostCluster(tenantLocalPath, hostCluster string) (int, error)

+ func (r *ClusterRegistration) InitializeDependencies(param *ClusterRegistrationParam) error

+ func (r *ClusterRegistration) LoadTemplateNodesTree(ignorePath, ignoreFile []string) (nodes nodestree.Node, err error)

+ func (r *ClusterRegistration) OverlayTemplateDirectoryPlaceholder(nodes *nodestree.Node, placeholder string, replaceVaule string)

+ func (r *ClusterRegistration) Remove() error

+ func (r *ClusterRegistration) ReplaceFilePath(nodes *nodestree.Node)

+ func (r *ClusterRegistration) Save() error

+ func (r *ClusterRegistration) SaveClusterByType(config *Config) (*nodestree.Node, error)

+ func (r *ClusterRegistration) SaveClusterToKustomization() (err error)

+ func (r *ClusterRegistration) SaveHostCluster(nodes *nodestree.Node) error

+ func (r *ClusterRegistration) SaveRuntime(nodes *nodestree.Node) error

+ func (r *ClusterRegistration) WriteCluster() error

+ func (r *ClusterRegistration) WriteFileToTenantConfigRepository(nodes *nodestree.Node) error

+ type ClusterRegistrationOperator interface

+ GetArgocdURL func() (string, error)

+ GetTraefikNodePortToHostCluster func(tenantLocalPath, hostCluster string) (int, error)

+ InitializeDependencies func(param *ClusterRegistrationParam) error

+ Remove func() error

+ Save func() error

+ func NewClusterRegistration() ClusterRegistrationOperator

+ type ClusterRegistrationParam struct

+ ArgocdHost string

+ CaBundle string

+ Cluster *resourcev1alpha1.Cluster

+ ClusterTemplateRepoLocalPath string

+ Configs *nautesconfigs.Config

+ GitRepoHTTPSURL string

+ RepoURL string

+ TenantConfigRepoLocalPath string

+ Traefik *Traefik

+ Vcluster *Vcluster

+ type ClusterUsage string

+ type CommonConfig struct

+ IgnoreFile []string

+ IgnorePath []string

+ type Config struct

+ Common CommonConfig

+ Remove Remove

+ Save Save

+ func NewClusterFileConfig(dir string) (*Config, error)

+ func (c *Config) GetRemoveHostClusterConfig() (ignorePath, ignoreFile []string)

+ func (c *Config) GetRemovePhysicalRuntimeConfig() (ignorePath, ignoreFile []string)

+ func (c *Config) GetRemoveVirtualRuntimeConfig() (ignorePath, ignoreFile []string)

+ func (c *Config) GetSaveHostClusterConfig() (ignorePath, ignoreFile []string)

+ func (c *Config) GetSavePhysicalRuntimeConfig() (ignorePath, ignoreFile []string)

+ func (c *Config) GetSaveVirtualRuntimeConfig() (ignorePath, ignoreFile []string)

+ type HostCluster struct

+ ApiServer string

+ ArgocdProject string

+ Name string

+ type HostClusterConfig struct

+ IgnoreFile []string

+ IgnorePath []string

+ type MockClusterRegistrationOperator struct

+ func NewMockClusterRegistrationOperator(ctrl *gomock.Controller) *MockClusterRegistrationOperator

+ func (m *MockClusterRegistrationOperator) EXPECT() *MockClusterRegistrationOperatorMockRecorder

+ func (m *MockClusterRegistrationOperator) GetArgocdURL() (string, error)

+ func (m *MockClusterRegistrationOperator) GetTraefikNodePortToHostCluster(tenantLocalPath, hostCluster string) (int, error)

+ func (m *MockClusterRegistrationOperator) InitializeDependencies(param *ClusterRegistrationParam) error

+ func (m *MockClusterRegistrationOperator) Remove() error

+ func (m *MockClusterRegistrationOperator) Save() error

+ type MockClusterRegistrationOperatorMockRecorder struct

+ func (mr *MockClusterRegistrationOperatorMockRecorder) GetArgocdURL() *gomock.Call

+ func (mr *MockClusterRegistrationOperatorMockRecorder) GetTraefikNodePortToHostCluster(tenantLocalPath, hostCluster interface{}) *gomock.Call

+ func (mr *MockClusterRegistrationOperatorMockRecorder) InitializeDependencies(param interface{}) *gomock.Call

+ func (mr *MockClusterRegistrationOperatorMockRecorder) Remove() *gomock.Call

+ func (mr *MockClusterRegistrationOperatorMockRecorder) Save() *gomock.Call

+ type Remove struct

+ HostCluster HostClusterConfig

+ PhysicalRuntime RuntimeConfig

+ VirtualRuntime RuntimeConfig

+ type Runtime struct

+ ApiServer string

+ Argocd *Argocd

+ ArgocdProject string

+ MountPath string

+ Name string

+ Type string

+ type RuntimeConfig struct

+ IgnoreFile []string

+ IgnorePath []string

+ type RuntimeNameAndApiServer struct

+ ClusterURL string

+ Name string

+ func AddOrUpdate(list []*RuntimeNameAndApiServer, item *RuntimeNameAndApiServer) []*RuntimeNameAndApiServer

+ func DeleteRuntimeByName(runtimeList []*RuntimeNameAndApiServer, name string) []*RuntimeNameAndApiServer

+ type Save struct

+ HostCluster HostClusterConfig

+ PhysicalRuntime RuntimeConfig

+ VirtualRuntime RuntimeConfig

+ type Traefik struct

+ HttpNodePort string

+ HttpsNodePort string

+ type Vcluster struct

+ ApiServer string

+ HostCluster *HostCluster

+ HttpsNodePort string

+ Name string

+ Namespace string

+ TlsSan string

+ func ConstructVcluster(param *ClusterRegistrationParam) (*Vcluster, error)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL