Command line interface in draft - 1

README.md

@@ -5,3 +5,12 @@
 [![License: MIT](https://img.shields.io/badge/License-MIT-yellow.svg)](https://opensource.org/licenses/MIT)
 
 evundler is a performance testing framework written in Go.
+
+
+## Installation
+```
+go get -u github.com/github.com/go-loadtest/evbundler/cmd/evbundler
+```
+
+## Usage
+`t.b.d`

cmd/evbundler/internal/base/base.go

@@ -0,0 +1,13 @@
+package base
+
+import "flag"
+
+type Command struct {
+	Name  string
+	Doc   string
+	Run   func(args []string) error
+	Flags *flag.FlagSet
+}
+
+// Commands is register subcommands
+var Commands []*Command

cmd/evbundler/internal/ping/ping.go

@@ -0,0 +1,50 @@
+package ping
+
+import (
+	"context"
+	"flag"
+	"time"
+
+	"github.com/go-loadtest/evbundler"
+	"github.com/go-loadtest/evbundler/cmd/evbundler/internal/base"
+	"github.com/go-loadtest/evbundler/dispatcher"
+	"github.com/go-loadtest/evbundler/event"
+)
+
+const name = "ping"
+
+var Cmd = &base.Command{
+	Name: name,
+	Doc:  "icmpv4 event generator",
+	Run:  run,
+}
+
+var target string
+var interval string
+
+func run(args []string) error {
+	flags := flag.NewFlagSet(name, flag.ContinueOnError)
+	flags.StringVar(&target, "target", "", `send to host or ip`)
+	flags.StringVar(&interval, "interval", "1s", `interval of send each packets e.g. 1s, 300ms, 1m`)
+
+	if err := flags.Parse(args); err != nil {
+		return err
+	}
+
+	ctx, cancel := context.WithCancel(context.Background())
+	defer cancel()
+
+	d, err := time.ParseDuration(interval)
+	if err != nil {
+		return err
+	}
+	evCh := evbundler.TickerProducer(ctx, d, func(t time.Time, evCh chan evbundler.Event) {
+		evCh <- event.NewICMPv4Event(1, "0.0.0.0", target)
+	})
+
+	wp := evbundler.NewWorkerPool(10, nil)
+	disp := dispatcher.NewGoChannel(wp)
+	_ = disp.Dispatch(ctx, evCh)
+
+	return nil
+}

cmd/evbundler/main.go

@@ -0,0 +1,46 @@
+package main
+
+import (
+	"flag"
+	"fmt"
+	"os"
+
+	"github.com/go-loadtest/evbundler/cmd/evbundler/internal/base"
+	"github.com/go-loadtest/evbundler/cmd/evbundler/internal/ping"
+)
+
+type Commands []*base.Command
+
+func (cs Commands) Usage() {
+	usage := `
+Usage of evbundler:
+		evbundler <command> [arguments]
+
+The commands are:
+
+`
+	fmt.Fprint(os.Stderr, usage)
+	for i := range cs {
+		fmt.Fprintf(os.Stderr, "\t\t%s\t%s\n", cs[i].Name, cs[i].Doc)
+	}
+	os.Exit(2)
+}
+
+func main() {
+	commands := Commands{
+		ping.Cmd,
+	}
+
+	flag.Usage = commands.Usage
+	flag.Parse()
+	args := flag.Args()
+	if len(args) < 1 {
+		commands.Usage()
+	}
+
+	for _, c := range commands {
+		if c.Name == args[0] {
+			c.Run(args[1:])
+		}
+	}
+}

event/http.go

@@ -25,7 +25,7 @@ type HTTPEvent struct {
 
 // Name is Event name each event types
 func (he HTTPEvent) Name() string {
-	return "HTTP"
+	return "http"
 }
 
 // Fire execute a Event by parameters

event/icmpv4.go

@@ -23,7 +23,7 @@ func NewICMPv4Event(seq int, listenAddr, addr string) *ICMPv4Event {
 }
 
 func (e ICMPv4Event) Name() string {
-	return "ICMPv4"
+	return "ping"
 }
 
 func (e ICMPv4Event) Fire(ctx context.Context) error {