command

var HTTPAPI = cli.Command{
	Name:    "httpapi",
	Aliases: []string{"h"},
	Usage:   "start dagger node as a HTTP API node",
	Action:  httpapiAction,
	Flags: mergeFlags(logFlags, consulFlags, receiverFlags, persisterFlags, dispatcherFlags,
		[]cli.Flag{}),
}

var Producer = cli.Command{
	Name:    "producer",
	Aliases: []string{"p"},
	Usage:   "start a dedicated dagger producer node, which reads data from stdin and publishes it on the given stream",
	Flags: mergeFlags(logFlags, consulFlags, persisterFlags, dispatcherFlags,
		[]cli.Flag{
			cli.StringFlag{
				Name:  "streamID, s",
				Usage: "Stream ID to publish records on",
			},
		}),
	Action: producerAction,
}

var Subscriber = cli.Command{
	Name:    "subscriber",
	Aliases: []string{"s"},
	Usage:   "start dagger node as a topic subscriber",
	Action:  subscriberAction,
	Flags: mergeFlags(logFlags, consulFlags, receiverFlags, persisterFlags,
		[]cli.Flag{
			cli.BoolFlag{
				Name:  "dataonly",
				Usage: "print only the 'Data' field of the record if true",
			},
			cli.StringFlag{
				Name:  "from",
				Value: "0",
				Usage: "subscribe to records from specified Unix nanosecond timestamp onward",
			},
			cli.StringFlag{
				Name:  "groupby",
				Usage: "match specified streams by specified tags (with @ sign)",
			},
		}),
}

var Worker = cli.Command{
	Name:    "worker",
	Aliases: []string{"w"},
	Usage:   "start dagger node as a worker",
	Action:  workerAction,
	Flags: mergeFlags(logFlags, consulFlags, receiverFlags, persisterFlags, dispatcherFlags, httpApiFlags,
		[]cli.Flag{
			cli.StringFlag{
				Name:  "appmetrics",
				Usage: "InfluxDB URL for app metrics (how many records are being processed etc.)",
			},
		}),
}