flwrs-plugin 0.0.1

Crate for building plugins for flwrs.
Documentation 
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

syntax = "proto3";

package schema.sink;

import "schema/schema.proto";
import "schema/common.proto";

// sink --> runtime

message SinkExitCode {
  enum Enum {
    OK = 0;
    INTERRUPTED = 1;
    ERROR = 2;
  }
}

message SinkExit {
  SinkExitCode.Enum code = 1;
  string message = 2;
}

message Initialize {
  string plugin_id = 1;
  string plugin_version = 2;
  schema.SchemaDefinition schema = 3;
}

message SinkMessage {
  oneof payload {
    Initialize initialize = 1;
    SinkExit exit = 2;
    common.LogEvent log = 3;
    common.ErrorEvent error = 4;
  }
}

// runtime --> sink

message SinkEvent {
  string plugin_id = 1;
  string plugin_version = 2;
  schema.PluginPayload payload = 3;
}

message Shutdown {}

message InitializeResponse {}

message RuntimeSinkMessage {
  oneof payload {
    InitializeResponse initialize = 1;
    Shutdown shutdown = 2;
    SinkEvent event = 3;
  }
}