niseroku

package

Go to main page

Versions in this module

v0

v0.2.3

Aug 9, 2024

v0.2.2

Feb 8, 2024

v0.2.1

Jan 20, 2024

v0.2.0

Jan 20, 2024

v0.1.21

Jan 16, 2024

v0.1.20

Jan 15, 2024

v0.1.19

Jan 15, 2024

v0.1.18

Dec 16, 2023

v0.1.17

Dec 6, 2023

Changes in this version

type Slug

+ func (s *Slug) HttpClientDo(port int, req *http.Request) (response *http.Response, err error)

v0.1.16

Nov 30, 2023

v0.1.15

Nov 30, 2023

v0.1.14

Aug 28, 2023

v0.1.13

Aug 28, 2023

v0.1.12

Jul 11, 2023

Changes in this version

type ParsedDebianFile

+ File string

v0.1.11

Jul 10, 2023

Changes in this version

+ type ParsedDebianFile struct

+ Arch string

+ Input string

+ Name string

+ RawVer string

+ Type string

+ Version version.Version

type RepreproListEntry

+ RawVer string

v0.1.10

Apr 8, 2023

v0.1.9

Apr 3, 2023

Changes in this version

type WatchProc

+ Created uint64

v0.1.8

Mar 30, 2023

Changes in this version

+ var CdkIncludeLogFile = "false"

+ var CdkIncludeLogFormat = "false"

+ var CdkIncludeLogFullPaths = "false"

+ var CdkIncludeLogLevel = "false"

+ var CdkIncludeLogLevels = "false"

+ var CdkIncludeLogOutput = "false"

+ var CdkIncludeLogTimestamps = "false"

+ var CdkIncludeProfiling = "false"

type Slug

+ func (s *Slug) StartCommand(name string, argv ...string) (err error)

+ func (s *Slug) StartShell() (err error)

type SlugWorker

+ func (s *SlugWorker) RunCommand(name string, argv ...string) (err error)

+ func (s *SlugWorker) RunShell() (err error)

v0.1.7

Mar 27, 2023

v0.1.6

Mar 20, 2023

v0.1.5

Mar 11, 2023

v0.1.4

Mar 11, 2023

v0.1.3

Mar 11, 2023

v0.1.2

Mar 10, 2023

Changes in this version

type Application

+ func (a *Application) IsRunningReady() (runningReady bool)

type Config

+ RestartSlugsOnStart bool

type Slug

+ func (s *Slug) GetSlugWorkerHashes() (workers []string)

v0.1.1

Mar 10, 2023

v0.1.0

Mar 5, 2023

Changes in this version

+ const ConfigFileName

+ const Name

+ const ProxyControlResponseMaxSize

+ var DefaultAppEndPort = 4400

+ var DefaultAppStartPort = 4200

+ var DefaultBuildPack = "https://github.com/go-enjin/enjenv-heroku-buildpack.git"

+ var DefaultConfigLocations = []string

+ var DefaultGitPort = 2403

+ var DefaultHttpPort = 80

+ var DefaultHttpsPort = 443

+ var DefaultOriginRequestTimeout = time.Minute

+ var DefaultProxyLimitsStatLifetime = time.Second

+ var DefaultRateLimitBurst int = 150

+ var DefaultRateLimitDelayScale int = 10

+ var DefaultRateLimitMax float64 = 150.0

+ var DefaultRateLimitMaxDelay time.Duration = 2 * time.Second

+ var DefaultRateLimitTTL time.Duration = 8760 * time.Hour

+ var DefaultReadyIntervalTimeout = time.Second

+ var DefaultRunAsGroup = "www-data"

+ var DefaultRunAsUser = "www-data"

+ var DefaultSlugStartupTimeout = 5 * time.Minute

+ var DefaultStatusWatchTtyPath = "/dev/tty"

+ var DefaultStatusWatchUpdateFrequency = time.Second

+ var IncludeLogFile = "false"

+ var IncludeLogFormat = "false"

+ var IncludeLogFullPaths = "false"

+ var IncludeLogLevel = "false"

+ var IncludeLogLevels = "false"

+ var IncludeLogOutput = "false"

+ var IncludeLogTimestampFormat = "false"

+ var IncludeLogTimestamps = "false"

+ var IncludeProfiling = "false"

+ var RxDebFileName = regexp.MustCompile(`^\s*(.+?)_(.+?)_(.+?)\.u?deb\s*$`)

+ var RxDscFileName = regexp.MustCompile(`^\s*(.+?)_(.+?)\.dsc\s*$`)

+ var RxExportLine = regexp.MustCompile(`^\s*export (.+?)=(['"]?)(.+?)(['"]?)\s*$`)

+ var RxLogFileName = regexp.MustCompile(`(?:/|^)([^/]+?)\.?(access|info|error|)\.log$`)

+ var RxRepreproList = regexp.MustCompile(`^\s*([^|]+)\|([^|]+)\|([^|]+):\s*(\S+)\s*(\S+)\s*$`)

+ var RxSlugArchiveName = regexp.MustCompile(`(?:/|^)([^/]+?)--([a-f0-9]+)\.zip$`)

+ var RxSlugRunningName = regexp.MustCompile(`(?:/|^)([^/]+?)--([a-f0-9]+).([a-f0-9]{10})(\.pid|\.port|)$`)

+ var RxSockCommand = regexp.MustCompile(`^\s*([a-z][-.a-z0-9]+?)\s*$`)

+ var RxSockCommandWithArgs = regexp.MustCompile(`^\s*([a-z][-.a-z0-9]+?)\s+(.+?)\s*$`)

+ var RxTangoTags = regexp.MustCompile(`<.+?>`)

+ func ApplyComments(content string, comments TomlComments) (modified string, err error)

+ func CheckAB(a, b V, check bool) (v V)

+ func DecomposeUrl(r *http.Request) (full, scheme, host string, port int)

+ func LoadApplications(config *Config) (foundApps map[string]*Application, err error)

+ func ParseDebianDebFilename(input string) (name, version, arch string, ok bool)

+ func ParseDebianDscFilename(input string) (name, version string, ok bool)

+ func WriteDefaultConfig(niserokuConfig string) (err error)

+ type AppOrigin struct

+ Host string

+ Scheme string

+ func (o AppOrigin) Dial(port int) (conn net.Conn, err error)

+ func (o AppOrigin) Dialer() (dialer *net.Dialer)

+ func (o AppOrigin) NetIP() (ip net.IP)

+ func (o AppOrigin) String() (baseUrl string)

+ type AppTimeouts struct

+ OriginRequest *time.Duration

+ ReadyInterval *time.Duration

+ SlugStartup *time.Duration

+ func (t AppTimeouts) String() (s string)

+ type Application struct

+ AccessLog string

+ AptArchivesPath string

+ AptBasePath string

+ AptEnjin *AptEnjinConfig

+ AptPackage *AptPackageConfig

+ AptRepositoryPath string

+ Config *Config

+ DeployFile string

+ Domains []string

+ ErrorLog string

+ GitRepo *git.Repository

+ Maintenance bool

+ Name string

+ NextSlug string

+ NoticeLog string

+ Origin AppOrigin

+ RepoPath string

+ Settings map[string]interface{}

+ Slugs map[string]*Slug

+ Source string

+ ThisSlug string

+ Timeouts AppTimeouts

+ Workers map[string]int

+ func NewApplication(source string, config *Config) (app *Application, err error)

+ func (a *Application) ApplySettings(envDir string) (err error)

+ func (a *Application) Cleanup()

+ func (a *Application) Deploy() (err error)

+ func (a *Application) GetGpgHome() (home string)

+ func (a *Application) GetNextSlug() (slug *Slug)

+ func (a *Application) GetSlugWorkerByPid(pid int) (si *SlugWorker)

+ func (a *Application) GetThisSlug() (slug *Slug)

+ func (a *Application) GetWebWorkers() (count int)

+ func (a *Application) GetWorkers(procType string) (count int)

+ func (a *Application) ImportGpgSecrets(other *Application) (info map[string][]string, err error)

+ func (a *Application) Invoke() (err error)

+ func (a *Application) IsDeploying() (locked bool)

+ func (a *Application) Load() (err error)

+ func (a *Application) LoadAllSlugs() (err error)

+ func (a *Application) LogAccessF(status int, remoteAddr string, r *http.Request, start time.Time)

+ func (a *Application) LogError(err error)

+ func (a *Application) LogErrorF(format string, argv ...interface{})

+ func (a *Application) LogInfoF(format string, argv ...interface{})

+ func (a *Application) OsEnviron() (environment []string)

+ func (a *Application) OsEnvironAptEnjinOnly() (aptEnv map[string]string)

+ func (a *Application) PrepareGpgSecrets() (err error)

+ func (a *Application) PurgeGpgSecrets() (err error)

+ func (a *Application) Save(keepCustomComments bool) (err error)

+ func (a *Application) SendSignal(sig process.Signal) (err error)

+ func (a *Application) SendStopSignal() (err error)

+ func (a *Application) SetupRepo() (err error)

+ func (a *Application) String() string

+ type AptEnjinConfig struct

+ Enable bool

+ Flavours map[string][]Distribution

+ GpgKeys map[string][]string

+ SiteKey string

+ SiteMail string

+ SiteMaint string

+ SiteName string

+ SiteUrl string

+ type AptPackageConfig struct

+ AptEnjin string

+ Codename string

+ Component string

+ Flavour string

+ type Command struct

+ func New() (s *Command)

+ func (c *Command) ExtraCommands(app *cli.App) (commands []*cli.Command)

+ func (c *Command) Init(this interface{})

+ func (c *Command) Prepare(ctx *cli.Context) (err error)

+ type Config struct

+ AccountEmail string

+ Applications map[string]*Application

+ BindAddr string

+ BuildPack string

+ DomainLookup map[string]*Application

+ EnableSSL bool

+ IncludeSlugs IncludeSlugsConfig

+ KeepSlugs bool

+ LogFile string

+ NeedRoot bool

+ Paths PathsConfig

+ PortLookup map[int]*Application

+ Ports PortsConfig

+ ProxyLimit RateLimit

+ ReservePorts map[int]*Application

+ RunAs RunAsConfig

+ SlugNice int

+ Source string

+ Timeouts TimeoutsConfig

+ Users []*User

+ func LoadConfig(niserokuConfig string) (config *Config, err error)

+ func (c *Config) CallProxyControlCommand(name string, argv ...string) (response string, err error)

+ func (c *Config) DialProxyControl() (conn net.Conn, err error)

+ func (c *Config) GetAllRunningPorts() (ports map[int]*Application)

+ func (c *Config) GetTomlValue(key string) (v interface{})

+ func (c *Config) IsGitRepositoryRunning() (running bool)

+ func (c *Config) IsReverseProxyRunning() (running bool)

+ func (c *Config) MergeConfig(cfg *Config) (err error)

+ func (c *Config) PrepareDirectories() (err error)

+ func (c *Config) Reload() (err error)

+ func (c *Config) RunAsChown(paths ...string) (err error)

+ func (c *Config) RunAsGetUidGid() (uid, gid int, err error)

+ func (c *Config) Save(keepCustomComments bool) (err error)

+ func (c *Config) SetTomlValue(key string, v string) (err error)

+ func (c *Config) SignalGitRepository(sig process.Signal) (sent bool)

+ func (c *Config) SignalReloadGitRepository() (sent bool)

+ func (c *Config) SignalReloadReverseProxy() (sent bool)

+ func (c *Config) SignalReverseProxy(sig process.Signal) (sent bool)

+ func (c *Config) SignalStopGitRepository() (sent bool)

+ func (c *Config) SignalStopReverseProxy() (sent bool)

+ func (c *Config) WriteProxyControl(conn net.Conn, name string, argv ...string) (response string, err error)

+ type Distribution struct

+ Architectures []string

+ Codename string

+ Components []string

+ Contents string

+ Description string

+ Label string

+ Origin string

+ SignWith string

+ Tracking string

+ Version string

+ func (d Distribution) String() (conf string)

+ type Distributions []Distribution

+ func (d Distributions) String() (conf string)

+ type GitRepository struct

+ func NewGitRepository(config *Config) (gr *GitRepository)

+ func (gr *GitRepository) Bind() (err error)

+ func (gr *GitRepository) Reload() (err error)

+ func (gr *GitRepository) Serve() (err error)

+ func (gr *GitRepository) Stop() (err error)

+ type IncludeSlugsConfig struct

+ OnStart bool

+ OnStop bool

+ type ParsedProxyLimits struct

+ Delayed ParsedProxyLimitsData

+ Request ParsedProxyLimitsData

+ TotalDelayed int64

+ TotalRequest int64

+ type ParsedProxyLimitsData struct

+ Addrs map[string]int64

+ Apps map[string]int64

+ Hosts map[string]int64

+ Ports map[string]int64

+ func NewProxyLimitsData() ParsedProxyLimitsData

+ type PathsConfig struct

+ AptSecrets string

+ Etc string

+ EtcApps string

+ EtcUsers string

+ ProxyPidFile string

+ ProxyRpcSock string

+ ProxySecrets string

+ RepoPidFile string

+ RepoSecrets string

+ Tmp string

+ TmpBuild string

+ TmpClone string

+ TmpRun string

+ Var string

+ VarAptRoot string

+ VarCache string

+ VarLogs string

+ VarRepos string

+ VarSettings string

+ VarSlugs string

+ type PortsConfig struct

+ AppEnd int

+ AppStart int

+ Git int

+ Http int

+ Https int

+ type RateLimit struct

+ Burst int

+ DelayScale int

+ LogAllowed bool

+ LogDelayed bool

+ LogLimited bool

+ Max float64

+ MaxDelay time.Duration

+ TTL time.Duration

+ type RepreproListEntry struct

+ Architecture string

+ Codename string

+ Component string

+ Name string

+ Version string

+ type ReverseProxy struct

+ func NewReverseProxy(config *Config) (rp *ReverseProxy)

+ func (rp *ReverseProxy) Bind() (err error)

+ func (rp *ReverseProxy) GetAppDomain(r *http.Request) (domain string, app *Application, ok bool)

+ func (rp *ReverseProxy) HandleSock(conn net.Conn)

+ func (rp *ReverseProxy) ProxyHttpHandler() (h http.Handler)

+ func (rp *ReverseProxy) Reload() (err error)

+ func (rp *ReverseProxy) Serve() (err error)

+ func (rp *ReverseProxy) ServeOriginHTTP(app *Application, forwardFor string, w http.ResponseWriter, r *http.Request) (status int, err error)

+ func (rp *ReverseProxy) Stop() (err error)

+ type RunAsConfig struct

+ Group string

+ User string

+ type Slug struct

+ App *Application

+ Archive string

+ Commit string

+ Name string

+ Settings *SlugSettings

+ SettingsFile string

+ Workers map[string]*SlugWorker

+ func NewSlugFromZip(app *Application, archive string) (slug *Slug, err error)

+ func (s *Slug) Cleanup()

+ func (s *Slug) ConsumeLivePort() (consumedPort int)

+ func (s *Slug) Destroy() (err error)

+ func (s *Slug) GetInstanceByPid(pid int) (si *SlugWorker)

+ func (s *Slug) GetLivePort() (livePort int)

+ func (s *Slug) GetNumWorkers() (num int)

+ func (s *Slug) GetOriginRequestTimeout() (timeout time.Duration)

+ func (s *Slug) GetReadyIntervalTimeout() (timeout time.Duration)

+ func (s *Slug) GetSlugStartupTimeout() (timeout time.Duration)

+ func (s *Slug) IsReady(hash string) (ready bool)

+ func (s *Slug) IsRunning(hash string) (running bool)

+ func (s *Slug) IsRunningReady() (running, ready bool)

+ func (s *Slug) RefreshWorkers()

+ func (s *Slug) SendSignalToAll(sig process.Signal)

+ func (s *Slug) StartForegroundWorkers(workersReady chan bool) (err error)

+ func (s *Slug) StopAll() (stopped int)

+ func (s *Slug) StopWorker(hash string) (stopped bool)

+ func (s *Slug) String() string

+ type SlugSettings struct

+ Live []string

+ Next []string

+ Path string

+ RunAs RunAsConfig

+ TomlMetaData toml.MetaData

+ func NewSlugSettings(path string, config RunAsConfig) (sw *SlugSettings, err error)

+ func (s *SlugSettings) Reload() (err error)

+ func (s *SlugSettings) Save() (err error)

+ type SlugWorker struct

+ Hash string

+ LogFile string

+ Name string

+ Pid int

+ PidFile string

+ Port int

+ PortFile string

+ RunPath string

+ Slug *Slug

+ func NewSlugWorker(slug *Slug) (si *SlugWorker, err error)

+ func NewSlugWorkerWithHash(slug *Slug, hash string) (si *SlugWorker, err error)

+ func (s *SlugWorker) Cleanup()

+ func (s *SlugWorker) Destroy() (err error)

+ func (s *SlugWorker) GetBinProcess() (proc *process.Process, err error)

+ func (s *SlugWorker) GetPid() (pid int, err error)

+ func (s *SlugWorker) IsReady() (ready bool)

+ func (s *SlugWorker) IsRunning() (running bool)

+ func (s *SlugWorker) IsRunningReady() (running, ready bool)

+ func (s *SlugWorker) PrepareStart(port int) (webCmd string, webArgv, environ []string, err error)

+ func (s *SlugWorker) ReadProcfile() (procTypes map[string]string, err error)

+ func (s *SlugWorker) ReserveUnusedPort() (port int)

+ func (s *SlugWorker) SendReloadSignal() (sent bool)

+ func (s *SlugWorker) SendSignal(sig process.Signal) (sent bool)

+ func (s *SlugWorker) SendStopSignal() (sent bool)

+ func (s *SlugWorker) Start(port int) (err error)

+ func (s *SlugWorker) StartForeground(port int) (err error)

+ func (s *SlugWorker) Stop() (stopped bool)

+ func (s *SlugWorker) String() (text string)

+ func (s *SlugWorker) Unpack() (err error)

+ type StatusWatch struct

+ func NewStatusWatch(cmd *Command, freq time.Duration, ttyPath string) (sw *StatusWatch, err error)

+ func (sw *StatusWatch) Run(ctx *cli.Context) (err error)

+ type TimeoutsConfig struct

+ OriginRequest time.Duration

+ ReadyInterval time.Duration

+ SlugStartup time.Duration

+ type TomlComment struct

+ Inline string

+ Lines []string

+ Statement string

+ func (t *TomlComment) String() (v string)

+ type TomlComments []*TomlComment

+ func MergeApplicationToml(current TomlComments, keepCustomComments bool) (modified TomlComments)

+ func MergeConfigToml(current TomlComments, keepCustomComments bool) (modified TomlComments)

+ func ParseComments(content string) (tomlComments TomlComments, err error)

+ func (t TomlComments) String() (v string)

+ type Tracking struct

+ func NewTracking() (t *Tracking)

+ func (t *Tracking) Decrement(keys ...string)

+ func (t *Tracking) Get(key string) (value int64)

+ func (t *Tracking) Increment(keys ...string)

+ func (t *Tracking) String() (summary string)

+ type User struct

+ Applications []string

+ AuditLog string

+ AuthorizedKeys []string

+ Name string

+ func (u *User) HasKey(given string) (has bool)

+ func (u *User) Log(format string, argv ...interface{})

+ func (u *User) String() (details string)

+ type Users []*User

+ func LoadUsers(path string) (users Users, err error)

+ func (u Users) String() (details string)

+ type WatchProc struct

+ Cpu float32

+ Hash string

+ Mem uint64

+ Name string

+ Nice int

+ Num int

+ Pid int

+ Ports []int

+ Threads int

+ type WatchSnapshot struct

+ Applications []WatchProc

+ Services []WatchProc

+ Stats cpuinfo.Stats

+ type Watching struct

+ func NewWatching(config *Config, refresh time.Duration, fn func()) (w *Watching, err error)

+ func (w *Watching) LogErrorF(format string, argv ...interface{})

+ func (w *Watching) LogInfoF(format string, argv ...interface{})

+ func (w *Watching) Snapshot() (s *WatchSnapshot)

+ func (w *Watching) Start() (err error)

+ func (w *Watching) Stop()

+ type WatchingByUsage []WatchProc

+ func (a WatchingByUsage) Len() int

+ func (a WatchingByUsage) Less(i, j int) bool

+ func (a WatchingByUsage) Swap(i, j int)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL