repository

package
v1.1.0 Latest Latest
Warning

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

 Go to latest Published: Dec 20, 2024 License: Apache-2.0 Imports: 5 Imported by: 8

Documentation

Index

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"`
	IsProd                 bool              `sql:"is_prod"`
	sql.AuditLog
	// contains filtered or unexported fields
}

func (*Cluster) IsEmpty added in v1.1.0 

func (c *Cluster) IsEmpty() bool

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 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 EphemeralContainerAction added in v0.6.21 

type EphemeralContainerAction struct {
	Id                   int             `sql:"id,pk"`
	EphemeralContainerId int             `sql:"ephemeral_container_id"`
	ActionType           ContainerAction `sql:"action_type"`
	PerformedBy          int32           `sql:"performed_by"`
	PerformedAt          time.Time       `sql:"performed_at"`
	// contains filtered or unexported fields
}

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, transactionUtilImpl *sql.TransactionUtilImpl) *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

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.