Core cli plugin, contains the core building blocks for the Flowcore CLI
$ npm install -g @flowcore/cli-plugin-core
$ core COMMAND
running command...
$ core (--version)
@flowcore/cli-plugin-core/1.2.0 linux-x64 node-v20.13.1
$ core --help [COMMAND]
USAGE
$ core COMMAND
...
Stream events from a datacore running on the Flowcore Platform
USAGE
$ core stream STREAM [--profile <value>] [-j] [-l] [-m <value>] [-o http|log] [-p] [-c] [-s <value>] [-d
<value>] [-H <value>] [-t <value>]
ARGUMENTS
STREAM stream url to connect to
FLAGS
-H, --header=<value>... [default: ] header to send with the request, example: (-H 'Authorization: Bearer TOKEN')
-c, --scan Scan the full time range
-d, --destination=<value> [default: http://localhost:3000/transform] Destination to send events to
-j, --json Output json only
-l, --[no-]live Change to live mode when reaching last time bucket
-m, --max=<value> Maximum number of events to send to the destination
-o, --output=<option> [default: http] Output format
<options: http|log>
-p, --payload Only send the event payload to the destination
-s, --start=<value> Start time bucket to stream from, example: (1y, 1m, 1w, 1d, 1h, now)
-t, --timeout=<value> [default: 5000] Timeout in milliseconds to wait for a response from the destination
--profile=<value> Specify the configuration profile to use
DESCRIPTION
Stream events from a datacore running on the Flowcore Platform
EXAMPLES
$ core stream https://flowcore.io/<org>/<data core>/<flow type>/<event type>.stream
$ core stream https://flowcore.io/<org>/<data core>/<flow type>/<event type>.stream -s 1y
$ core stream https://flowcore.io/<org>/<data core>/<flow type>/<event type>.stream -o log -s 3m --json > some.json
$ core stream https://flowcore.io/<org>/<data core>/<flow type>/[<event type1>,<event type2>,<event type3>].stream -o log -s 3m
See code: src/commands/stream.ts