Documentation ¶
Overview ¶
Package cluster is a generated GoMock package.
Index ¶
- Constants
- func IsHostCluser(cluster *resourcev1alpha1.Cluster) bool
- 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
- type Argocd
- type Cert
- type Cluster
- type ClusterAction
- type ClusterManagement
- func (c *ClusterManagement) AppendDexRedirectURIs(url string) error
- func (c *ClusterManagement) GetClsuter(tenantLocalPath, clusterName string) (*resourcev1alpha1.Cluster, error)
- func (c *ClusterManagement) GetDeploymentRedirectURI(params *ClusterRegistrationParams) (string, error)
- func (c *ClusterManagement) GetOAuthProxyRedirectURI(params *ClusterRegistrationParams) (string, error)
- func (c *ClusterManagement) ListClusters(tenantLocalPath string) ([]*resourcev1alpha1.Cluster, error)
- func (c *ClusterManagement) RemoveCluster(params *ClusterRegistrationParams) error
- func (c *ClusterManagement) RemoveDexRedirectURIs(url string) error
- func (c *ClusterManagement) SaveCluster(params *ClusterRegistrationParams) error
- func (c *ClusterManagement) SaveClusterRuntime(nodes *nodestree.Node) error
- func (c *ClusterManagement) UpdateDexConfig(cm *v1.ConfigMap, redirectURIs string, fn DexCallback) error
- type ClusterRegistrationOperator
- type ClusterRegistrationParams
- type ClusterUsage
- type ComponentDefinition
- type ComponentImplementation
- type ComponentMap
- type ComponentName
- type ComponentType
- type ComponentsList
- type ComponentsListFunc
- type Connector
- type DefaultValueOptions
- type DefaultValueProvider
- type Deployment
- type DeploymentServer
- type DexCallback
- type DexConfig
- type File
- func (c *File) CreateDir(dir string) (string, error)
- func (c *File) CreateFile(filePath string) (string, error)
- func (c *File) DeleteDir(dir string) error
- func (c *File) DeleteFile(filePath string) error
- func (c *File) IsDir(path string) (bool, error)
- func (c *File) ListFilesInDirectory(dir string) ([]string, error)
- func (c *File) ReadFile(filePath string) ([]byte, error)
- func (c *File) WriteFile(filePath string, content []byte) error
- type FileOperation
- type Gateway
- type GatewayServer
- type Ingress
- type Middleware
- type MiddlewareError
- type MiddlewareOauth
- type MockClusterRegistrationOperator
- func (m *MockClusterRegistrationOperator) EXPECT() *MockClusterRegistrationOperatorMockRecorder
- func (m *MockClusterRegistrationOperator) GetClsuter(tenantLocalPath, clusterName string) (*v1alpha1.Cluster, error)
- func (m *MockClusterRegistrationOperator) ListClusters(tenantLocalPath string) ([]*v1alpha1.Cluster, error)
- func (m *MockClusterRegistrationOperator) RemoveCluster(params *ClusterRegistrationParams) error
- func (m *MockClusterRegistrationOperator) SaveCluster(params *ClusterRegistrationParams) error
- type MockClusterRegistrationOperatorMockRecorder
- func (mr *MockClusterRegistrationOperatorMockRecorder) GetClsuter(tenantLocalPath, clusterName interface{}) *gomock.Call
- func (mr *MockClusterRegistrationOperatorMockRecorder) ListClusters(tenantLocalPath interface{}) *gomock.Call
- func (mr *MockClusterRegistrationOperatorMockRecorder) RemoveCluster(params interface{}) *gomock.Call
- func (mr *MockClusterRegistrationOperatorMockRecorder) SaveCluster(params interface{}) *gomock.Call
- type MockDefaultValueProvider
- type MockDefaultValueProviderMockRecorder
- type MockDeployment
- func (m *MockDeployment) EXPECT() *MockDeploymentMockRecorder
- func (m *MockDeployment) GetDefaultValue(field string, opt *DefaultValueOptions) (string, error)
- func (m *MockDeployment) GetDeploymentServer(param *ClusterRegistrationParams) *DeploymentServer
- func (m *MockDeployment) GetOauthURL(param *ClusterRegistrationParams) (string, error)
- type MockDeploymentMockRecorder
- type MockGateway
- type MockGatewayMockRecorder
- type MockOAuthProxy
- type MockOAuthProxyMockRecorder
- type MockPipeline
- func (m *MockPipeline) EXPECT() *MockPipelineMockRecorder
- func (m *MockPipeline) GetDefaultValue(field string, opt *DefaultValueOptions) (string, error)
- func (m *MockPipeline) GetOauthURL(param *ClusterRegistrationParams) (string, error)
- func (m *MockPipeline) GetPipelineServer(param *ClusterRegistrationParams) *PipelineServer
- type MockPipelineMockRecorder
- type MockSecretManagement
- type MockSecretManagementMockRecorder
- type OAuth
- type OAuth2Proxy
- type OAuthProxy
- type OAuthProxyServer
- type Pipeline
- type PipelineServer
- type RepositoriesInfo
- type RuntimeType
- type SecretManagement
- type SecretManagementServer
- type StaticClients
- type Storage
- type Tekton
- type Template
- type TemplateFunc
- type TemplateOperation
- type Traefik
- type Vault
- type VclusterInfo
- type Web
Constants ¶
const ( HttpsNodePort = "httpsNodePort" HttpNodePort = "httpNodePort" Host = "host" )
const (
ClusterTemplatesDir = "cluster-tempaltes"
)
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 ¶
func (*Argocd) GetDefaultValue ¶
func (t *Argocd) GetDefaultValue(field string, opt *DefaultValueOptions) (string, error)
func (*Argocd) GetDeploymentServer ¶
func (a *Argocd) GetDeploymentServer(param *ClusterRegistrationParams) *DeploymentServer
func (*Argocd) GetOauthURL ¶
func (a *Argocd) GetOauthURL(param *ClusterRegistrationParams) (string, error)
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) AppendDexRedirectURIs ¶
func (c *ClusterManagement) AppendDexRedirectURIs(url string) error
func (*ClusterManagement) GetClsuter ¶
func (c *ClusterManagement) GetClsuter(tenantLocalPath, clusterName string) (*resourcev1alpha1.Cluster, error)
func (*ClusterManagement) GetDeploymentRedirectURI ¶
func (c *ClusterManagement) GetDeploymentRedirectURI(params *ClusterRegistrationParams) (string, error)
func (*ClusterManagement) GetOAuthProxyRedirectURI ¶
func (c *ClusterManagement) GetOAuthProxyRedirectURI(params *ClusterRegistrationParams) (string, 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) RemoveDexRedirectURIs ¶
func (c *ClusterManagement) RemoveDexRedirectURIs(url string) error
func (*ClusterManagement) SaveCluster ¶
func (c *ClusterManagement) SaveCluster(params *ClusterRegistrationParams) error
func (*ClusterManagement) SaveClusterRuntime ¶
func (c *ClusterManagement) SaveClusterRuntime(nodes *nodestree.Node) error
func (*ClusterManagement) UpdateDexConfig ¶
func (c *ClusterManagement) UpdateDexConfig(cm *v1.ConfigMap, redirectURIs string, fn DexCallback) 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 }
func NewClusterManagement ¶
func NewClusterManagement(file FileOperation, nodestree nodestree.NodesTree) (ClusterRegistrationOperator, 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 ComponentMap ¶
type ComponentMap map[ComponentName]ComponentImplementation
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 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 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 { DefaultValueProvider GetGatewayServer(param *ClusterRegistrationParams) *GatewayServer }
func NewTraefik ¶
func NewTraefik() Gateway
type GatewayServer ¶
type GatewayServer struct {
Traefik *Traefik
}
type Middleware ¶
type Middleware struct { OAuth *MiddlewareOauth Errors *MiddlewareError }
type MiddlewareError ¶
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 ¶
func (m *MockClusterRegistrationOperator) EXPECT() *MockClusterRegistrationOperatorMockRecorder
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 ¶
func (m *MockClusterRegistrationOperator) RemoveCluster(params *ClusterRegistrationParams) error
RemoveCluster mocks base method.
func (*MockClusterRegistrationOperator) SaveCluster ¶
func (m *MockClusterRegistrationOperator) SaveCluster(params *ClusterRegistrationParams) error
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 ¶
func (m *MockDefaultValueProvider) EXPECT() *MockDefaultValueProviderMockRecorder
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 ¶
func (m *MockDeployment) EXPECT() *MockDeploymentMockRecorder
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 ¶
func (m *MockOAuthProxy) EXPECT() *MockOAuthProxyMockRecorder
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 ¶
func (m *MockPipeline) EXPECT() *MockPipelineMockRecorder
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 ¶
func (m *MockSecretManagement) EXPECT() *MockSecretManagementMockRecorder
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 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) GetDefaultValue ¶
func (t *OAuth2Proxy) GetDefaultValue(field string, opt *DefaultValueOptions) (string, error)
func (*OAuth2Proxy) GetOauthProxyServer ¶
func (o *OAuth2Proxy) GetOauthProxyServer(param *ClusterRegistrationParams) *OAuthProxyServer
type OAuthProxy ¶
type OAuthProxy interface { DefaultValueProvider 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)
type PipelineServer ¶
type PipelineServer struct {
Tekton *Tekton
}
type RepositoriesInfo ¶
type RuntimeType ¶
type RuntimeType string
type SecretManagement ¶
type SecretManagement interface { DefaultValueProvider }
func NewVault ¶
func NewVault() SecretManagement
type SecretManagementServer ¶
type SecretManagementServer struct {
Vault *Vault
}
type StaticClients ¶
type Tekton ¶
func (*Tekton) GetDefaultValue ¶
func (t *Tekton) GetDefaultValue(field 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) RegisterFunc ¶
type TemplateFunc ¶
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) GetDefaultValue ¶
func (t *Traefik) GetDefaultValue(field string, opt *DefaultValueOptions) (string, error)
func (*Traefik) GetGatewayServer ¶
func (t *Traefik) GetGatewayServer(param *ClusterRegistrationParams) *GatewayServer
type Vault ¶
type Vault struct { }
func (*Vault) GetDefaultValue ¶
func (v *Vault) GetDefaultValue(field string, opt *DefaultValueOptions) (string, error)
func (*Vault) GetSecretManagementServer ¶
func (v *Vault) GetSecretManagementServer(param *ClusterRegistrationParams) *SecretManagementServer
type VclusterInfo ¶
type VclusterInfo struct {
HttpsNodePort string
}