utils

Documentation

Index

• Constants
• func DirStagingToFinal(s string) string
• func HaproxyBalanceAlgorithm(scheduler string) (balance string, err error)
• func HaproxyConfigHttpCheck(uri, domain string) string
• func HaproxyConfigHttpCheckExpect(s string) string
• func HaproxySendProxy(s string) (r string, err error)
• func KeepalivedConfHexQuote(s string) string
• func KeepalivedConfQuoteScriptArgs(args []string) string
• func WritePidFile(pid int, pidFile string) error
• type ConfigDirManager
  • func NewConfigDirManager(baseDir string) *ConfigDirManager
  • func (m *ConfigDirManager) MostRecentSubdir() string
  • func (m *ConfigDirManager) NewDir(f DirFunc) (finalDir string, err error)
  • func (m *ConfigDirManager) Prune(nRetain int) error
• type DirFunc
• type HaproxySslPolicyParams
  • func HaproxySslPolicy(policy string) *HaproxySslPolicyParams
• type PidFile
  • func NewPidFile(path, comm string) *PidFile
  • func (pf *PidFile) ConfirmOrUnlink() (proc *os.Process, confirmed bool, err error)

Constants

const (
	FileModeDir           = os.FileMode(0755)
	FileModeFile          = os.FileMode(0644)
	FileModeFileExec      = os.FileMode(0755)
	FileModeDirSensitive  = os.FileMode(0700)
	FileModeFileSensitive = os.FileMode(0600)
)

const (
	ConfigDirMode = os.FileMode(0755)
)

const HaproxyCfgExt = "cfg"

Functions

func DirStagingToFinal

func DirStagingToFinal(s string) string

func HaproxyBalanceAlgorithm

func HaproxyBalanceAlgorithm(scheduler string) (balance string, err error)

func HaproxyConfigHttpCheck

func HaproxyConfigHttpCheck(uri, domain string) string

func HaproxyConfigHttpCheckExpect

func HaproxyConfigHttpCheckExpect(s string) string

func HaproxySendProxy

func HaproxySendProxy(s string) (r string, err error)

func KeepalivedConfHexQuote

func KeepalivedConfHexQuote(s string) string

func KeepalivedConfQuoteScriptArgs

func KeepalivedConfQuoteScriptArgs(args []string) string

func WritePidFile

func WritePidFile(pid int, pidFile string) error

Types

type ConfigDirManager

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

func NewConfigDirManager

func NewConfigDirManager(baseDir string) *ConfigDirManager

TODO

• set active

func (*ConfigDirManager) MostRecentSubdir

func (m *ConfigDirManager) MostRecentSubdir() string

func (*ConfigDirManager) NewDir

func (m *ConfigDirManager) NewDir(f DirFunc) (finalDir string, err error)

call f() inside 20180830.104050.333.lbcorpus.json.staging move to final name 20180830.104050.333.lbcorpus.json

func (*ConfigDirManager) Prune

func (m *ConfigDirManager) Prune(nRetain int) error

type DirFunc

type DirFunc func(string) error

type HaproxySslPolicyParams

type HaproxySslPolicyParams struct {
	SslMinVer string
	Ciphers   string
}

func HaproxySslPolicy

func HaproxySslPolicy(policy string) *HaproxySslPolicyParams

TODO restrict ciphers as noted in https://help.aliyun.com/document_detail/90740.html

type PidFile

type PidFile struct {
	Path string
	Comm string
}

func NewPidFile

func NewPidFile(path, comm string) *PidFile

func (*PidFile) ConfirmOrUnlink

func (pf *PidFile) ConfirmOrUnlink() (proc *os.Process, confirmed bool, err error)

ConfirmedOrUnlink reads the pidfile, confirm that it's running and comm matches pf.Comm

When confirmed is true, proc must be non-nil