cargo-pipe 0.1.0

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
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58

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:
      ty: UnsignedLongLong
  - name: timer2
    ty: Poller
    config:
      ty: TimerConfig
      path: catalogs/timer2.yml
    output:
      ty: UnsignedLongLong
  - name: printer
    ty: Exporter
    config:
      ty: PrinterConfig
    upstreams: [ "timer1", "timer2" ]
objects:
  - ty: Bar
    fields:
      - name: bar1
        ty: Integer
      - name: bar2
        ty: String
  - ty: ProjectedBar
    metas:
      - derives: [Clone, Debug, Project]
      - project: 
          input: Bar
    fields:
      - name: bar1
        ty: Integer
        metas:
          - project:
              from: bar1
      - name: bar2
        ty: String
        metas:
          - project:
              expr: "b.bar2.to_owned()"
              alias: "b"
cstores:
  - name: "context_printer"
    config:
      ty: "ContextPrinterConfig"
      path: "catalogs/context_printer.yml"
error:
  config:
    ty: "PipeErrorPrinterConfig"