Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
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{}), }
Worker takes on computations. It registers as a subscriber for necessary topics and publishes the results of the computations
View Source
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, }
Producer reads records from stdin and submits them to registered subscribers via RPC
View Source
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)", }, }), }
Subscriber registers as a subscriber for a certain topic(s). Useful for debugging.
View Source
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.)", }, }), }
Worker takes on computations. It registers as a subscriber for necessary topics and publishes the results of the computations
Functions ¶
This section is empty.
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.