Added some docs

client/consul/sync.go

@@ -430,7 +430,7 @@ func (c *ConsulService) consulPresent() bool {
 func (c *ConsulService) runCheck(check Check) {
 	res := check.Run()
 	if res.Duration >= check.Timeout() {
-		c.logger.Printf("[DEBUG] check took time: %v, timeout: %v", res.Duration, check.Timeout())
+		c.logger.Printf("[DEBUG] consul.sync: check took time: %v, timeout: %v", res.Duration, check.Timeout())
 	}
 	state := consul.HealthCritical
 	output := res.Output
@@ -448,7 +448,7 @@ func (c *ConsulService) runCheck(check Check) {
 	}
 	if err := c.client.Agent().UpdateTTL(check.ID(), output, state); err != nil {
 		if c.availble {
-			c.logger.Printf("[DEBUG] error updating ttl check for check %q: %v", check.ID(), err)
+			c.logger.Printf("[DEBUG] consul.sync: error updating ttl check for check %q: %v", check.ID(), err)
 			c.availble = false
 		} else {
 			c.availble = true

client/driver/executor/checks.go

@@ -21,24 +21,25 @@ var (
 )
 
 const (
+	// The default check timeout
 	defaultCheckTimeout = 30 * time.Second
 )
 
 // DockerScriptCheck runs nagios compatible scripts in a docker container and
 // provides the check result
 type DockerScriptCheck struct {
-	id          string
-	interval    time.Duration
-	timeout     time.Duration
-	containerID string
+	id          string        // id of the check
+	interval    time.Duration // interval of the check
+	timeout     time.Duration // timeout of the check
+	containerID string        // container id in which the check will be invoked
 	logger      *log.Logger
-	cmd         string
-	args        []string
+	cmd         string   // check command
+	args        []string // check command arguments
 
-	dockerEndpoint string
-	tlsCert        string
-	tlsCa          string
-	tlsKey         string
+	dockerEndpoint string // docker endpoint
+	tlsCert        string // path to tls certificate
+	tlsCa          string // path to tls ca
+	tlsKey         string // path to tls key
 }
 
 // dockerClient creates the client to interact with the docker daemon
@@ -124,19 +125,22 @@ func (d *DockerScriptCheck) Interval() time.Duration {
 
 // Timeout returns the duration after which a check is timed out.
 func (d *DockerScriptCheck) Timeout() time.Duration {
+	if d.timeout == 0 {
+		return defaultCheckTimeout
+	}
 	return d.timeout
 }
 
 // ExecScriptCheck runs a nagios compatible script and returns the check result
 type ExecScriptCheck struct {
-	id       string
-	interval time.Duration
-	timeout  time.Duration
-	cmd      string
-	args     []string
-	taskDir  string
+	id       string        // id of the script check
+	interval time.Duration // interval at which the check is invoked
+	timeout  time.Duration // timeout duration of the check
+	cmd      string        // command of the check
+	args     []string      // args passed to the check
+	taskDir  string        // the root directory of the check
 
-	FSIsolation bool
+	FSIsolation bool // indicates whether the check has to be run within a chroot
 }
 
 // Run runs an exec script check
@@ -154,10 +158,6 @@ func (e *ExecScriptCheck) Run() *cstructs.CheckResult {
 	go func() {
 		errCh <- cmd.Wait()
 	}()
-	timeout := defaultCheckTimeout
-	if e.timeout != 0 {
-		timeout = e.timeout
-	}
 	for {
 		select {
 		case err := <-errCh:
@@ -181,7 +181,7 @@ func (e *ExecScriptCheck) Run() *cstructs.CheckResult {
 				Timestamp: ts,
 				Duration:  endTime.Sub(ts),
 			}
-		case <-time.After(timeout):
+		case <-time.After(e.Timeout()):
 			errCh <- fmt.Errorf("timed out after waiting 30s")
 		}
 	}
@@ -200,5 +200,8 @@ func (e *ExecScriptCheck) Interval() time.Duration {
 
 // Timeout returns the duration after which a check is timed out.
 func (e *ExecScriptCheck) Timeout() time.Duration {
+	if e.timeout == 0 {
+		return defaultCheckTimeout
+	}
 	return e.timeout
 }

client/driver/structs/structs.go

@@ -68,9 +68,19 @@ func (r *RecoverableError) Error() string {
 
 // CheckResult encapsulates the result of a check
 type CheckResult struct {
+
+	// ExitCode is the exit code of the check
 	ExitCode int
+
+	// Output is the output of the check script
 	Output string
+
+	// Timestamp is the time at which the check was executed
 	Timestamp time.Time
+
+	// Duration is the time it took the check to run
 	Duration time.Duration
+
+	// Err is the error that a check returned
 	Err error
 }