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)
	// RetireIdempotencyKey renames idempotency_key so a new job can reuse the same logical key (e.g. after cluster deleted).
	RetireIdempotencyKey(ctx context.Context, jobUUID string) 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
}