daemon

Documentation

Index

• Variables
• func Coalesce(values ...string) string
• func StartMetricsServer(addr string)
• func StringArg(args map[string]interface{}, key string) (string, bool)
• type CaddyManager
  • func NewCaddyManager() *CaddyManager
  • func (cm *CaddyManager) EnsureMainCaddyfile() error
  • func (cm *CaddyManager) GenerateConfig(appName, domain, outputMode string, port int, appDir string, ...) error
  • func (cm *CaddyManager) Reload() error
  • func (cm *CaddyManager) RemoveConfig(appName string) error
  • func (cm *CaddyManager) Validate() error
• type CommandHandler
  • func NewCommandHandler(config *types.DaemonConfig) *CommandHandler
  • func (ch *CommandHandler) HandleCommand(cmd types.Command) types.Response
  • func (ch *CommandHandler) Shutdown()
  • func (ch *CommandHandler) ValidateCommand(cmd types.Command) error
• type HealthMonitor
  • func NewHealthMonitor(config *types.DaemonConfig) *HealthMonitor
  • func (hm *HealthMonitor) Start()
• type MonitoredApp
• type NextDeployDaemon
  • func NewNextDeployDaemon(configPath string, socketPathOverride string) (*NextDeployDaemon, error)
  • func (d *NextDeployDaemon) Shutdown()
  • func (d *NextDeployDaemon) Start() error
• type ProcessManager
  • func NewProcessManager() *ProcessManager
  • func (pm *ProcessManager) CurrentServiceName() string
  • func (pm *ProcessManager) FindAppServices(appName string) ([]string, error)
  • func (pm *ProcessManager) GenerateServiceFile(appName, projectDir, outputMode string, dopplerToken string, port int, ...) (string, bool, error)
  • func (pm *ProcessManager) RemoveService(serviceName string) error
  • func (pm *ProcessManager) RestartService(serviceName string) error
  • func (pm *ProcessManager) StartService(serviceName string) error
  • func (pm *ProcessManager) StopService(serviceName string) error
• type ReleaseContext
• type SocketServer
  • func NewSocketServer(socketPath string, commandHandler *CommandHandler) *SocketServer
  • func (ss *SocketServer) AcceptConnections()
  • func (ss *SocketServer) Close() error
  • func (ss *SocketServer) Start() error

Variables

var (
	CommandsHandled = expvar.NewInt("commands_handled")
	RequestsTotal   = expvar.NewInt("requests_total")
	StartTime       = time.Now()
)

Functions

func Coalesce

func Coalesce(values ...string) string

func StartMetricsServer

func StartMetricsServer(addr string)

func StringArg

func StringArg(args map[string]interface{}, key string) (string, bool)

Types

type CaddyManager

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

func NewCaddyManager

func NewCaddyManager() *CaddyManager

func (*CaddyManager) EnsureMainCaddyfile

func (cm *CaddyManager) EnsureMainCaddyfile() error

func (*CaddyManager) GenerateConfig

func (cm *CaddyManager) GenerateConfig(appName, domain, outputMode string, port int, appDir string, features *nextcore.DetectedFeatures, distDir, exportDir string) error

func (*CaddyManager) Reload

func (cm *CaddyManager) Reload() error

func (*CaddyManager) RemoveConfig

func (cm *CaddyManager) RemoveConfig(appName string) error

func (*CaddyManager) Validate

func (cm *CaddyManager) Validate() error

type CommandHandler

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

func NewCommandHandler

func NewCommandHandler(config *types.DaemonConfig) *CommandHandler

func (*CommandHandler) HandleCommand

func (ch *CommandHandler) HandleCommand(cmd types.Command) types.Response

func (*CommandHandler) Shutdown

func (ch *CommandHandler) Shutdown()

func (*CommandHandler) ValidateCommand

func (ch *CommandHandler) ValidateCommand(cmd types.Command) error

type HealthMonitor

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

func NewHealthMonitor

func NewHealthMonitor(config *types.DaemonConfig) *HealthMonitor

func (*HealthMonitor) Start

func (hm *HealthMonitor) Start()

type MonitoredApp

type MonitoredApp struct {
	ContainerName string
	DesiredState  string // "running" or "stopped"
	RestartPolicy string // "always", "on-failure", "never"
	MaxRestarts   int
	RestartCount  int
	LastCheck     time.Time
}

type NextDeployDaemon

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

func NewNextDeployDaemon

func NewNextDeployDaemon(configPath string, socketPathOverride string) (*NextDeployDaemon, error)

func (*NextDeployDaemon) Shutdown

func (d *NextDeployDaemon) Shutdown()

func (*NextDeployDaemon) Start

func (d *NextDeployDaemon) Start() error

type ProcessManager

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

func NewProcessManager

func NewProcessManager() *ProcessManager

func (*ProcessManager) CurrentServiceName

func (pm *ProcessManager) CurrentServiceName() string

func (*ProcessManager) FindAppServices

func (pm *ProcessManager) FindAppServices(appName string) ([]string, error)

func (*ProcessManager) GenerateServiceFile

func (pm *ProcessManager) GenerateServiceFile(appName, projectDir, outputMode string, dopplerToken string, port int, packageManager string, releaseID string) (string, bool, error)

func (*ProcessManager) RemoveService

func (pm *ProcessManager) RemoveService(serviceName string) error

func (*ProcessManager) RestartService

func (pm *ProcessManager) RestartService(serviceName string) error

func (*ProcessManager) StartService

func (pm *ProcessManager) StartService(serviceName string) error

func (*ProcessManager) StopService

func (pm *ProcessManager) StopService(serviceName string) error

type ReleaseContext

type ReleaseContext struct {
	AppName          string
	Domain           string
	ReleaseDir       string
	ReleaseID        string
	OutputMode       string
	DopplerToken     string
	PackageManager   string
	TarballPath      string
	DetectedFeatures *nextcore.DetectedFeatures
	DistDir          string
	ExportDir        string
}

type SocketServer

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

func NewSocketServer

func NewSocketServer(socketPath string, commandHandler *CommandHandler) *SocketServer

func (*SocketServer) AcceptConnections

func (ss *SocketServer) AcceptConnections()

func (*SocketServer) Close

func (ss *SocketServer) Close() error

func (*SocketServer) Start

func (ss *SocketServer) Start() error