merge with scouter-go-lib

Author: gunlee01

go.mod

@@ -5,7 +5,4 @@ go 1.15
 require (
 	github.com/emirpasic/gods v1.12.0
 	github.com/magiconair/properties v1.8.4
-	github.com/scouter-project/scouter-go-lib v0.0.0
 )
-
-replace github.com/scouter-project/scouter-go-lib => /Users/gunlee/Documents/workspace/gunlee01/scouter-go-lib

scouterx/common/constants/netcafeconstant/netcafeconstants.go

@@ -0,0 +1,10 @@
+package netcafeconstant
+
+var CAFE = []byte("CAFE")
+var CAFE_N = []byte("CAFN")
+var CAFE_MTU = []byte("CAFM")
+var JAVA = []byte("JAVA")
+var JAVA_N = []byte("JAVN")
+var JAVA_MTU = []byte("JAVM")
+var TCP_AGENT_V2 = 0xCAFE1002
+var TCP_AGENT = 0xCAFE1001

scouterx/common/constants/packconstant/packconstants.go

@@ -0,0 +1,18 @@
+package packconstants
+
+// Pack type
+const (
+	// M
+	MAP               byte = 10
+	XLOG              byte = 21
+	DROPPED_XLOG      byte = 22
+	XLOG_PROFILE      byte = 26
+	XLOG_PROFILE2     byte = 27
+	TEXT              byte = 50
+	PERFCOUNTER       byte = 60
+	PERF_STATUS       byte = 61
+	PERFCOUNTER_K8S   byte = 65
+	K8S_CLUSTER__INFO byte = 66
+	ALERT             byte = 70
+	OBJECT            byte = 80
+)

scouterx/common/constants/tcpflag/tcpflag.go

@@ -0,0 +1,13 @@
+package tcpflag
+
+const OK byte = 0x01
+const NOT_OK byte = 0x02
+
+const HasNEXT byte = 0x03
+const NoNEXT byte = 0x04
+
+const FAIL byte = 0x05
+const INVALID_SESSION byte = 0x44
+
+const CLUSTER_SEND_NEXT byte = 0x03
+const CLUSTER_SEND_STOP byte = 0x04

scouterx/common/constants/timeconstant/timeconstants.go

@@ -0,0 +1,11 @@
+package timeconstants
+
+const (
+	REALTIME int8 = 1
+	ONE_MIN  int8 = 2
+	FIVE_MIN int8 = 3
+	TEN_MIN  int8 = 4
+	HOUR     int8 = 5
+	DAY      int8 = 6
+	SNAPSHOT int8 = 7
+)

scouterx/common/constants/valueconstant/valueconstants.go

@@ -0,0 +1,21 @@
+package valueconstants
+
+const (
+	NULL           byte = 0
+	BOOLEAN        byte = 10
+	DECIMAL        byte = 20
+	FLOAT          byte = 30
+	DOUBLE         byte = 40
+	DOUBLE_SUMMARY byte = 45
+	LONG_SUMMARY   byte = 46
+	TEXT           byte = 50
+	TEXT_HASH      byte = 51
+	BLOB           byte = 60
+	IP4ADDR        byte = 61
+	LIST           byte = 70
+	ARRAY_INT      byte = 71
+	ARRAY_FLOAT    byte = 72
+	ARRAY_TEXT     byte = 73
+	ARRAY_LONG     byte = 74
+	MAP            byte = 80
+)

scouterx/common/factory/channelfactory/channelfactory.go

@@ -0,0 +1,17 @@
+package channelfactory
+
+import (
+	"github.com/scouter-contrib/scouter-agent-golang/scouterx/conf"
+	"sync"
+)
+
+var once sync.Once
+var udpChannel chan []byte
+
+//GetUDPChannel returns  channel which stores pack data.
+func GetUDPChannel() chan []byte {
+	once.Do(func() {
+		udpChannel = make(chan []byte, conf.GetInstance().SendQueueSize)
+	})
+	return udpChannel
+}

scouterx/common/logger/logger.go

@@ -0,0 +1,34 @@
+package logger
+
+import (
+	"github.com/scouter-contrib/scouter-agent-golang/scouterx/common/util"
+	"io"
+	"log"
+	"os"
+	"path/filepath"
+)
+
+//Init initializes logger
+func Init() {
+	p := util.GetScouterPath()
+	logPath := filepath.Join(p, "logs")
+	util.MakeDir(logPath)
+	fileName := filepath.Join(logPath, "scouter.log")
+	logfile, e := os.OpenFile(fileName, os.O_CREATE|os.O_WRONLY|os.O_APPEND, 0666)
+	if e != nil {
+		log.Fatalln("cannot open log file")
+	}
+
+	Trace = log.New(io.MultiWriter(logfile, os.Stdout), "trace:", log.Ldate|log.Ltime|log.Lshortfile)
+	Info = log.New(io.MultiWriter(logfile, os.Stdout), "info:", log.Ldate|log.Ltime|log.Lshortfile)
+	Warning = log.New(io.MultiWriter(logfile, os.Stdout), "warning:", log.Ldate|log.Ltime|log.Lshortfile)
+	Error = log.New(io.MultiWriter(logfile, os.Stderr), "error:", log.Ldate|log.Ltime|log.Lshortfile)
+}
+
+// Error level
+var (
+	Trace   *log.Logger // trace log
+	Info    *log.Logger // info log
+	Warning *log.Logger // warning log
+	Error   *log.Logger // error log
+)

scouterx/common/netdata/alertpack.go

@@ -0,0 +1,59 @@
+package netdata
+
+import packconstants "github.com/scouter-contrib/scouter-agent-golang/scouterx/common/constants/packconstant"
+
+type AlertLevel uint8
+
+const AlertInfo AlertLevel = 0
+const AlertWarn AlertLevel = 1
+const AlertError AlertLevel = 2
+const AlertFatal AlertLevel = 3
+
+// AlertPack has text info
+type AlertPack struct {
+	Time int64
+	ObjType string
+	ObjHash int32
+	Level AlertLevel
+	Title string
+	Message string
+	Tags *MapValue
+}
+
+func NewAlertPack() *AlertPack {
+	pack := new(AlertPack)
+	pack.Tags = NewMapValue()
+	return pack
+}
+
+func (p *AlertPack) Write(out *DataOutputX) error {
+	_, err := out.WriteInt64(p.Time)
+	_, err = out.WriteUInt8(uint8(p.Level))
+	_, err = out.WriteString(p.ObjType)
+	_, err = out.WriteInt32(p.ObjHash)
+	_, err = out.WriteString(p.Title)
+	_, err = out.WriteString(p.Message)
+	_, err = out.WriteValue(p.Tags)
+
+	return err
+}
+
+func (p *AlertPack) Read(in *DataInputX) (Pack, error) {
+	//TODO not yet implemented
+	return p, nil
+}
+
+func (pack *AlertPack) ToString() string {
+	var str string
+	str += "AlertPack:"
+	str += " title: " + pack.Title
+	str += " message: " + pack.Message
+	return str
+}
+
+//GetPackType returns pack type
+func (pack *AlertPack) GetPackType() byte {
+	return packconstants.ALERT
+}
+
+

scouterx/common/netdata/booleanvalue.go

@@ -0,0 +1,58 @@
+package netdata
+
+import (
+	valueconstants "github.com/scouter-contrib/scouter-agent-golang/scouterx/common/constants/valueconstant"
+)
+
+//BooleanValue has bool value
+type BooleanValue struct {
+	Value bool
+}
+
+//NewBooleanValue return new BooleanVaue instance
+/*
+func NewBooleanValue(value bool) *BooleanValue {
+	booleanValue := new(BooleanValue)
+	booleanValue.Value = value
+	return booleanValue
+
+}
+*/
+
+//NewBooleanValue return new BooleanVaue instance
+func NewBooleanValue(value bool) *BooleanValue {
+	booleanValue := new(BooleanValue)
+	booleanValue.Value = value
+	return booleanValue
+
+}
+
+//NewBooleanEmptyValue return new BooleanVaue instance
+func NewBooleanEmptyValue() *BooleanValue {
+	BooleanValue := new(BooleanValue)
+	return BooleanValue
+}
+
+//GetValueType returns value type
+func (booleanValue *BooleanValue) GetValueType() byte {
+	return valueconstants.BOOLEAN
+}
+
+func (booleanValue *BooleanValue) Read(in *DataInputX) (Value, error) {
+	var err error
+	booleanValue.Value, err = in.ReadBoolean()
+	return booleanValue, err
+}
+
+func (booleanValue *BooleanValue) Write(out *DataOutputX) error {
+	_, err := out.WriteBoolean(booleanValue.Value)
+	return err
+}
+
+// ToString returns converted string value from boolean value
+func (booleanValue *BooleanValue) ToString() string {
+	if booleanValue.Value {
+		return "true"
+	}
+	return "fasle"
+}