service_repo

type CreateServiceInput struct {
	KubernetesName       string
	Name                 string
	ServiceType          schema.ServiceType
	Description          string
	EnvironmentID        uuid.UUID
	GitHubInstallationID *int64
	GitRepository        *string
	GitRepositoryOwner   *string
	KubernetesSecret     string
	Database             *string
	DatabaseVersion      *string
	TemplateID           *uuid.UUID
	TemplateInstanceID   *uuid.UUID
	ServiceGroupID       *uuid.UUID
	DetectedPorts        []schema.PortSpec // This is used to store detected ports, not for creation
}

type MutateConfigInput struct {
	ServiceID                     uuid.UUID
	Builder                       *schema.ServiceBuilder
	Provider                      *enum.Provider
	Framework                     *enum.Framework
	GitBranch                     *string
	GitTag                        *string
	Icon                          *string
	OverwritePorts                []schema.PortSpec
	AddPorts                      []schema.PortSpec
	RemovePorts                   []schema.PortSpec
	OverwriteHosts                []schema.HostSpec
	AddHosts                      []schema.HostSpec
	RemoveHosts                   []schema.HostSpec
	Replicas                      *int32
	AutoDeploy                    *bool
	RailpackBuilderInstallCommand *string
	RailpackBuilderBuildCommand   *string
	RunCommand                    *string
	Public                        *bool
	Image                         *string
	DockerBuilderDockerfilePath   *string
	DockerBuilderBuildContext     *string
	CustomDefinitionVersion       *string
	DatabaseConfig                *schema.DatabaseConfig
	S3BackupSourceID              *uuid.UUID
	S3BackupBucket                *string
	BackupSchedule                *string
	BackupRetentionCount          *int
	SecurityContext               *schema.SecurityContext
	HealthCheck                   *schema.HealthCheck
	OverwriteVariableMounts       []*schema.VariableMount
	AddVariableMounts             []*schema.VariableMount
	RemoveVariableMounts          []*schema.VariableMount
	ProtectedVariables            *[]string
	OverwriteVolumes              []schema.ServiceVolume
	AddVolumes                    []schema.ServiceVolume
	RemoveVolumes                 []schema.ServiceVolume
	InitContainers                []*schema.InitContainer
	Resources                     *schema.Resources
}

type NeedsDeploymentResponse string

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

type ServiceRepositoryInterface interface {
	// Create the service
	Create(ctx context.Context, tx repository.TxInterface, input *CreateServiceInput) (*ent.Service, error)
	CreateConfig(ctx context.Context, tx repository.TxInterface, input *MutateConfigInput) (*ent.ServiceConfig, error)
	// Update the service
	Update(ctx context.Context, tx repository.TxInterface, serviceID uuid.UUID, name *string, description *string) error
	// Update service config
	UpdateConfig(ctx context.Context, tx repository.TxInterface, existingConfig *ent.ServiceConfig, input *MutateConfigInput) error
	Delete(ctx context.Context, tx repository.TxInterface, serviceID uuid.UUID) error
	SetCurrentDeployment(ctx context.Context, tx repository.TxInterface, serviceID uuid.UUID, deploymentID uuid.UUID) error
	UpdateVariableMounts(ctx context.Context, tx repository.TxInterface, serviceID uuid.UUID, variableMounts []*schema.VariableMount) error
	UpdateDatabaseStorageSize(ctx context.Context, tx repository.TxInterface, serviceID uuid.UUID, newSize string) (*schema.DatabaseConfig, error)
	GetByID(ctx context.Context, serviceID uuid.UUID) (svc *ent.Service, err error)
	GetByIDsAndEnvironment(ctx context.Context, serviceIDs []uuid.UUID, environmentID uuid.UUID) ([]*ent.Service, error)
	GetByName(ctx context.Context, name string) (*ent.Service, error)
	GetDatabaseType(ctx context.Context, serviceID uuid.UUID) (string, error)
	GetDatabases(ctx context.Context) ([]*ent.Service, error)
	GetByInstallationIDAndRepoName(ctx context.Context, installationID int64, repoName string) ([]*ent.Service, error)
	GetByEnvironmentID(ctx context.Context, environmentID uuid.UUID, authPredicate predicate.Service, withLatestDeployment bool) ([]*ent.Service, error)
	GetGithubPrivateKey(ctx context.Context, serviceID uuid.UUID) (string, error)
	CountDomainCollisons(ctx context.Context, tx repository.TxInterface, domain string) (int, error)
	GetDeploymentNamespace(ctx context.Context, serviceID uuid.UUID) (string, error)
	// Summarize services in environment
	SummarizeServices(ctx context.Context, environmentIDs []uuid.UUID) (counts map[uuid.UUID]int, icons map[uuid.UUID][]string, err error)
	NeedsDeployment(ctx context.Context, service *ent.Service) (NeedsDeploymentResponse, error)
	// See if volume is in use
	IsVolumeInUse(ctx context.Context, volumeName string) (bool, error)
	// Get services using a PVC
	GetServicesUsingPVC(ctx context.Context, pvcID string) ([]*ent.Service, error)
	// Get PVC mount paths by IDs
	GetPVCMountPaths(ctx context.Context, pvcs []*models.PVCInfo) (map[string]string, error)
	// Get database config for a service
	GetDatabaseConfig(ctx context.Context, serviceID uuid.UUID) (*schema.DatabaseConfig, error)
}