Documentation ¶
Index ¶
- type Cluster
- type ClusterDescription
- type ClusterDescriptionRepository
- type ClusterDescriptionRepositoryImpl
- type ClusterNamespacePair
- type ClusterRepository
- type ClusterRepositoryImpl
- func (impl ClusterRepositoryImpl) Delete(model *Cluster) error
- func (impl ClusterRepositoryImpl) FindActiveClusters() ([]Cluster, error)
- func (impl ClusterRepositoryImpl) FindAll() ([]Cluster, error)
- func (impl ClusterRepositoryImpl) FindAllActive() ([]Cluster, error)
- func (impl ClusterRepositoryImpl) FindAllActiveExceptVirtual() ([]Cluster, error)
- func (impl ClusterRepositoryImpl) FindById(id int) (*Cluster, error)
- func (impl ClusterRepositoryImpl) FindByIds(id []int) ([]Cluster, error)
- func (impl ClusterRepositoryImpl) FindByNames(clusterNames []string) ([]*Cluster, error)
- func (impl ClusterRepositoryImpl) FindOne(clusterName string) (*Cluster, error)
- func (impl ClusterRepositoryImpl) FindOneActive(clusterName string) (*Cluster, error)
- func (impl ClusterRepositoryImpl) MarkClusterDeleted(model *Cluster) error
- func (impl ClusterRepositoryImpl) Save(model *Cluster) error
- func (impl ClusterRepositoryImpl) SaveAll(models []*Cluster) error
- func (impl ClusterRepositoryImpl) SetDescription(id int, description string, userId int32) error
- func (impl ClusterRepositoryImpl) Update(model *Cluster) error
- func (impl ClusterRepositoryImpl) UpdateClusterConnectionStatus(clusterId int, errorInConnecting string) error
- type ContainerAction
- type EnvCluserInfo
- type Environment
- type EnvironmentRepository
- type EnvironmentRepositoryImpl
- func (repositoryImpl EnvironmentRepositoryImpl) Create(mappings *Environment) error
- func (repositoryImpl EnvironmentRepositoryImpl) FindAll() ([]Environment, error)
- func (repositoryImpl EnvironmentRepositoryImpl) FindAllActive() ([]*Environment, error)
- func (repositoryImpl EnvironmentRepositoryImpl) FindAllActiveEnvOnlyDetails() ([]*Environment, error)
- func (repositoryImpl EnvironmentRepositoryImpl) FindAllActiveWithFilter() ([]*Environment, error)
- func (repositoryImpl EnvironmentRepositoryImpl) FindByClusterId(clusterId int) ([]*Environment, error)
- func (repositoryImpl EnvironmentRepositoryImpl) FindByClusterIdAndNamespace(namespaceClusterPair []*ClusterNamespacePair) ([]*Environment, error)
- func (repositoryImpl EnvironmentRepositoryImpl) FindByClusterIds(clusterIds []int) ([]*Environment, error)
- func (repositoryImpl EnvironmentRepositoryImpl) FindByClusterIdsWithFilter(clusterIds []int) ([]*Environment, error)
- func (repositoryImpl EnvironmentRepositoryImpl) FindByEnvName(envName string) ([]*Environment, error)
- func (repositoryImpl EnvironmentRepositoryImpl) FindByEnvNameAndClusterIds(envName string, clusterIds []int) ([]*Environment, error)
- func (repositoryImpl EnvironmentRepositoryImpl) FindByEnvNameOrIdentifierOrNamespace(clusterId int, envName string, identifier string, namespace string) (*Environment, error)
- func (repositoryImpl EnvironmentRepositoryImpl) FindById(id int) (*Environment, error)
- func (repositoryImpl EnvironmentRepositoryImpl) FindByIdentifier(identifier string) (*Environment, error)
- func (repositoryImpl EnvironmentRepositoryImpl) FindByIds(ids []*int) ([]*Environment, error)
- func (repositoryImpl EnvironmentRepositoryImpl) FindByName(name string) (*Environment, error)
- func (repositoryImpl EnvironmentRepositoryImpl) FindByNameOrIdentifier(name string, identifier string) (*Environment, error)
- func (repo EnvironmentRepositoryImpl) FindByNames(envNames []string) ([]*Environment, error)
- func (repositoryImpl EnvironmentRepositoryImpl) FindByNamespaceAndClusterName(namespaces string, clusterName string) (*Environment, error)
- func (repositoryImpl EnvironmentRepositoryImpl) FindEnvClusterInfosByIds(envIds []int) ([]*EnvCluserInfo, error)
- func (repositoryImpl EnvironmentRepositoryImpl) FindEnvLinkedWithCiPipelines(externalCi bool, ciPipelineIds []int) ([]*Environment, error)
- func (repo EnvironmentRepositoryImpl) FindIdsByNames(envNames []string) ([]int, error)
- func (repositoryImpl EnvironmentRepositoryImpl) FindOne(environment string) (*Environment, error)
- func (repositoryImpl EnvironmentRepositoryImpl) FindOneByNamespaceAndClusterId(namespace string, clusterId int) (*Environment, error)
- func (repo EnvironmentRepositoryImpl) GetConnection() (dbConnection *pg.DB)
- func (repo EnvironmentRepositoryImpl) MarkEnvironmentDeleted(deleteReq *Environment, tx *pg.Tx) error
- func (repositoryImpl EnvironmentRepositoryImpl) Update(mappings *Environment) error
- type EphemeralContainerAction
- type EphemeralContainerBean
- type EphemeralContainersRepository
- type EphemeralContainersRepositoryImpl
- func (impl EphemeralContainersRepositoryImpl) FindContainerByName(clusterID int, namespace, podName, name string) (*EphemeralContainerBean, error)
- func (impl EphemeralContainersRepositoryImpl) SaveEphemeralContainerActionAudit(tx *pg.Tx, model *EphemeralContainerAction) error
- func (impl EphemeralContainersRepositoryImpl) SaveEphemeralContainerData(tx *pg.Tx, model *EphemeralContainerBean) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Cluster ¶
type Cluster struct { Id int `sql:"id,pk"` ClusterName string `sql:"cluster_name"` Description string `sql:"description"` ServerUrl string `sql:"server_url"` PrometheusEndpoint string `sql:"prometheus_endpoint"` Active bool `sql:"active,notnull"` CdArgoSetup bool `sql:"cd_argo_setup,notnull"` Config map[string]string `sql:"config"` PUserName string `sql:"p_username"` PPassword string `sql:"p_password"` PTlsClientCert string `sql:"p_tls_client_cert"` PTlsClientKey string `sql:"p_tls_client_key"` AgentInstallationStage int `sql:"agent_installation_stage"` K8sVersion string `sql:"k8s_version"` ErrorInConnecting string `sql:"error_in_connecting"` IsVirtualCluster bool `sql:"is_virtual_cluster"` InsecureSkipTlsVerify bool `sql:"insecure_skip_tls_verify"` sql.AuditLog // contains filtered or unexported fields }
type ClusterDescription ¶ added in v0.6.17
type ClusterDescription struct { ClusterId int `sql:"cluster_id"` ClusterName string `sql:"cluster_name"` ClusterDescription string `sql:"cluster_description"` ServerUrl string `sql:"server_url"` ClusterCreatedOn time.Time `sql:"cluster_created_on"` ClusterCreatedBy int32 `sql:"cluster_created_by"` NoteId int `sql:"note_id,pk"` Note string `sql:"note"` sql.AuditLog }
TODO: remove this whole repository, nothing different which cannot be included in cluster repository
type ClusterDescriptionRepository ¶ added in v0.6.17
type ClusterDescriptionRepository interface {
FindByClusterIdWithClusterDetails(clusterId int) (*ClusterDescription, error)
}
type ClusterDescriptionRepositoryImpl ¶ added in v0.6.17
type ClusterDescriptionRepositoryImpl struct {
// contains filtered or unexported fields
}
func NewClusterDescriptionRepositoryImpl ¶ added in v0.6.17
func NewClusterDescriptionRepositoryImpl(dbConnection *pg.DB, logger *zap.SugaredLogger) *ClusterDescriptionRepositoryImpl
func (ClusterDescriptionRepositoryImpl) FindByClusterIdWithClusterDetails ¶ added in v0.6.17
func (impl ClusterDescriptionRepositoryImpl) FindByClusterIdWithClusterDetails(clusterId int) (*ClusterDescription, error)
type ClusterNamespacePair ¶ added in v0.3.14
type ClusterRepository ¶
type ClusterRepository interface { Save(model *Cluster) error FindOne(clusterName string) (*Cluster, error) FindOneActive(clusterName string) (*Cluster, error) FindAll() ([]Cluster, error) FindAllActive() ([]Cluster, error) FindAllActiveExceptVirtual() ([]Cluster, error) FindById(id int) (*Cluster, error) FindByIds(id []int) ([]Cluster, error) Update(model *Cluster) error SetDescription(id int, description string, userId int32) error Delete(model *Cluster) error MarkClusterDeleted(model *Cluster) error UpdateClusterConnectionStatus(clusterId int, errorInConnecting string) error FindActiveClusters() ([]Cluster, error) SaveAll(models []*Cluster) error FindByNames(clusterNames []string) ([]*Cluster, error) }
type ClusterRepositoryImpl ¶
type ClusterRepositoryImpl struct {
// contains filtered or unexported fields
}
func NewClusterRepositoryImpl ¶
func NewClusterRepositoryImpl(dbConnection *pg.DB, logger *zap.SugaredLogger) *ClusterRepositoryImpl
func (ClusterRepositoryImpl) Delete ¶
func (impl ClusterRepositoryImpl) Delete(model *Cluster) error
func (ClusterRepositoryImpl) FindActiveClusters ¶ added in v0.6.18
func (impl ClusterRepositoryImpl) FindActiveClusters() ([]Cluster, error)
func (ClusterRepositoryImpl) FindAll ¶
func (impl ClusterRepositoryImpl) FindAll() ([]Cluster, error)
func (ClusterRepositoryImpl) FindAllActive ¶
func (impl ClusterRepositoryImpl) FindAllActive() ([]Cluster, error)
func (ClusterRepositoryImpl) FindAllActiveExceptVirtual ¶ added in v0.6.24
func (impl ClusterRepositoryImpl) FindAllActiveExceptVirtual() ([]Cluster, error)
func (ClusterRepositoryImpl) FindById ¶
func (impl ClusterRepositoryImpl) FindById(id int) (*Cluster, error)
func (ClusterRepositoryImpl) FindByIds ¶
func (impl ClusterRepositoryImpl) FindByIds(id []int) ([]Cluster, error)
func (ClusterRepositoryImpl) FindByNames ¶ added in v0.6.23
func (impl ClusterRepositoryImpl) FindByNames(clusterNames []string) ([]*Cluster, error)
func (ClusterRepositoryImpl) FindOne ¶
func (impl ClusterRepositoryImpl) FindOne(clusterName string) (*Cluster, error)
func (ClusterRepositoryImpl) FindOneActive ¶
func (impl ClusterRepositoryImpl) FindOneActive(clusterName string) (*Cluster, error)
func (ClusterRepositoryImpl) MarkClusterDeleted ¶ added in v0.3.15
func (impl ClusterRepositoryImpl) MarkClusterDeleted(model *Cluster) error
func (ClusterRepositoryImpl) Save ¶
func (impl ClusterRepositoryImpl) Save(model *Cluster) error
func (ClusterRepositoryImpl) SaveAll ¶ added in v0.6.18
func (impl ClusterRepositoryImpl) SaveAll(models []*Cluster) error
func (ClusterRepositoryImpl) SetDescription ¶ added in v0.6.26
func (impl ClusterRepositoryImpl) SetDescription(id int, description string, userId int32) error
func (ClusterRepositoryImpl) Update ¶
func (impl ClusterRepositoryImpl) Update(model *Cluster) error
func (ClusterRepositoryImpl) UpdateClusterConnectionStatus ¶ added in v0.4.24
func (impl ClusterRepositoryImpl) UpdateClusterConnectionStatus(clusterId int, errorInConnecting string) error
type ContainerAction ¶ added in v0.6.21
type ContainerAction int
const ActionAccessed ContainerAction = 1
const ActionCreate ContainerAction = 0
const ActionTerminate ContainerAction = 2
type EnvCluserInfo ¶ added in v0.6.17
type Environment ¶
type Environment struct { Id int `sql:"id,pk"` Name string `sql:"environment_name"` ClusterId int `sql:"cluster_id"` Cluster *Cluster Active bool `sql:"active,notnull"` Default bool `sql:"default,notnull"` GrafanaDatasourceId int `sql:"grafana_datasource_id"` Namespace string `sql:"namespace"` EnvironmentIdentifier string `sql:"environment_identifier"` Description string `sql:"description"` IsVirtualEnvironment bool `sql:"is_virtual_environment"` sql.AuditLog // contains filtered or unexported fields }
type EnvironmentRepository ¶
type EnvironmentRepository interface { FindOne(environment string) (*Environment, error) Create(mappings *Environment) error FindAll() ([]Environment, error) FindAllActive() ([]*Environment, error) MarkEnvironmentDeleted(mappings *Environment, tx *pg.Tx) error GetConnection() (dbConnection *pg.DB) FindAllActiveEnvOnlyDetails() ([]*Environment, error) FindById(id int) (*Environment, error) Update(mappings *Environment) error FindByName(name string) (*Environment, error) FindByIdentifier(identifier string) (*Environment, error) FindByNameOrIdentifier(name string, identifier string) (*Environment, error) FindByEnvNameOrIdentifierOrNamespace(clusterId int, envName string, identifier string, namespace string) (*Environment, error) FindByClusterId(clusterId int) ([]*Environment, error) FindByIds(ids []*int) ([]*Environment, error) FindByNamespaceAndClusterName(namespaces string, clusterName string) (*Environment, error) FindOneByNamespaceAndClusterId(namespace string, clusterId int) (*Environment, error) FindByClusterIdAndNamespace(namespaceClusterPair []*ClusterNamespacePair) ([]*Environment, error) FindByClusterIds(clusterIds []int) ([]*Environment, error) FindIdsByNames(envNames []string) ([]int, error) FindByNames(envNames []string) ([]*Environment, error) FindByEnvName(envName string) ([]*Environment, error) FindByEnvNameAndClusterIds(envName string, clusterIds []int) ([]*Environment, error) FindByClusterIdsWithFilter(clusterIds []int) ([]*Environment, error) FindAllActiveWithFilter() ([]*Environment, error) FindEnvClusterInfosByIds([]int) ([]*EnvCluserInfo, error) FindEnvLinkedWithCiPipelines(externalCi bool, ciPipelineIds []int) ([]*Environment, error) }
type EnvironmentRepositoryImpl ¶
type EnvironmentRepositoryImpl struct {
// contains filtered or unexported fields
}
func NewEnvironmentRepositoryImpl ¶
func NewEnvironmentRepositoryImpl(dbConnection *pg.DB, logger *zap.SugaredLogger, appStatusRepository appStatus.AppStatusRepository) *EnvironmentRepositoryImpl
func (EnvironmentRepositoryImpl) Create ¶
func (repositoryImpl EnvironmentRepositoryImpl) Create(mappings *Environment) error
func (EnvironmentRepositoryImpl) FindAll ¶
func (repositoryImpl EnvironmentRepositoryImpl) FindAll() ([]Environment, error)
func (EnvironmentRepositoryImpl) FindAllActive ¶
func (repositoryImpl EnvironmentRepositoryImpl) FindAllActive() ([]*Environment, error)
func (EnvironmentRepositoryImpl) FindAllActiveEnvOnlyDetails ¶ added in v0.6.17
func (repositoryImpl EnvironmentRepositoryImpl) FindAllActiveEnvOnlyDetails() ([]*Environment, error)
func (EnvironmentRepositoryImpl) FindAllActiveWithFilter ¶ added in v0.6.13
func (repositoryImpl EnvironmentRepositoryImpl) FindAllActiveWithFilter() ([]*Environment, error)
func (EnvironmentRepositoryImpl) FindByClusterId ¶
func (repositoryImpl EnvironmentRepositoryImpl) FindByClusterId(clusterId int) ([]*Environment, error)
func (EnvironmentRepositoryImpl) FindByClusterIdAndNamespace ¶ added in v0.3.14
func (repositoryImpl EnvironmentRepositoryImpl) FindByClusterIdAndNamespace(namespaceClusterPair []*ClusterNamespacePair) ([]*Environment, error)
func (EnvironmentRepositoryImpl) FindByClusterIds ¶ added in v0.3.14
func (repositoryImpl EnvironmentRepositoryImpl) FindByClusterIds(clusterIds []int) ([]*Environment, error)
func (EnvironmentRepositoryImpl) FindByClusterIdsWithFilter ¶ added in v0.6.13
func (repositoryImpl EnvironmentRepositoryImpl) FindByClusterIdsWithFilter(clusterIds []int) ([]*Environment, error)
func (EnvironmentRepositoryImpl) FindByEnvName ¶ added in v0.6.13
func (repositoryImpl EnvironmentRepositoryImpl) FindByEnvName(envName string) ([]*Environment, error)
func (EnvironmentRepositoryImpl) FindByEnvNameAndClusterIds ¶ added in v0.6.13
func (repositoryImpl EnvironmentRepositoryImpl) FindByEnvNameAndClusterIds(envName string, clusterIds []int) ([]*Environment, error)
func (EnvironmentRepositoryImpl) FindByEnvNameOrIdentifierOrNamespace ¶ added in v0.6.26
func (repositoryImpl EnvironmentRepositoryImpl) FindByEnvNameOrIdentifierOrNamespace(clusterId int, envName string, identifier string, namespace string) (*Environment, error)
func (EnvironmentRepositoryImpl) FindById ¶
func (repositoryImpl EnvironmentRepositoryImpl) FindById(id int) (*Environment, error)
func (EnvironmentRepositoryImpl) FindByIdentifier ¶ added in v0.3.14
func (repositoryImpl EnvironmentRepositoryImpl) FindByIdentifier(identifier string) (*Environment, error)
func (EnvironmentRepositoryImpl) FindByIds ¶
func (repositoryImpl EnvironmentRepositoryImpl) FindByIds(ids []*int) ([]*Environment, error)
func (EnvironmentRepositoryImpl) FindByName ¶
func (repositoryImpl EnvironmentRepositoryImpl) FindByName(name string) (*Environment, error)
func (EnvironmentRepositoryImpl) FindByNameOrIdentifier ¶ added in v0.3.14
func (repositoryImpl EnvironmentRepositoryImpl) FindByNameOrIdentifier(name string, identifier string) (*Environment, error)
func (EnvironmentRepositoryImpl) FindByNames ¶ added in v0.6.23
func (repo EnvironmentRepositoryImpl) FindByNames(envNames []string) ([]*Environment, error)
func (EnvironmentRepositoryImpl) FindByNamespaceAndClusterName ¶
func (repositoryImpl EnvironmentRepositoryImpl) FindByNamespaceAndClusterName(namespaces string, clusterName string) (*Environment, error)
func (EnvironmentRepositoryImpl) FindEnvClusterInfosByIds ¶ added in v0.6.17
func (repositoryImpl EnvironmentRepositoryImpl) FindEnvClusterInfosByIds(envIds []int) ([]*EnvCluserInfo, error)
func (EnvironmentRepositoryImpl) FindEnvLinkedWithCiPipelines ¶ added in v0.6.19
func (repositoryImpl EnvironmentRepositoryImpl) FindEnvLinkedWithCiPipelines(externalCi bool, ciPipelineIds []int) ([]*Environment, error)
func (EnvironmentRepositoryImpl) FindIdsByNames ¶ added in v0.6.9
func (repo EnvironmentRepositoryImpl) FindIdsByNames(envNames []string) ([]int, error)
func (EnvironmentRepositoryImpl) FindOne ¶
func (repositoryImpl EnvironmentRepositoryImpl) FindOne(environment string) (*Environment, error)
func (EnvironmentRepositoryImpl) FindOneByNamespaceAndClusterId ¶ added in v0.3.17
func (repositoryImpl EnvironmentRepositoryImpl) FindOneByNamespaceAndClusterId(namespace string, clusterId int) (*Environment, error)
func (EnvironmentRepositoryImpl) GetConnection ¶ added in v0.3.15
func (repo EnvironmentRepositoryImpl) GetConnection() (dbConnection *pg.DB)
func (EnvironmentRepositoryImpl) MarkEnvironmentDeleted ¶ added in v0.3.15
func (repo EnvironmentRepositoryImpl) MarkEnvironmentDeleted(deleteReq *Environment, tx *pg.Tx) error
func (EnvironmentRepositoryImpl) Update ¶
func (repositoryImpl EnvironmentRepositoryImpl) Update(mappings *Environment) error
type EphemeralContainerAction ¶ added in v0.6.21
type EphemeralContainerBean ¶ added in v0.6.21
type EphemeralContainerBean struct { Id int `sql:"id,pk"` Name string `sql:"name"` ClusterId int `sql:"cluster_id"` Namespace string `sql:"namespace"` PodName string `sql:"pod_name"` TargetContainer string `sql:"target_container"` Config string `sql:"config"` IsExternallyCreated bool `sql:"is_externally_created"` // contains filtered or unexported fields }
type EphemeralContainersRepository ¶ added in v0.6.21
type EphemeralContainersRepository interface { sql.TransactionWrapper SaveEphemeralContainerData(tx *pg.Tx, model *EphemeralContainerBean) error SaveEphemeralContainerActionAudit(tx *pg.Tx, model *EphemeralContainerAction) error FindContainerByName(clusterID int, namespace, podName, name string) (*EphemeralContainerBean, error) }
type EphemeralContainersRepositoryImpl ¶ added in v0.6.21
type EphemeralContainersRepositoryImpl struct { *sql.TransactionUtilImpl // contains filtered or unexported fields }
func NewEphemeralContainersRepositoryImpl ¶ added in v0.6.21
func NewEphemeralContainersRepositoryImpl(db *pg.DB) *EphemeralContainersRepositoryImpl
func (EphemeralContainersRepositoryImpl) FindContainerByName ¶ added in v0.6.21
func (impl EphemeralContainersRepositoryImpl) FindContainerByName(clusterID int, namespace, podName, name string) (*EphemeralContainerBean, error)
func (EphemeralContainersRepositoryImpl) SaveEphemeralContainerActionAudit ¶ added in v0.6.21
func (impl EphemeralContainersRepositoryImpl) SaveEphemeralContainerActionAudit(tx *pg.Tx, model *EphemeralContainerAction) error
func (EphemeralContainersRepositoryImpl) SaveEphemeralContainerData ¶ added in v0.6.21
func (impl EphemeralContainersRepositoryImpl) SaveEphemeralContainerData(tx *pg.Tx, model *EphemeralContainerBean) error
Source Files ¶
Click to show internal directories.
Click to hide internal directories.