cluster

package
v0.4.2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 21, 2023 License: Apache-2.0 Imports: 22 Imported by: 0

Documentation

Overview

Package cluster is a generated GoMock package.

Index

Constants

View Source
const (
	HttpsNodePort = "httpsNodePort"
	HttpNodePort  = "httpNodePort"
	Host          = "host"
)
View Source
const (
	ClusterTemplatesDir = "cluster-templates"
)
View Source
const (
	Dex = "dex"
)

Variables

This section is empty.

Functions

func IsHostCluser

func IsHostCluser(cluster *resourcev1alpha1.Cluster) bool

func IsPhysical

func IsPhysical(cluster *resourcev1alpha1.Cluster) bool

func IsPhysicalDeploymentRuntime

func IsPhysicalDeploymentRuntime(cluster *resourcev1alpha1.Cluster) bool

func IsPhysicalProjectPipelineRuntime

func IsPhysicalProjectPipelineRuntime(cluster *resourcev1alpha1.Cluster) bool

func IsVirtual

func IsVirtual(cluster *resourcev1alpha1.Cluster) bool

func IsVirtualDeploymentRuntime

func IsVirtualDeploymentRuntime(cluster *resourcev1alpha1.Cluster) bool

func IsVirtualProjectPipelineRuntime

func IsVirtualProjectPipelineRuntime(cluster *resourcev1alpha1.Cluster) bool

Types

type Argocd

type Argocd struct {
	Host string
	URL  string
	Port string
}

func (*Argocd) GetDefaultValue

func (a *Argocd) GetDefaultValue(_ string, opt *DefaultValueOptions) (string, error)

func (*Argocd) GetDeploymentServer

func (a *Argocd) GetDeploymentServer(params *ClusterRegistrationParams) *DeploymentServer

func (*Argocd) GetOauthURL

func (a *Argocd) GetOauthURL(params *ClusterRegistrationParams) (string, error)

type Cert

type Cert struct {
	Default string
	Gitlab  string
}

type Cluster

type Cluster struct {
	Name        string
	ApiServer   string
	Usage       string
	ClusterType string
	WorkerType  string
}

components options

type ClusterAction

type ClusterAction string

type ClusterManagement

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

func (*ClusterManagement) GetClsuter

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

func (*ClusterManagement) ListClusters

func (c *ClusterManagement) ListClusters(tenantLocalPath string) ([]*resourcev1alpha1.Cluster, error)

func (*ClusterManagement) RemoveCluster

func (c *ClusterManagement) RemoveCluster(params *ClusterRegistrationParams) error

func (*ClusterManagement) SaveCluster

func (c *ClusterManagement) SaveCluster(params *ClusterRegistrationParams) error

type ClusterRegistrationOperator

type ClusterRegistrationOperator interface {
	GetClsuter(tenantLocalPath, clusterName string) (*resourcev1alpha1.Cluster, error)
	ListClusters(tenantLocalPath string) ([]*resourcev1alpha1.Cluster, error)
	SaveCluster(params *ClusterRegistrationParams) error
	RemoveCluster(params *ClusterRegistrationParams) error
}

type ClusterRegistrationParams

type ClusterRegistrationParams struct {
	Cluster       *resourcev1alpha1.Cluster
	Repo          *RepositoriesInfo
	Cert          *Cert
	NautesConfigs nautesconfigs.Nautes
	SecretConfigs nautesconfigs.SecretRepo
	OauthConfigs  nautesconfigs.OAuth
	GitConfigs    nautesconfigs.GitRepo
	Clusters      []resourcev1alpha1.Cluster
	HostCluster   *resourcev1alpha1.Cluster
	Vcluster      *VclusterInfo
}

type ClusterUsage

type ClusterUsage string

type ComponentDefinition

type ComponentDefinition map[ComponentType]ComponentMap

type ComponentImplementation

type ComponentImplementation interface{}

type ComponentName

type ComponentName string

type ComponentType

type ComponentType string

type ComponentsList

type ComponentsList struct {
	Pipeline         map[ComponentName]Pipeline         `json:"pipeline"`
	Deployemnt       map[ComponentName]Deployment       `json:"deployment"`
	Gateway          map[ComponentName]Gateway          `json:"gateway"`
	OAuthProxy       map[ComponentName]OAuthProxy       `json:"oauthProxy"`
	SecretManagement map[ComponentName]SecretManagement `json:"secretManagement"`
}

func NewComponentsList

func NewComponentsList() *ComponentsList

func (*ComponentsList) GenerateTemplateFuncs

func (c *ComponentsList) GenerateTemplateFuncs(cluster *resourcev1alpha1.Cluster) ([]template.FuncMap, error)

GenerateTemplateFuncs Find components in the component list. Find the implementation of specific components and call the method of generating template maps. Return maps of all components.

func (*ComponentsList) GetComponent

func (c *ComponentsList) GetComponent(componentType, componentName string) (interface{}, error)

GetComponent retrieves a specific component by its type and componentName from the ComponentsList. The function uses reflection to iterate over the struct fields, searching for the field tagged with the componentType. Once found, it checks if the field is a map and then searches for the given componentName within that map. If successful, it returns the component's instance; otherwise, an error is thrown.

type ComponentsListFunc

type ComponentsListFunc func(interface{}) interface{}

type Connector

type Connector struct {
	Type   string           `yaml:"type"`
	ID     string           `yaml:"id"`
	Name   string           `yaml:"name"`
	Config ConnectorsConfig `yaml:"config"`
}

type ConnectorsConfig added in v0.4.1

type ConnectorsConfig struct {
	BaseURL      string `yaml:"baseURL"`
	ClientID     string `yaml:"clientID"`
	ClientSecret string `yaml:"clientSecret"`
	RedirectURI  string `yaml:"redirectURI"`
}

type DefaultValueOptions

type DefaultValueOptions struct {
	Cluster *Cluster
}

components

type DefaultValueProvider

type DefaultValueProvider interface {
	GetDefaultValue(field string, opt *DefaultValueOptions) (string, error)
}

components

type Deployment

type Deployment interface {
	DefaultValueProvider
	GetDeploymentServer(param *ClusterRegistrationParams) *DeploymentServer
	GetOauthURL(param *ClusterRegistrationParams) (string, error)
}

func NewArgocd

func NewArgocd() Deployment

func NewDeploymentServer

func NewDeploymentServer(cluster *resourcev1alpha1.Cluster) (Deployment, error)

type DeploymentServer

type DeploymentServer struct {
	Argocd *Argocd
}

type DexCallback

type DexCallback func(dex *DexConfig, url string) error

type DexConfig

type DexConfig struct {
	Issuer        string          `yaml:"issuer"`
	Storage       Storage         `yaml:"storage"`
	Web           Web             `yaml:"web"`
	Connectors    []Connector     `yaml:"connectors"`
	OAuth2        OAuth           `yaml:"oauth2"`
	StaticClients []StaticClients `yaml:"staticClients"`
}

type File

type File struct{}

func (*File) CreateDir

func (c *File) CreateDir(dir string) (string, error)

func (*File) CreateFile

func (c *File) CreateFile(filePath string) (string, error)

func (*File) DeleteDir

func (c *File) DeleteDir(dir string) error

func (*File) DeleteFile

func (c *File) DeleteFile(filePath string) error

func (*File) IsDir

func (c *File) IsDir(path string) (bool, error)

func (*File) ListFilesInDirectory

func (c *File) ListFilesInDirectory(dir string) ([]string, error)

func (*File) ReadFile

func (c *File) ReadFile(filePath string) ([]byte, error)

func (*File) WriteFile

func (c *File) WriteFile(filePath string, content []byte) error

type FileOperation

type FileOperation interface {
	ReadFile(filePath string) ([]byte, error)
	CreateFile(filePath string) (string, error)
	WriteFile(filePath string, content []byte) error
	DeleteFile(filePath string) error
	CreateDir(dir string) (string, error)
	DeleteDir(dir string) error
	IsDir(path string) (bool, error)
	ListFilesInDirectory(dirPath string) ([]string, error)
}

func NewClusterConfigFile

func NewClusterConfigFile() (FileOperation, error)

type Gateway

type Gateway interface {
	GetGatewayServer(param *ClusterRegistrationParams) *GatewayServer
}

func NewTraefik

func NewTraefik() Gateway

type GatewayServer

type GatewayServer struct {
	Traefik *Traefik
}

type Ingress

type Ingress struct {
	Name string
	Host string
}

type Middleware

type Middleware struct {
	OAuth  *MiddlewareOauth
	Errors *MiddlewareError
}

type MiddlewareError

type MiddlewareError struct {
	Name string
	URL  string
}

type MiddlewareOauth

type MiddlewareOauth struct {
	Name string
}

type MockClusterRegistrationOperator

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

MockClusterRegistrationOperator is a mock of ClusterRegistrationOperator interface.

func NewMockClusterRegistrationOperator

func NewMockClusterRegistrationOperator(ctrl *gomock.Controller) *MockClusterRegistrationOperator

NewMockClusterRegistrationOperator creates a new mock instance.

func (*MockClusterRegistrationOperator) EXPECT

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockClusterRegistrationOperator) GetClsuter

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

GetClsuter mocks base method.

func (*MockClusterRegistrationOperator) ListClusters

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

ListClusters mocks base method.

func (*MockClusterRegistrationOperator) RemoveCluster

RemoveCluster mocks base method.

func (*MockClusterRegistrationOperator) SaveCluster

SaveCluster mocks base method.

type MockClusterRegistrationOperatorMockRecorder

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

MockClusterRegistrationOperatorMockRecorder is the mock recorder for MockClusterRegistrationOperator.

func (*MockClusterRegistrationOperatorMockRecorder) GetClsuter

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

GetClsuter indicates an expected call of GetClsuter.

func (*MockClusterRegistrationOperatorMockRecorder) ListClusters

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

ListClusters indicates an expected call of ListClusters.

func (*MockClusterRegistrationOperatorMockRecorder) RemoveCluster

func (mr *MockClusterRegistrationOperatorMockRecorder) RemoveCluster(params interface{}) *gomock.Call

RemoveCluster indicates an expected call of RemoveCluster.

func (*MockClusterRegistrationOperatorMockRecorder) SaveCluster

func (mr *MockClusterRegistrationOperatorMockRecorder) SaveCluster(params interface{}) *gomock.Call

SaveCluster indicates an expected call of SaveCluster.

type MockDefaultValueProvider

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

MockDefaultValueProvider is a mock of DefaultValueProvider interface.

func NewMockDefaultValueProvider

func NewMockDefaultValueProvider(ctrl *gomock.Controller) *MockDefaultValueProvider

NewMockDefaultValueProvider creates a new mock instance.

func (*MockDefaultValueProvider) EXPECT

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockDefaultValueProvider) GetDefaultValue

func (m *MockDefaultValueProvider) GetDefaultValue(field string, opt *DefaultValueOptions) (string, error)

GetDefaultValue mocks base method.

type MockDefaultValueProviderMockRecorder

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

MockDefaultValueProviderMockRecorder is the mock recorder for MockDefaultValueProvider.

func (*MockDefaultValueProviderMockRecorder) GetDefaultValue

func (mr *MockDefaultValueProviderMockRecorder) GetDefaultValue(field, opt interface{}) *gomock.Call

GetDefaultValue indicates an expected call of GetDefaultValue.

type MockDeployment

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

MockDeployment is a mock of Deployment interface.

func NewMockDeployment

func NewMockDeployment(ctrl *gomock.Controller) *MockDeployment

NewMockDeployment creates a new mock instance.

func (*MockDeployment) EXPECT

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockDeployment) GetDefaultValue

func (m *MockDeployment) GetDefaultValue(field string, opt *DefaultValueOptions) (string, error)

GetDefaultValue mocks base method.

func (*MockDeployment) GetDeploymentServer

func (m *MockDeployment) GetDeploymentServer(param *ClusterRegistrationParams) *DeploymentServer

GetDeploymentServer mocks base method.

func (*MockDeployment) GetOauthURL

func (m *MockDeployment) GetOauthURL(param *ClusterRegistrationParams) (string, error)

GetOauthURL mocks base method.

type MockDeploymentMockRecorder

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

MockDeploymentMockRecorder is the mock recorder for MockDeployment.

func (*MockDeploymentMockRecorder) GetDefaultValue

func (mr *MockDeploymentMockRecorder) GetDefaultValue(field, opt interface{}) *gomock.Call

GetDefaultValue indicates an expected call of GetDefaultValue.

func (*MockDeploymentMockRecorder) GetDeploymentServer

func (mr *MockDeploymentMockRecorder) GetDeploymentServer(param interface{}) *gomock.Call

GetDeploymentServer indicates an expected call of GetDeploymentServer.

func (*MockDeploymentMockRecorder) GetOauthURL

func (mr *MockDeploymentMockRecorder) GetOauthURL(param interface{}) *gomock.Call

GetOauthURL indicates an expected call of GetOauthURL.

type MockGateway

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

MockGateway is a mock of Gateway interface.

func NewMockGateway

func NewMockGateway(ctrl *gomock.Controller) *MockGateway

NewMockGateway creates a new mock instance.

func (*MockGateway) EXPECT

func (m *MockGateway) EXPECT() *MockGatewayMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockGateway) GetDefaultValue

func (m *MockGateway) GetDefaultValue(field string, opt *DefaultValueOptions) (string, error)

GetDefaultValue mocks base method.

func (*MockGateway) GetGatewayServer

func (m *MockGateway) GetGatewayServer(param *ClusterRegistrationParams) *GatewayServer

GetGatewayServer mocks base method.

type MockGatewayMockRecorder

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

MockGatewayMockRecorder is the mock recorder for MockGateway.

func (*MockGatewayMockRecorder) GetDefaultValue

func (mr *MockGatewayMockRecorder) GetDefaultValue(field, opt interface{}) *gomock.Call

GetDefaultValue indicates an expected call of GetDefaultValue.

func (*MockGatewayMockRecorder) GetGatewayServer

func (mr *MockGatewayMockRecorder) GetGatewayServer(param interface{}) *gomock.Call

GetGatewayServer indicates an expected call of GetGatewayServer.

type MockOAuthProxy

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

MockOAuthProxy is a mock of OAuthProxy interface.

func NewMockOAuthProxy

func NewMockOAuthProxy(ctrl *gomock.Controller) *MockOAuthProxy

NewMockOAuthProxy creates a new mock instance.

func (*MockOAuthProxy) EXPECT

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockOAuthProxy) GetDefaultValue

func (m *MockOAuthProxy) GetDefaultValue(field string, opt *DefaultValueOptions) (string, error)

GetDefaultValue mocks base method.

func (*MockOAuthProxy) GetOauthProxyServer

func (m *MockOAuthProxy) GetOauthProxyServer(param *ClusterRegistrationParams) *OAuthProxyServer

GetOauthProxyServer mocks base method.

type MockOAuthProxyMockRecorder

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

MockOAuthProxyMockRecorder is the mock recorder for MockOAuthProxy.

func (*MockOAuthProxyMockRecorder) GetDefaultValue

func (mr *MockOAuthProxyMockRecorder) GetDefaultValue(field, opt interface{}) *gomock.Call

GetDefaultValue indicates an expected call of GetDefaultValue.

func (*MockOAuthProxyMockRecorder) GetOauthProxyServer

func (mr *MockOAuthProxyMockRecorder) GetOauthProxyServer(param interface{}) *gomock.Call

GetOauthProxyServer indicates an expected call of GetOauthProxyServer.

type MockPipeline

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

MockPipeline is a mock of Pipeline interface.

func NewMockPipeline

func NewMockPipeline(ctrl *gomock.Controller) *MockPipeline

NewMockPipeline creates a new mock instance.

func (*MockPipeline) EXPECT

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockPipeline) GetDefaultValue

func (m *MockPipeline) GetDefaultValue(field string, opt *DefaultValueOptions) (string, error)

GetDefaultValue mocks base method.

func (*MockPipeline) GetOauthURL

func (m *MockPipeline) GetOauthURL(param *ClusterRegistrationParams) (string, error)

GetOauthURL mocks base method.

func (*MockPipeline) GetPipelineServer

func (m *MockPipeline) GetPipelineServer(param *ClusterRegistrationParams) *PipelineServer

GetPipelineServer mocks base method.

type MockPipelineMockRecorder

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

MockPipelineMockRecorder is the mock recorder for MockPipeline.

func (*MockPipelineMockRecorder) GetDefaultValue

func (mr *MockPipelineMockRecorder) GetDefaultValue(field, opt interface{}) *gomock.Call

GetDefaultValue indicates an expected call of GetDefaultValue.

func (*MockPipelineMockRecorder) GetOauthURL

func (mr *MockPipelineMockRecorder) GetOauthURL(param interface{}) *gomock.Call

GetOauthURL indicates an expected call of GetOauthURL.

func (*MockPipelineMockRecorder) GetPipelineServer

func (mr *MockPipelineMockRecorder) GetPipelineServer(param interface{}) *gomock.Call

GetPipelineServer indicates an expected call of GetPipelineServer.

type MockSecretManagement

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

MockSecretManagement is a mock of SecretManagement interface.

func NewMockSecretManagement

func NewMockSecretManagement(ctrl *gomock.Controller) *MockSecretManagement

NewMockSecretManagement creates a new mock instance.

func (*MockSecretManagement) EXPECT

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockSecretManagement) GetDefaultValue

func (m *MockSecretManagement) GetDefaultValue(field string, opt *DefaultValueOptions) (string, error)

GetDefaultValue mocks base method.

type MockSecretManagementMockRecorder

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

MockSecretManagementMockRecorder is the mock recorder for MockSecretManagement.

func (*MockSecretManagementMockRecorder) GetDefaultValue

func (mr *MockSecretManagementMockRecorder) GetDefaultValue(field, opt interface{}) *gomock.Call

GetDefaultValue indicates an expected call of GetDefaultValue.

type OAuth

type OAuth struct {
	SkipApprovalScreen bool `yaml:"skipApprovalScreen"`
}

type OAuth2Proxy

type OAuth2Proxy struct {
	Hosts           string
	WhitelistDomain string
	Redirect        string
	Ingresses       []*Ingress
}

func (*OAuth2Proxy) GenerateOAuthProxyRedirect

func (o *OAuth2Proxy) GenerateOAuthProxyRedirect(cluster *resourcev1alpha1.Cluster) string

func (*OAuth2Proxy) GetOauthProxyServer

func (o *OAuth2Proxy) GetOauthProxyServer(param *ClusterRegistrationParams) *OAuthProxyServer

type OAuthProxy

type OAuthProxy interface {
	GetOauthProxyServer(param *ClusterRegistrationParams) *OAuthProxyServer
	GenerateOAuthProxyRedirect(cluster *resourcev1alpha1.Cluster) string
}

func NewOAuth2Proxy

func NewOAuth2Proxy() OAuthProxy

func NewOAuthProxyServer

func NewOAuthProxyServer(cluster *resourcev1alpha1.Cluster) (OAuthProxy, error)

type OAuthProxyServer

type OAuthProxyServer struct {
	OAuth2Proxy *OAuth2Proxy
}

type Pipeline

type Pipeline interface {
	DefaultValueProvider
	GetPipelineServer(param *ClusterRegistrationParams) *PipelineServer
}

func NewPipelineServer

func NewPipelineServer(cluster *resourcev1alpha1.Cluster) (Pipeline, error)

func NewTekton

func NewTekton() Pipeline

type PipelineServer

type PipelineServer struct {
	Tekton *Tekton
}

type RepositoriesInfo

type RepositoriesInfo struct {
	ClusterTemplateDir string
	TenantRepoDir      string
	TenantRepoURL      string
}

type RuntimeType

type RuntimeType string

type SecretManagement

type SecretManagement interface {
}

func NewVault

func NewVault() SecretManagement

type SecretManagementServer

type SecretManagementServer struct {
	Vault *Vault
}

type StaticClients

type StaticClients struct {
	ID           string   `yaml:"id"`
	RedirectURIs []string `yaml:"redirectURIs"`
	Name         string   `yaml:"name"`
	Secret       string   `yaml:"secret"`
}

type Storage

type Storage struct {
	Type string `yaml:"type"`
}

type Tekton

type Tekton struct {
	Hosts string
	URL   string
}

func (*Tekton) GetDefaultValue

func (t *Tekton) GetDefaultValue(_ string, opt *DefaultValueOptions) (string, error)

func (*Tekton) GetPipelineServer

func (t *Tekton) GetPipelineServer(param *ClusterRegistrationParams) *PipelineServer

type Template

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

func (*Template) Clone

func (t *Template) Clone() (TemplateOperation, error)

func (*Template) Execute

func (t *Template) Execute(wr io.Writer, data any) error

func (*Template) Parse

func (t *Template) Parse(text string) error

func (*Template) RegisterFunc

func (t *Template) RegisterFunc(funcMap template.FuncMap)

type TemplateFunc

type TemplateFunc func(funcMap *template.FuncMap, customFunc func())

type TemplateOperation

type TemplateOperation interface {
	RegisterFunc(funcMap template.FuncMap)
	Parse(text string) error
	Execute(wr io.Writer, data any) error
	Clone() (TemplateOperation, error)
}

func NewTemplate

func NewTemplate(name string) TemplateOperation

type Traefik

type Traefik struct {
	HttpsNodePort string
	HttpNodePort  string
	Middlewares   []*Middleware
}

func (*Traefik) GetGatewayServer

func (t *Traefik) GetGatewayServer(param *ClusterRegistrationParams) *GatewayServer

type Vault

type Vault struct {
}

type VclusterInfo

type VclusterInfo struct {
	HttpsNodePort string
}

type Web

type Web struct {
	HTTP string `yaml:"http"`
}

Jump to

Keyboard shortcuts

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