cron

Documentation

Index

• Variables
• func BuildCommand(username string, args ...string) *exec.Cmd
• func BuildHeartbeatRequest(hostname string, desiredAgents []*model.DesiredAgent) model.HeartbeatRequest
• func CheckDirectoryExists(username string, fp string) bool
• func CheckFileExists(username string, fp string) bool
• func CheckFileOrDirExists(username, fp, fileType string) bool
• func Control(runUser, workdir, arg string) (string, error)
• func ControlStart(runUser, workdir string) (string, error)
• func ControlStartIn(runUser, workdir string) error
• func ControlStatus(runUser, workdir string) (string, error)
• func ControlStop(runUser, workdir string) (string, error)
• func ControlStopIn(runUser, workdir string) error
• func ExecuteCommandWithOutput(cmd *exec.Cmd) (string, error)
• func FilesReady(da *model.DesiredAgent) bool
• func HandleDesiredAgent(da *model.DesiredAgent, last *model.DesiredAgent)
• func HandleHeartbeatResponse(respone *model.HeartbeatResponse, lastDesiredAgents []*model.DesiredAgent)
• func Heartbeat()
• func InsureDesiredAgentDirExists(da *model.DesiredAgent) error
• func InsureNewVersion(da *model.DesiredAgent) error
• func InsureNewVersionFiles(da *model.DesiredAgent) error
• func InsureRunUserExists(da *model.DesiredAgent) error
• func InsureUserDir(fp, username string, createByRoot bool) error
• func Md5sumCheck(runUser, workdir, tarfile, md5file string) error
• func ReadDesiredAgents() []*model.DesiredAgent
• func ReadVersion(username, agentDir string) string
• func SleepRandomDuration()
• func StartDesiredAgent(da *model.DesiredAgent, last *model.DesiredAgent) error
• func StopAgentOf(da *model.DesiredAgent, lastRunUser, lastWorkDir string) error
• func StopDesiredAgent(last *model.DesiredAgent) error
• func Untar(da *model.DesiredAgent) error
• func WriteVersion(da *model.DesiredAgent) (err error)

Variables

var (
	HasSudoPermission = false
	CurrentUser       = ""
)

Functions

func BuildCommand

func BuildCommand(username string, args ...string) *exec.Cmd

func BuildHeartbeatRequest

func BuildHeartbeatRequest(hostname string, desiredAgents []*model.DesiredAgent) model.HeartbeatRequest

func CheckDirectoryExists

func CheckDirectoryExists(username string, fp string) bool

func CheckFileExists

func CheckFileExists(username string, fp string) bool

func CheckFileOrDirExists

func CheckFileOrDirExists(username, fp, fileType string) bool

func Control

func Control(runUser, workdir, arg string) (string, error)

func ControlStart

func ControlStart(runUser, workdir string) (string, error)

func ControlStartIn

func ControlStartIn(runUser, workdir string) error

func ControlStatus

func ControlStatus(runUser, workdir string) (string, error)

func ControlStop

func ControlStop(runUser, workdir string) (string, error)

func ControlStopIn

func ControlStopIn(runUser, workdir string) error

func ExecuteCommandWithOutput

func ExecuteCommandWithOutput(cmd *exec.Cmd) (string, error)

func FilesReady

func FilesReady(da *model.DesiredAgent) bool

func HandleDesiredAgent

func HandleDesiredAgent(da *model.DesiredAgent, last *model.DesiredAgent)

func HandleHeartbeatResponse

func HandleHeartbeatResponse(respone *model.HeartbeatResponse, lastDesiredAgents []*model.DesiredAgent)

func Heartbeat

func Heartbeat()

func InsureDesiredAgentDirExists

func InsureDesiredAgentDirExists(da *model.DesiredAgent) error

func InsureNewVersion

func InsureNewVersion(da *model.DesiredAgent) error

func InsureNewVersionFiles

func InsureNewVersionFiles(da *model.DesiredAgent) error

func InsureRunUserExists

func InsureRunUserExists(da *model.DesiredAgent) error

func InsureUserDir

func InsureUserDir(fp, username string, createByRoot bool) error

func Md5sumCheck

func Md5sumCheck(runUser, workdir, tarfile, md5file string) error

func ReadDesiredAgents

func ReadDesiredAgents() []*model.DesiredAgent

func ReadVersion

func ReadVersion(username, agentDir string) string

func SleepRandomDuration

func SleepRandomDuration()

func StartDesiredAgent

func StartDesiredAgent(da *model.DesiredAgent, last *model.DesiredAgent) error

func StopAgentOf

func StopAgentOf(da *model.DesiredAgent, lastRunUser, lastWorkDir string) error

func StopDesiredAgent

func StopDesiredAgent(last *model.DesiredAgent) error

func Untar

func Untar(da *model.DesiredAgent) error

func WriteVersion

func WriteVersion(da *model.DesiredAgent) (err error)