Change kernel specific name in code base and change syslog to filelog.

Author: Random-Liu

Dockerfile.in

@@ -20,4 +20,4 @@ RUN test -h /etc/localtime && rm -f /etc/localtime && cp /usr/share/zoneinfo/UTC
 
 ADD ./bin/node-problem-detector /node-problem-detector
 ADD config /config
-ENTRYPOINT ["/node-problem-detector", "--kernel-monitor=/config/kernel-monitor.json"]
+ENTRYPOINT ["/node-problem-detector", "--system-log-monitor=/config/kernel-monitor.json"]

README.md

@@ -49,7 +49,7 @@ List of supported problem daemons:
 
 | Problem Daemon |  NodeCondition  | Description |
 |----------------|:---------------:|:------------|
-| [KernelMonitor](https://github.com/kubernetes/node-problem-detector/tree/master/pkg/kernelmonitor) | KernelDeadlock | A problem daemon monitors kernel log and reports problem according to predefined rules. |
+| [KernelMonitor](https://github.com/kubernetes/node-problem-detector/tree/master/pkg/logmonitor) | KernelDeadlock | A problem daemon monitors kernel log and reports problem according to predefined rules. |
 
 # Usage
 ## Flags

cmd/node_problem_detector.go

@@ -26,10 +26,10 @@ import (
 	"github.com/golang/glog"
 	"github.com/spf13/pflag"
 
-	"k8s.io/node-problem-detector/pkg/kernelmonitor"
 	"k8s.io/node-problem-detector/pkg/options"
 	"k8s.io/node-problem-detector/pkg/problemclient"
 	"k8s.io/node-problem-detector/pkg/problemdetector"
+	"k8s.io/node-problem-detector/pkg/systemlogmonitor"
 	"k8s.io/node-problem-detector/pkg/version"
 )
 
@@ -67,9 +67,9 @@ func main() {
 		os.Exit(0)
 	}
 
-	k := kernelmonitor.NewKernelMonitorOrDie(npdo.KernelMonitorConfigPath)
+	l := systemlogmonitor.NewLogMonitorOrDie(npdo.SystemLogMonitorConfigPath)
 	c := problemclient.NewClientOrDie(npdo)
-	p := problemdetector.NewProblemDetector(k, c)
+	p := problemdetector.NewProblemDetector(l, c)
 
 	// Start http server.
 	if npdo.ServerPort > 0 {

config/docker-monitor-filelog.json

@@ -1,5 +1,5 @@
 {
-	"plugin": "syslog",
+	"plugin": "filelog",
 	"pluginConfig": {
 		"timestamp": "^time=\"(\\S*)\"",
 		"message": "msg=\"([^\n]*)\"",

config/kernel-monitor-filelog.json

@@ -1,5 +1,5 @@
 {
-	"plugin": "syslog",
+	"plugin": "filelog",
 	"pluginConfig": {
 		"timestamp": "^.{15}",
 		"message": "kernel: \\[.*\\] (.*)",

pkg/options/options.go

@@ -30,8 +30,8 @@ import (
 type NodeProblemDetectorOptions struct {
 	// command line options
 
-	// KernelMonitorConfigPath specifies the path to kernel monitor configuration file.
-	KernelMonitorConfigPath string
+	// SystemLogMonitorConfigPath specifies the path to system log monitor configuration file.
+	SystemLogMonitorConfigPath string
 	// ApiServerOverride is the custom URI used to connect to Kubernetes ApiServer.
 	ApiServerOverride string
 	// PrintVersion is the flag determining whether version information is printed.
@@ -55,8 +55,8 @@ func NewNodeProblemDetectorOptions() *NodeProblemDetectorOptions {
 
 // AddFlags adds node problem detector command line options to pflag.
 func (npdo *NodeProblemDetectorOptions) AddFlags(fs *pflag.FlagSet) {
-	fs.StringVar(&npdo.KernelMonitorConfigPath, "kernel-monitor",
-		"/config/kernel-monitor.json", "The path to the kernel monitor config file")
+	fs.StringVar(&npdo.SystemLogMonitorConfigPath, "system-log-monitor",
+		"/config/kernel-monitor.json", "The path to the system log monitor config file")
 	fs.StringVar(&npdo.ApiServerOverride, "apiserver-override",
 		"", "Custom URI used to connect to Kubernetes ApiServer")
 	fs.BoolVar(&npdo.PrintVersion, "version", false, "Print version information and quit")

pkg/problemdetector/problem_detector.go

@@ -24,8 +24,8 @@ import (
 	"k8s.io/kubernetes/pkg/util/clock"
 
 	"k8s.io/node-problem-detector/pkg/condition"
-	"k8s.io/node-problem-detector/pkg/kernelmonitor"
 	"k8s.io/node-problem-detector/pkg/problemclient"
+	"k8s.io/node-problem-detector/pkg/systemlogmonitor"
 	"k8s.io/node-problem-detector/pkg/util"
 )
 
@@ -39,12 +39,12 @@ type problemDetector struct {
 	client           problemclient.Client
 	conditionManager condition.ConditionManager
 	// TODO(random-liu): Use slices of problem daemons if multiple monitors are needed in the future
-	monitor kernelmonitor.KernelMonitor
+	monitor systemlogmonitor.LogMonitor
 }
 
 // NewProblemDetector creates the problem detector. Currently we just directly passed in the problem daemons, but
 // in the future we may want to let the problem daemons register themselves.
-func NewProblemDetector(monitor kernelmonitor.KernelMonitor, client problemclient.Client) ProblemDetector {
+func NewProblemDetector(monitor systemlogmonitor.LogMonitor, client problemclient.Client) ProblemDetector {
 	return &problemDetector{
 		client:           client,
 		conditionManager: condition.NewConditionManager(client, clock.RealClock{}),

pkg/kernelmonitor/README.md renamed to pkg/systemlogmonitor/README.md

@@ -43,8 +43,8 @@ with new rule definition:
 
 Kernel monitor supports different log management tools with different log
 watchers:
-* [syslog](https://github.com/kubernetes/node-problem-detector/blob/master/pkg/kernelmonitor/logwatchers/syslog)
-* [journald](https://github.com/kubernetes/node-problem-detector/blob/master/pkg/kernelmonitor/logwatchers/journald)
+* [syslog](https://github.com/kubernetes/node-problem-detector/blob/master/pkg/logmonitor/logwatchers/syslog)
+* [journald](https://github.com/kubernetes/node-problem-detector/blob/master/pkg/logmonitor/logwatchers/journald)
 
 ### Change Log Path
 
@@ -57,5 +57,5 @@ You can always configure `logPath` and volume mount to match your OS distro.
 ### New Log Watcher
 
 Kernel monitor uses [Log
-Watcher](https://github.com/kubernetes/node-problem-detector/blob/master/pkg/kernelmonitor/logwatchers/types/log_watcher.go) to support different log management tools.
+Watcher](https://github.com/kubernetes/node-problem-detector/blob/master/pkg/logmonitor/logwatchers/types/log_watcher.go) to support different log management tools.
 It is easy to implement a new log watcher.

pkg/kernelmonitor/config.go renamed to pkg/systemlogmonitor/config.go

@@ -14,26 +14,26 @@ See the License for the specific language governing permissions and
 limitations under the License.
 */
 
-package kernelmonitor
+package systemlogmonitor
 
 import (
-	watchertypes "k8s.io/node-problem-detector/pkg/kernelmonitor/logwatchers/types"
-	kerntypes "k8s.io/node-problem-detector/pkg/kernelmonitor/types"
+	watchertypes "k8s.io/node-problem-detector/pkg/systemlogmonitor/logwatchers/types"
+	logtypes "k8s.io/node-problem-detector/pkg/systemlogmonitor/types"
 	"k8s.io/node-problem-detector/pkg/types"
 )
 
-// MonitorConfig is the configuration of kernel monitor.
+// MonitorConfig is the configuration of log monitor.
 type MonitorConfig struct {
-	// WatcherConfig is the configuration of kernel log watcher.
+	// WatcherConfig is the configuration of log watcher.
 	watchertypes.WatcherConfig
 	// BufferSize is the size (in lines) of the log buffer.
 	BufferSize int `json:"bufferSize"`
-	// Source is the source name of the kernel monitor
+	// Source is the source name of the log monitor
 	Source string `json:"source"`
-	// DefaultConditions are the default states of all the conditions kernel monitor should handle.
+	// DefaultConditions are the default states of all the conditions log monitor should handle.
 	DefaultConditions []types.Condition `json:"conditions"`
-	// Rules are the rules kernel monitor will follow to parse the log file.
-	Rules []kerntypes.Rule `json:"rules"`
+	// Rules are the rules log monitor will follow to parse the log file.
+	Rules []logtypes.Rule `json:"rules"`
 }
 
 // applyDefaultConfiguration applies default configurations.

pkg/kernelmonitor/log_buffer.go renamed to pkg/systemlogmonitor/log_buffer.go

@@ -14,28 +14,28 @@ See the License for the specific language governing permissions and
 limitations under the License.
 */
 
-package kernelmonitor
+package systemlogmonitor
 
 import (
 	"regexp"
 	"strings"
 
-	"k8s.io/node-problem-detector/pkg/kernelmonitor/types"
+	"k8s.io/node-problem-detector/pkg/systemlogmonitor/types"
 )
 
 // LogBuffer buffers the logs and supports match in the log buffer with regular expression.
 type LogBuffer interface {
 	// Push pushes log into the log buffer.
-	Push(*types.KernelLog)
+	Push(*types.Log)
 	// Match with regular expression in the log buffer.
-	Match(string) []*types.KernelLog
+	Match(string) []*types.Log
 	// String returns a concatenated string of the buffered logs.
 	String() string
 }
 
 type logBuffer struct {
 	// buffer is a simple ring buffer.
-	buffer  []*types.KernelLog
+	buffer  []*types.Log
 	msg     []string
 	max     int
 	current int
@@ -47,20 +47,20 @@ type logBuffer struct {
 // lines of patterns we support.
 func NewLogBuffer(maxLines int) *logBuffer {
 	return &logBuffer{
-		buffer: make([]*types.KernelLog, maxLines, maxLines),
+		buffer: make([]*types.Log, maxLines, maxLines),
 		msg:    make([]string, maxLines, maxLines),
 		max:    maxLines,
 	}
 }
 
-func (b *logBuffer) Push(log *types.KernelLog) {
+func (b *logBuffer) Push(log *types.Log) {
 	b.buffer[b.current%b.max] = log
 	b.msg[b.current%b.max] = log.Message
 	b.current++
 }
 
 // TODO(random-liu): Cache regexp if garbage collection becomes a problem someday.
-func (b *logBuffer) Match(expr string) []*types.KernelLog {
+func (b *logBuffer) Match(expr string) []*types.Log {
 	// The expression should be checked outside, and it must match to the end.
 	reg := regexp.MustCompile(expr + `\z`)
 	log := b.String()
@@ -72,7 +72,7 @@ func (b *logBuffer) Match(expr string) []*types.KernelLog {
 	// reverse index
 	s := len(log) - loc[0] - 1
 	total := 0
-	matched := []*types.KernelLog{}
+	matched := []*types.Log{}
 	for i := b.tail(); i >= b.current && b.buffer[i%b.max] != nil; i-- {
 		matched = append(matched, b.buffer[i%b.max])
 		total += len(b.msg[i%b.max]) + 1 // Add '\n'

pkg/kernelmonitor/log_buffer_test.go renamed to pkg/systemlogmonitor/log_buffer_test.go

@@ -14,13 +14,13 @@ See the License for the specific language governing permissions and
 limitations under the License.
 */
 
-package kernelmonitor
+package systemlogmonitor
 
 import (
 	"reflect"
 	"testing"
 
-	"k8s.io/node-problem-detector/pkg/kernelmonitor/types"
+	"k8s.io/node-problem-detector/pkg/systemlogmonitor/types"
 )
 
 func TestPush(t *testing.T) {
@@ -52,7 +52,7 @@ func TestPush(t *testing.T) {
 	} {
 		b := NewLogBuffer(test.max)
 		for _, log := range test.logs {
-			b.Push(&types.KernelLog{Message: log})
+			b.Push(&types.Log{Message: log})
 		}
 		got := b.String()
 		if test.expected != got {
@@ -94,13 +94,13 @@ func TestMatch(t *testing.T) {
 	} {
 		b := NewLogBuffer(max)
 		for _, log := range test.logs {
-			b.Push(&types.KernelLog{Message: log})
+			b.Push(&types.Log{Message: log})
 		}
 		for i, expr := range test.exprs {
-			kLogs := b.Match(expr)
+			logs := b.Match(expr)
 			got := []string{}
-			for _, kLog := range kLogs {
-				got = append(got, kLog.Message)
+			for _, log := range logs {
+				got = append(got, log.Message)
 			}
 			if !reflect.DeepEqual(test.expected[i], got) {
 				t.Errorf("case %d.%d: expected %v, got %v", c+1, i+1, test.expected[i], got)