Documentation
¶
Index ¶
- Constants
- func BuildEnvironmentIdentifer(clusterName string, namespace string) string
- type ClusterBean
- type ClusterEnvDto
- type ClusterService
- type ClusterServiceImpl
- func (impl ClusterServiceImpl) CheckIfConfigIsValid(cluster *ClusterBean) error
- func (impl *ClusterServiceImpl) CreateGrafanaDataSource(clusterBean *ClusterBean, env *repository.Environment) (int, error)
- func (impl *ClusterServiceImpl) Delete(bean *ClusterBean, userId int32) error
- func (impl ClusterServiceImpl) DeleteFromDb(bean *ClusterBean, userId int32) error
- func (impl *ClusterServiceImpl) FindAll() ([]*ClusterBean, error)
- func (impl *ClusterServiceImpl) FindAllActive() ([]ClusterBean, error)
- func (impl *ClusterServiceImpl) FindAllForAutoComplete() ([]ClusterBean, error)
- func (impl *ClusterServiceImpl) FindById(id int) (*ClusterBean, error)
- func (impl *ClusterServiceImpl) FindByIds(ids []int) ([]ClusterBean, error)
- func (impl *ClusterServiceImpl) FindOne(clusterName string) (*ClusterBean, error)
- func (impl *ClusterServiceImpl) FindOneActive(clusterName string) (*ClusterBean, error)
- func (impl *ClusterServiceImpl) GetAllClusterNamespaces() map[string][]string
- func (impl *ClusterServiceImpl) GetClusterConfig(cluster *ClusterBean) (*util.ClusterConfig, error)
- func (impl *ClusterServiceImpl) GetK8sClient() (*v12.CoreV1Client, error)
- func (impl *ClusterServiceImpl) Save(parent context.Context, bean *ClusterBean, userId int32) (*ClusterBean, error)
- func (impl *ClusterServiceImpl) SyncNsInformer(bean *ClusterBean)
- func (impl *ClusterServiceImpl) Update(ctx context.Context, bean *ClusterBean, userId int32) (*ClusterBean, error)
- type ClusterServiceImplExtended
- func (impl *ClusterServiceImplExtended) CreateGrafanaDataSource(clusterBean *ClusterBean, env *repository.Environment) (int, error)
- func (impl ClusterServiceImplExtended) DeleteFromDb(bean *ClusterBean, userId int32) error
- func (impl *ClusterServiceImplExtended) FindAll() ([]*ClusterBean, error)
- func (impl *ClusterServiceImplExtended) Save(ctx context.Context, bean *ClusterBean, userId int32) (*ClusterBean, error)
- func (impl *ClusterServiceImplExtended) Update(ctx context.Context, bean *ClusterBean, userId int32) (*ClusterBean, error)
- type DefaultClusterComponent
- type EnvDto
- type EnvironmentBean
- type EnvironmentService
- type EnvironmentServiceImpl
- func (impl EnvironmentServiceImpl) Create(mappings *EnvironmentBean, userId int32) (*EnvironmentBean, error)
- func (impl EnvironmentServiceImpl) Delete(deleteReq *EnvironmentBean, userId int32) error
- func (impl EnvironmentServiceImpl) FindById(id int) (*EnvironmentBean, error)
- func (impl EnvironmentServiceImpl) FindByIds(ids []*int) ([]*EnvironmentBean, error)
- func (impl EnvironmentServiceImpl) FindByNamespaceAndClusterName(namespaces string, clusterName string) (*repository.Environment, error)
- func (impl EnvironmentServiceImpl) FindClusterByEnvId(id int) (*ClusterBean, error)
- func (impl EnvironmentServiceImpl) FindOne(environment string) (*EnvironmentBean, error)
- func (impl EnvironmentServiceImpl) GetAll() ([]EnvironmentBean, error)
- func (impl EnvironmentServiceImpl) GetAllActive() ([]EnvironmentBean, error)
- func (impl EnvironmentServiceImpl) GetByClusterId(id int) ([]*EnvironmentBean, error)
- func (impl EnvironmentServiceImpl) GetCombinedEnvironmentListForDropDown(token string, isActionUserSuperAdmin bool, ...) ([]*ClusterEnvDto, error)
- func (impl EnvironmentServiceImpl) GetCombinedEnvironmentListForDropDownByClusterIds(token string, clusterIds []int, auth func(token string, object string) bool) ([]*ClusterEnvDto, error)
- func (impl EnvironmentServiceImpl) GetEnvironmentListForAutocomplete() ([]EnvironmentBean, error)
- func (impl EnvironmentServiceImpl) Update(mappings *EnvironmentBean, userId int32) (*EnvironmentBean, error)
- type PrometheusAuth
Constants ¶
View Source
const DEFAULT_CLUSTER = "default_cluster"
View Source
const DefaultClusterName = "default_cluster"
View Source
const TokenFilePath = "/var/run/secrets/kubernetes.io/serviceaccount/token"
Variables ¶
This section is empty.
Functions ¶
func BuildEnvironmentIdentifer ¶ added in v0.3.17
Types ¶
type ClusterBean ¶
type ClusterBean struct { Id int `json:"id,omitempty" validate:"number"` ClusterName string `json:"cluster_name,omitempty" validate:"required"` ServerUrl string `json:"server_url,omitempty" validate:"url,required"` PrometheusUrl string `json:"prometheus_url,omitempty" validate:"validate-non-empty-url"` Active bool `json:"active"` Config map[string]string `json:"config,omitempty" validate:"required"` PrometheusAuth *PrometheusAuth `json:"prometheusAuth,omitempty"` DefaultClusterComponent []*DefaultClusterComponent `json:"defaultClusterComponent"` AgentInstallationStage int `json:"agentInstallationStage,notnull"` // -1=external, 0=not triggered, 1=progressing, 2=success, 3=fails K8sVersion string `json:"k8sVersion"` HasConfigOrUrlChanged bool `json:"-"` ErrorInConnecting string `json:"-"` }
type ClusterEnvDto ¶ added in v0.3.14
type ClusterService ¶
type ClusterService interface { Save(parent context.Context, bean *ClusterBean, userId int32) (*ClusterBean, error) FindOne(clusterName string) (*ClusterBean, error) FindOneActive(clusterName string) (*ClusterBean, error) FindAll() ([]*ClusterBean, error) FindAllActive() ([]ClusterBean, error) DeleteFromDb(bean *ClusterBean, userId int32) error FindById(id int) (*ClusterBean, error) FindByIds(id []int) ([]ClusterBean, error) Update(ctx context.Context, bean *ClusterBean, userId int32) (*ClusterBean, error) Delete(bean *ClusterBean, userId int32) error FindAllForAutoComplete() ([]ClusterBean, error) CreateGrafanaDataSource(clusterBean *ClusterBean, env *repository.Environment) (int, error) GetClusterConfig(cluster *ClusterBean) (*util.ClusterConfig, error) GetK8sClient() (*v12.CoreV1Client, error) GetAllClusterNamespaces() map[string][]string }
type ClusterServiceImpl ¶
type ClusterServiceImpl struct { K8sUtil *util.K8sUtil K8sInformerFactory informer.K8sInformerFactory // contains filtered or unexported fields }
func NewClusterServiceImpl ¶
func NewClusterServiceImpl(repository repository.ClusterRepository, logger *zap.SugaredLogger, K8sUtil *util.K8sUtil, K8sInformerFactory informer.K8sInformerFactory) *ClusterServiceImpl
func (ClusterServiceImpl) CheckIfConfigIsValid ¶ added in v0.6.2
func (impl ClusterServiceImpl) CheckIfConfigIsValid(cluster *ClusterBean) error
func (*ClusterServiceImpl) CreateGrafanaDataSource ¶
func (impl *ClusterServiceImpl) CreateGrafanaDataSource(clusterBean *ClusterBean, env *repository.Environment) (int, error)
func (*ClusterServiceImpl) Delete ¶
func (impl *ClusterServiceImpl) Delete(bean *ClusterBean, userId int32) error
func (ClusterServiceImpl) DeleteFromDb ¶ added in v0.3.15
func (impl ClusterServiceImpl) DeleteFromDb(bean *ClusterBean, userId int32) error
func (*ClusterServiceImpl) FindAll ¶
func (impl *ClusterServiceImpl) FindAll() ([]*ClusterBean, error)
func (*ClusterServiceImpl) FindAllActive ¶
func (impl *ClusterServiceImpl) FindAllActive() ([]ClusterBean, error)
func (*ClusterServiceImpl) FindAllForAutoComplete ¶
func (impl *ClusterServiceImpl) FindAllForAutoComplete() ([]ClusterBean, error)
func (*ClusterServiceImpl) FindById ¶
func (impl *ClusterServiceImpl) FindById(id int) (*ClusterBean, error)
func (*ClusterServiceImpl) FindByIds ¶
func (impl *ClusterServiceImpl) FindByIds(ids []int) ([]ClusterBean, error)
func (*ClusterServiceImpl) FindOne ¶
func (impl *ClusterServiceImpl) FindOne(clusterName string) (*ClusterBean, error)
func (*ClusterServiceImpl) FindOneActive ¶
func (impl *ClusterServiceImpl) FindOneActive(clusterName string) (*ClusterBean, error)
func (*ClusterServiceImpl) GetAllClusterNamespaces ¶ added in v0.6.10
func (impl *ClusterServiceImpl) GetAllClusterNamespaces() map[string][]string
func (*ClusterServiceImpl) GetClusterConfig ¶ added in v0.2.8
func (impl *ClusterServiceImpl) GetClusterConfig(cluster *ClusterBean) (*util.ClusterConfig, error)
func (*ClusterServiceImpl) GetK8sClient ¶ added in v0.6.1
func (impl *ClusterServiceImpl) GetK8sClient() (*v12.CoreV1Client, error)
func (*ClusterServiceImpl) Save ¶
func (impl *ClusterServiceImpl) Save(parent context.Context, bean *ClusterBean, userId int32) (*ClusterBean, error)
func (*ClusterServiceImpl) SyncNsInformer ¶ added in v0.3.14
func (impl *ClusterServiceImpl) SyncNsInformer(bean *ClusterBean)
func (*ClusterServiceImpl) Update ¶
func (impl *ClusterServiceImpl) Update(ctx context.Context, bean *ClusterBean, userId int32) (*ClusterBean, error)
type ClusterServiceImplExtended ¶ added in v0.3.9
type ClusterServiceImplExtended struct { K8sInformerFactory informer.K8sInformerFactory *ClusterServiceImpl // contains filtered or unexported fields }
extends ClusterServiceImpl and enhances method of ClusterService with full mode specific errors
func NewClusterServiceImplExtended ¶ added in v0.3.9
func NewClusterServiceImplExtended(repository repository.ClusterRepository, environmentRepository repository.EnvironmentRepository, grafanaClient grafana.GrafanaClient, logger *zap.SugaredLogger, installedAppRepository repository2.InstalledAppRepository, K8sUtil *util.K8sUtil, clusterServiceCD cluster2.ServiceClient, K8sInformerFactory informer.K8sInformerFactory, gitOpsRepository repository3.GitOpsConfigRepository) *ClusterServiceImplExtended
func (*ClusterServiceImplExtended) CreateGrafanaDataSource ¶ added in v0.3.9
func (impl *ClusterServiceImplExtended) CreateGrafanaDataSource(clusterBean *ClusterBean, env *repository.Environment) (int, error)
func (ClusterServiceImplExtended) DeleteFromDb ¶ added in v0.3.15
func (impl ClusterServiceImplExtended) DeleteFromDb(bean *ClusterBean, userId int32) error
func (*ClusterServiceImplExtended) FindAll ¶ added in v0.3.9
func (impl *ClusterServiceImplExtended) FindAll() ([]*ClusterBean, error)
func (*ClusterServiceImplExtended) Save ¶ added in v0.3.9
func (impl *ClusterServiceImplExtended) Save(ctx context.Context, bean *ClusterBean, userId int32) (*ClusterBean, error)
func (*ClusterServiceImplExtended) Update ¶ added in v0.3.9
func (impl *ClusterServiceImplExtended) Update(ctx context.Context, bean *ClusterBean, userId int32) (*ClusterBean, error)
type DefaultClusterComponent ¶
type EnvDto ¶ added in v0.3.14
type EnvDto struct { EnvironmentId int `json:"environmentId" validate:"number"` EnvironmentName string `json:"environmentName,omitempty" validate:"max=50"` Namespace string `json:"namespace,omitempty" validate:"name-space-component,max=50"` EnvironmentIdentifier string `json:"environmentIdentifier,omitempty"` }
type EnvironmentBean ¶
type EnvironmentBean struct { Id int `json:"id,omitempty" validate:"number"` Environment string `json:"environment_name,omitempty" validate:"required,max=50"` ClusterId int `json:"cluster_id,omitempty" validate:"number,required"` ClusterName string `json:"cluster_name,omitempty"` Active bool `json:"active"` Default bool `json:"default"` PrometheusEndpoint string `json:"prometheus_endpoint,omitempty"` Namespace string `json:"namespace,omitempty" validate:"name-space-component,max=50"` CdArgoSetup bool `json:"isClusterCdActive"` EnvironmentIdentifier string `json:"environmentIdentifier"` }
type EnvironmentService ¶
type EnvironmentService interface { FindOne(environment string) (*EnvironmentBean, error) Create(mappings *EnvironmentBean, userId int32) (*EnvironmentBean, error) GetAll() ([]EnvironmentBean, error) GetAllActive() ([]EnvironmentBean, error) Delete(deleteReq *EnvironmentBean, userId int32) error FindById(id int) (*EnvironmentBean, error) Update(mappings *EnvironmentBean, userId int32) (*EnvironmentBean, error) FindClusterByEnvId(id int) (*ClusterBean, error) GetEnvironmentListForAutocomplete() ([]EnvironmentBean, error) FindByIds(ids []*int) ([]*EnvironmentBean, error) FindByNamespaceAndClusterName(namespaces string, clusterName string) (*repository.Environment, error) GetByClusterId(id int) ([]*EnvironmentBean, error) GetCombinedEnvironmentListForDropDown(token string, isActionUserSuperAdmin bool, auth func(token string, object string) bool) ([]*ClusterEnvDto, error) GetCombinedEnvironmentListForDropDownByClusterIds(token string, clusterIds []int, auth func(token string, object string) bool) ([]*ClusterEnvDto, error) }
type EnvironmentServiceImpl ¶
type EnvironmentServiceImpl struct { K8sUtil *util.K8sUtil // contains filtered or unexported fields }
func NewEnvironmentServiceImpl ¶
func NewEnvironmentServiceImpl(environmentRepository repository.EnvironmentRepository, clusterService ClusterService, logger *zap.SugaredLogger, K8sUtil *util.K8sUtil, k8sInformerFactory informer.K8sInformerFactory, userAuthService user.UserAuthService) *EnvironmentServiceImpl
func (EnvironmentServiceImpl) Create ¶
func (impl EnvironmentServiceImpl) Create(mappings *EnvironmentBean, userId int32) (*EnvironmentBean, error)
func (EnvironmentServiceImpl) Delete ¶ added in v0.3.15
func (impl EnvironmentServiceImpl) Delete(deleteReq *EnvironmentBean, userId int32) error
func (EnvironmentServiceImpl) FindById ¶
func (impl EnvironmentServiceImpl) FindById(id int) (*EnvironmentBean, error)
func (EnvironmentServiceImpl) FindByIds ¶
func (impl EnvironmentServiceImpl) FindByIds(ids []*int) ([]*EnvironmentBean, error)
func (EnvironmentServiceImpl) FindByNamespaceAndClusterName ¶
func (impl EnvironmentServiceImpl) FindByNamespaceAndClusterName(namespaces string, clusterName string) (*repository.Environment, error)
func (EnvironmentServiceImpl) FindClusterByEnvId ¶
func (impl EnvironmentServiceImpl) FindClusterByEnvId(id int) (*ClusterBean, error)
func (EnvironmentServiceImpl) FindOne ¶
func (impl EnvironmentServiceImpl) FindOne(environment string) (*EnvironmentBean, error)
func (EnvironmentServiceImpl) GetAll ¶
func (impl EnvironmentServiceImpl) GetAll() ([]EnvironmentBean, error)
func (EnvironmentServiceImpl) GetAllActive ¶
func (impl EnvironmentServiceImpl) GetAllActive() ([]EnvironmentBean, error)
func (EnvironmentServiceImpl) GetByClusterId ¶
func (impl EnvironmentServiceImpl) GetByClusterId(id int) ([]*EnvironmentBean, error)
func (EnvironmentServiceImpl) GetCombinedEnvironmentListForDropDown ¶ added in v0.3.14
func (impl EnvironmentServiceImpl) GetCombinedEnvironmentListForDropDown(token string, isActionUserSuperAdmin bool, auth func(token string, object string) bool) ([]*ClusterEnvDto, error)
func (EnvironmentServiceImpl) GetCombinedEnvironmentListForDropDownByClusterIds ¶ added in v0.3.14
func (impl EnvironmentServiceImpl) GetCombinedEnvironmentListForDropDownByClusterIds(token string, clusterIds []int, auth func(token string, object string) bool) ([]*ClusterEnvDto, error)
func (EnvironmentServiceImpl) GetEnvironmentListForAutocomplete ¶
func (impl EnvironmentServiceImpl) GetEnvironmentListForAutocomplete() ([]EnvironmentBean, error)
func (EnvironmentServiceImpl) Update ¶
func (impl EnvironmentServiceImpl) Update(mappings *EnvironmentBean, userId int32) (*EnvironmentBean, error)
Source Files
¶
Click to show internal directories.
Click to hide internal directories.