diff --git a/src/go.mod b/src/go.mod index a571b7d..7f2ee1f 100644 --- a/src/go.mod +++ b/src/go.mod @@ -1,3 +1,3 @@ -module zabbix-bench +module zbbx-bench go 1.20 diff --git a/src/main.go b/src/main.go index c11bb8f..2354eb6 100644 --- a/src/main.go +++ b/src/main.go @@ -10,7 +10,7 @@ import ( "sync" "syscall" "time" - "zabbix-bench/zabbix" + "zbbx-bench/zbbx" ) var ( @@ -19,8 +19,8 @@ var ( argClinetName = flag.String("client-format", "client-%d", "format of client name") argPacketSize = flag.Int("packet-size", 400, "count of metric in packet") argMetricName = flag.String("metric-format", "metric-%d", "format of metric name in packet") - argPacketDelay = flag.Duration("packet-delay", 60*time.Second, "delay of send packet") - argZabbix = flag.String("zabbix", "127.0.0.1:10051", "address of zabbix server") + argPacketDelay = flag.Duration("packet-delay", time.Second, "delay of send packet") + argZbbx = flag.String("server", "127.0.0.1:10051", "address of server server") argMaxMetrics = flag.Int("max-metrics", 0, "max number of metrics each client sends") argMaxDuration = flag.Duration("max-duration", 0, "max duration of benchmark test") @@ -86,21 +86,21 @@ func main() { } -// client of zabbix server +// client of zbbx server type client struct { id int host string - sender *zabbix.Sender + sender *zbbx.Sender } -// generate and send zabbix packet +// generate and send zbbx packet func (c *client) send() error { now := time.Now().Unix() - metrics := make([]*zabbix.Metric, 0) + metrics := make([]*zbbx.Metric, 0) for i := 0; i < *argPacketSize; i++ { - metrics = append(metrics, zabbix.NewMetric(c.host, fmt.Sprintf(*argMetricName, i), fmt.Sprintf("%d", i), now)) + metrics = append(metrics, zbbx.NewMetric(c.host, fmt.Sprintf(*argMetricName, i), fmt.Sprintf("%d", i), now)) } - return c.sender.Send(zabbix.NewPacket(metrics, now)) + return c.sender.Send(zbbx.NewPacket(metrics, now)) } func StartClient(id int) { @@ -108,7 +108,7 @@ func StartClient(id int) { c := &client{ id: id, host: fmt.Sprintf(*argClinetName, id), - sender: zabbix.NewSender(*argZabbix), + sender: zbbx.NewSender(*argZbbx), } ticker := time.Tick(*argPacketDelay) for { diff --git a/src/zabbix/metric.go b/src/zbbx/metric.go similarity index 96% rename from src/zabbix/metric.go rename to src/zbbx/metric.go index a0153b5..e5bcf31 100644 --- a/src/zabbix/metric.go +++ b/src/zbbx/metric.go @@ -1,4 +1,4 @@ -package zabbix +package zbbx import ( "time" diff --git a/src/zabbix/packet.go b/src/zbbx/packet.go similarity index 98% rename from src/zabbix/packet.go rename to src/zbbx/packet.go index 5ca52f0..25491d6 100644 --- a/src/zabbix/packet.go +++ b/src/zbbx/packet.go @@ -1,4 +1,4 @@ -package zabbix +package zbbx import ( "encoding/binary" diff --git a/src/zabbix/sender.go b/src/zbbx/sender.go similarity index 85% rename from src/zabbix/sender.go rename to src/zbbx/sender.go index 02e347e..ab56799 100644 --- a/src/zabbix/sender.go +++ b/src/zbbx/sender.go @@ -1,4 +1,4 @@ -package zabbix +package zbbx import ( "fmt" @@ -17,7 +17,7 @@ type Sender struct { func NewSender(address string) *Sender { s := &Sender{address: address} if err := s.resolv(); err != nil { - os.Stderr.WriteString(fmt.Sprintf("Can't resolv zabbix address: %s\n", err.Error())) + os.Stderr.WriteString(fmt.Sprintf("Can't resolv address: %s\n", err.Error())) os.Exit(1) } return s @@ -61,7 +61,7 @@ func (s *Sender) Send(packet *Packet) error { _, err = s.read(conn) if err != nil { - fmt.Fprintf(os.Stderr, "Read zabbix response error: %s\n", err.Error()) + fmt.Fprintf(os.Stderr, "Read response error: %s\n", err.Error()) } return conn.Close()