cargo-pipe 0.1.4

A command-line tool to generate and build data integration app using pipebase framework
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41

name: print_timer_tick
dependencies:
  - name: pipebase
    path: ../../../pipebase
    modules: ["pipebase::prelude::*"]
pipes:
  - name: timer1
    ty: Poller
    config:
      ty: TimerConfig
      path: catalogs/timer1.yml
    output: UnsignedLongLong
  - name: timer2
    ty: Poller
    config:
      ty: TimerConfig
      path: catalogs/timer2.yml
    output: UnsignedLongLong
  - name: printer
    ty: Exporter
    config:
      ty: PrinterConfig
    upstreams: [ "timer1", "timer2" ]
    buffer: 10
objects:
  - ty: Bar
    fields:
      - name: bar1
        ty: Integer
      - name: bar2
        ty: String
cstores:
  - name: "context_printer"
    config:
      ty: "ContextPrinterConfig"
      path: "catalogs/context_printer.yml"
error:
  config:
    ty: "PipeErrorPrinterConfig"
  buffer: 10