deployer

Jul 17, 2026

Changes in this version

type Deployer

+ func (d *Deployer) MovePreparedServiceTakod(serviceName string, service *config.ServiceConfig, imageRef string, ...) error

+ func (d *Deployer) PreflightAssignmentMutations(services map[string]config.ServiceConfig) error

+ func (d *Deployer) PreflightAssignmentRemovals(serviceNames []string) error

+ func (d *Deployer) ResolveAllAssignments(services map[string]config.ServiceConfig) error

+ func (d *Deployer) ResolvedAssignments() map[string][]scheduler.Assignment

+ func (d *Deployer) SetPlacementMovementTargets(serverNames []string) error

+ func (d *Deployer) SetPriorAssignments(assignments map[string][]scheduler.Assignment)

+ func (d *Deployer) SetRuntimeFactory(factory *nodeclient.Factory)

Jul 11, 2026

Changes in this version

type Deployer

+ func (d *Deployer) PreflightTakodProxyCapabilities(services map[string]config.ServiceConfig) error

Jul 10, 2026

Changes in this version

+ const DefaultDeployRunTimeout

+ func PrepareServiceFilesPayload(project, environment, serviceName string, service *config.ServiceConfig) ([]takod.ServiceFileBundle, []string, string, error)

+ func ServiceFileMounts(project, environment, serviceName string, files []config.ServiceFileConfig, ...) ([]string, error)

+ func ServiceFileSetID(contentHash string) (string, error)

+ type DeployRunResult struct

+ Command []string

+ DurationMs int64

+ ExitCode int

+ Image string

+ Server string

+ Service string

type Deployer

+ func (d *Deployer) BuildSharedTakodImage(buildName string, build config.SharedBuildConfig, imageRef string, ...) error

+ func (d *Deployer) DeployPreparedServiceTakod(serviceName string, service *config.ServiceConfig, imageRef string, ...) error

+ func (d *Deployer) EnsurePreparedServiceImage(serviceName string, service *config.ServiceConfig, imageRef string) error

+ func (d *Deployer) EnsureSharedTakodImage(buildName string, imageRef string, consumers map[string]config.ServiceConfig) error

+ func (d *Deployer) PrepareServiceFiles(serviceName string, service *config.ServiceConfig) ([]takod.ServiceFileBundle, []string, string, error)

+ func (d *Deployer) RunDeployStep(serviceName string, service *config.ServiceConfig, imageRef string, ...) (*DeployRunResult, error)

+ func (d *Deployer) RunDeployStepOnNodes(serviceName string, service *config.ServiceConfig, imageRef string, ...) (*DeployRunResult, error)

+ func (d *Deployer) RunInputHash(service *config.ServiceConfig) (string, error)

Jul 7, 2026

Changes in this version

+ const DefaultReleaseTimeout

type Deployer

+ func (d *Deployer) ApplyJobSchedules(services map[string]config.ServiceConfig) error

+ func (d *Deployer) JobOwnerServer(service *config.ServiceConfig) (string, error)

+ func (d *Deployer) ReleaseRunFor(serviceName string) *ReleaseRun

+ func (d *Deployer) SetBaseContext(ctx context.Context)

+ func (d *Deployer) SetEventSink(sink events.Sink)

+ type RegistryAuthError struct

+ Err error

+ Node string

+ func (e *RegistryAuthError) Error() string

+ func (e *RegistryAuthError) Unwrap() error

+ type ReleaseRun struct

+ Command []string

+ DurationMs int64

+ ExitCode int

+ Image string

+ Server string

+ Service string

Jul 6, 2026

Changes in this version

type Deployer

+ func (d *Deployer) SetOutput(w io.Writer)

Jun 22, 2026

Changes in this version

+ func ServiceRevisionID(project string, environment string, serviceName string, imageRef string, ...) string

type Deployer

+ func (d *Deployer) ActivateTakodServiceRevision(serviceName string, service *config.ServiceConfig, imageRef string) error

+ func (d *Deployer) DeployServiceTakodWarmOnly(serviceName string, service *config.ServiceConfig, imageRef string) error

+ func (d *Deployer) PruneTakodServiceRevisions(services map[string]config.ServiceConfig, keepRevisions map[string]string) error

+ func (d *Deployer) ReconcileTakodProxyWithActiveRevisions(services map[string]config.ServiceConfig, activeRevisions map[string]string) error

Jun 18, 2026

Changes in this version

type Deployer

+ func (d *Deployer) SetSkipBuild(skip bool)

Jun 16, 2026

Changes in this version

type Deployer

+ func (d *Deployer) BuildServiceEnvFileContent(serviceName string, service *config.ServiceConfig) (string, error)

Jun 15, 2026

Changes in this version

type Deployer

+ func (d *Deployer) DeployServiceTakod(serviceName string, service *config.ServiceConfig, imageRef string) error

+ func (d *Deployer) PrepareGeneratedConfigArtifacts(services map[string]config.ServiceConfig) (map[string]config.ServiceConfig, error)

+ func (d *Deployer) ReconcileTakodProxy(services map[string]config.ServiceConfig) error

+ func (d *Deployer) RemoveServiceTakod(serviceName string) error

+ func (d *Deployer) SetCLIVersion(version string)

+ func (d *Deployer) SetDeployHooksEnabled(enabled bool)

+ func (d *Deployer) SetTargetServers(serverNames []string) error

+ func (d *Deployer) SetupTakodRuntime() error

+ func (d *Deployer) ValidateServicePlatformCompatibility(serviceName string, service *config.ServiceConfig) error

Nov 16, 2025

Changes in this version

+ type BuildJob struct

+ ImageName string

+ Service *config.ServiceConfig

+ ServiceName string

+ type BuildResult struct

+ Duration time.Duration

+ Error error

+ ImageName string

+ ServiceName string

+ type CacheManager struct

+ func NewCacheManager(projectName, environment string, verbose bool) *CacheManager

+ func (cm *CacheManager) GenerateCacheKey(serviceName string, service *config.ServiceConfig) (string, error)

+ func (cm *CacheManager) GetBuildCommand(imageName, buildContext string, service *config.ServiceConfig) string

+ func (cm *CacheManager) GetBuildKitFlags(serviceName string, service *config.ServiceConfig) []string

+ func (cm *CacheManager) GetLocalCachePath(serviceName string) string

+ func (cm *CacheManager) IsCached(serviceName string) bool

+ func (cm *CacheManager) OptimizeBuildContext(buildPath string) ([]string, error)

+ func (cm *CacheManager) SaveImageToCache(imageName, serviceName string) error

+ type CacheStats struct

+ CacheHits int

+ CacheMisses int

+ TimesSaved time.Duration

+ TotalBuilds int

+ func (cs *CacheStats) GetHitRate() float64

+ func (cs *CacheStats) Report()

+ type ContainerManager struct

+ func NewContainerManager(client *ssh.Client, verbose bool) *ContainerManager

+ func (cm *ContainerManager) Exists(containerName string) (bool, error)

+ func (cm *ContainerManager) GetStatus(containerName string) (string, error)

+ func (cm *ContainerManager) IsRunning(containerName string) (bool, error)

+ func (cm *ContainerManager) Remove(containerName string) error

+ func (cm *ContainerManager) Rename(oldName, newName string) error

+ func (cm *ContainerManager) StopGracefully(containerName string, gracePeriodSeconds int) error

+ func (cm *ContainerManager) WaitForTrafficDrain(containerName string, drainSeconds int)

+ type Deployer struct

+ func NewDeployer(client *ssh.Client, cfg *config.Config, environment string, verbose bool) *Deployer

+ func NewDeployerWithPool(client *ssh.Client, cfg *config.Config, environment string, sshPool *ssh.Pool, ...) *Deployer

+ func (d *Deployer) BuildImage(serviceName string, service *config.ServiceConfig) (string, error)

+ func (d *Deployer) CheckPortAvailability(port int) (*PortInfo, error)

+ func (d *Deployer) DeployService(serviceName string, service *config.ServiceConfig, skipBuild bool) error

+ func (d *Deployer) DeployServiceSwarm(serviceName string, service *config.ServiceConfig, fullImageName string) error

+ func (d *Deployer) IsSwarmMode() bool

+ func (d *Deployer) ResolvePortConflict(portInfo *PortInfo, serviceName string, autoKill bool) error

+ func (d *Deployer) Rollback(serviceName string) error

+ func (d *Deployer) RollbackToState(serviceName string, serviceState *state.ServiceState) error

+ func (d *Deployer) SetupSwarmCluster() error

+ func (d *Deployer) VerifyDatabaseConnectivity(serviceName string, service *config.ServiceConfig) error

+ func (d *Deployer) VerifyNetworkSetup() error

+ type DeploymentMetrics struct

+ BuildDuration time.Duration

+ BuildsParallel int

+ CacheHitRate float64

+ DeployDuration time.Duration

+ DeploysParallel int

+ EndTime time.Time

+ Failures []string

+ ParallelSpeedup float64

+ ServicesDeployed int

+ StartTime time.Time

+ TotalDuration time.Duration

+ type DeploymentOrchestrator struct

+ func NewDeploymentOrchestrator(deployer *Deployer, config OrchestratorConfig) *DeploymentOrchestrator

+ func (do *DeploymentOrchestrator) Deploy(ctx context.Context, services map[string]config.ServiceConfig, skipBuild bool) error

+ func (do *DeploymentOrchestrator) EstimateDeploymentTime(serviceCount int) time.Duration

+ func (do *DeploymentOrchestrator) GetMetrics() *DeploymentMetrics

+ type EnhancedBuildResult struct

+ CacheHit bool

+ Duration time.Duration

+ Error error

+ ImageName string

+ ServiceName string

+ func (r *EnhancedBuildResult) String() string

+ type EnvManager struct

+ func NewEnvManager(client *ssh.Client, projectName, environment string, verbose bool) *EnvManager

+ func (em *EnvManager) LoadAndMerge(service *config.ServiceConfig) map[string]string

+ type HealthChecker struct

+ func NewHealthChecker(client *ssh.Client, verbose bool) *HealthChecker

+ func (hc *HealthChecker) VerifyDatabaseConnectivity(containerName string, service *config.ServiceConfig) error

+ func (hc *HealthChecker) WaitForHealthy(containerName string, retries int) error

+ type IgnoreParser struct

+ func NewIgnoreParser() *IgnoreParser

+ func (ip *IgnoreParser) AddDefaultExclusions()

+ func (ip *IgnoreParser) GetExcludedPatterns() []string

+ func (ip *IgnoreParser) LoadIgnoreFile(filePath string) error

+ func (ip *IgnoreParser) ShouldIgnore(relPath string) bool

+ type MaintenanceManager struct

+ func NewMaintenanceManager(client *ssh.Client, projectName string, verbose bool) *MaintenanceManager

+ func (mm *MaintenanceManager) IsActive(serviceName string) (bool, error)

+ func (mm *MaintenanceManager) Remove(serviceName string) error

+ type OrchestratorConfig struct

+ BuildTimeout time.Duration

+ DeployTimeout time.Duration

+ EnableCache bool

+ MaxConcurrentBuilds int

+ MaxConcurrentDeploys int

+ type ParallelBuilder struct

+ func NewParallelBuilder(deployer *Deployer, maxConcurrent int) *ParallelBuilder

+ func (pb *ParallelBuilder) BuildAllLevels(ctx context.Context, services map[string]config.ServiceConfig, skipBuild bool) (map[string]string, error)

+ func (pb *ParallelBuilder) GroupByDependencyLevel(services map[string]config.ServiceConfig) [][]string

+ type ParallelDeployer struct

+ func NewParallelDeployer(deployer *Deployer, maxConcurrent int) *ParallelDeployer

+ func (pd *ParallelDeployer) DeployLevel(ctx context.Context, services map[string]config.ServiceConfig, ...) error

+ type PortInfo struct

+ ContainerID string

+ IsDocker bool

+ PID string

+ Port int

+ ProcessName string

+ type ReplicaManager struct

+ func NewReplicaManager(client *ssh.Client, projectName, environment string, verbose bool) *ReplicaManager

+ func (rm *ReplicaManager) CleanupOld(serviceName string, desiredCount int) error

+ func (rm *ReplicaManager) GetContainerName(serviceName string, replicaNum int) string

+ type Stage struct

+ Fn func(context.Context) error

+ Name string

+ type VolumeTransformer struct

+ func NewVolumeTransformer(projectName, environment string) *VolumeTransformer

+ func (vt *VolumeTransformer) Transform(volumes []string) []string