repository

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

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

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

type IAuditLogRepository interface {
	CreateAuditLog(ctx context.Context, auditLog *model.AuditLog) error
}

type IClusterRepository interface {
	GetClusterByUUID(ctx context.Context, uuid string) (*model.Cluster, error)
	GetClustersByProjectId(ctx context.Context, projectId string) ([]model.Cluster, error)
	CreateCluster(ctx context.Context, cluster *model.Cluster) error
	UpdateCluster(ctx context.Context, cluster *model.Cluster) error
	DeleteUpdateCluster(ctx context.Context, cluster *model.Cluster, clusterUUID string) error
}

type IErrorRepository interface {
	CreateError(ctx context.Context, err *model.Error) error
	GetErrorsByClusterUUID(ctx context.Context, clusterUUID string) ([]model.Error, error)
}

type IJobsRepository interface {
	CreateJob(ctx context.Context, job *model.Job) error
	GetJobByIdempotencyKey(ctx context.Context, key string) (*model.Job, error)
	GetJobByUUID(ctx context.Context, jobUUID string) (*model.Job, error)
	MarkJobQueued(ctx context.Context, jobUUID string, nextRunAt time.Time) error
	MarkJobStarted(ctx context.Context, jobUUID, lockedBy string) error
	MarkJobSucceeded(ctx context.Context, jobUUID string) error
	MarkJobFailed(ctx context.Context, jobUUID string, lastErr string, nextRunAt time.Time, attempts int) error
}

type IKubeconfigRepository interface {
	GetKubeconfigByUUID(ctx context.Context, clusterUUID string) (*model.Kubeconfigs, error)
	CreateKubeconfig(ctx context.Context, kubeconfig *model.Kubeconfigs) error
	UpdateKubeconfig(ctx context.Context, clusterUUID string, kubeConfig string) error
}

type INodeGroupsRepository interface {
	GetNodeGroupsByClusterUUID(ctx context.Context, uuid, nodeType, nodeGroupStatus string) ([]model.NodeGroups, error)
	CreateNodeGroups(ctx context.Context, nodeGroups *model.NodeGroups) error
	UpdateNodeGroups(ctx context.Context, nodeGroups *model.NodeGroups) error
	GetNodeGroupByUUID(ctx context.Context, uuid string) (*model.NodeGroups, error)
	GetClusterProjectUUIDByNodeGroupUUID(ctx context.Context, nodeGroupUUID string) (string, error)
}

type IRepository interface {
	Cluster() IClusterRepository
	AuditLog() IAuditLogRepository
	Kubeconfig() IKubeconfigRepository
	NodeGroups() INodeGroupsRepository
	Resources() IResourcesRepository
	Error() IErrorRepository
	Jobs() IJobsRepository
	StartDBTransaction(ctx context.Context) (*gorm.DB, error)
	CommitDBTransaction(tx *gorm.DB) error
}

type IResourcesRepository interface {
	CreateResource(ctx context.Context, resource *model.Resource) error
	GetResourceByClusterUUID(ctx context.Context, clusterUUID string, resourceType string) ([]model.Resource, error)
}

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

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

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

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