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
57

syntax = "proto3";

package schema.source;

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

// source --> runtime

message SourceExitCode {
  enum Enum {
    UNDEFINED = 0;
    OK = 1;
    INTERRUPTED = 2;
    ERROR = 3;
  }
}

message SourceExit {
  SourceExitCode.Enum code = 1;
  string message = 2;
}

message SourceEvent {
  string source_id = 1;
  string source_version = 2;
  schema.PluginPayload payload = 3;
}

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

message SourceMessage {
  oneof payload {
    Initialize initialize = 1;
    SourceExit exit = 2;
    SourceEvent event = 3;
    common.LogEvent log = 4;
    common.ErrorEvent error = 5;
  }
}

// runtime --> source

message InitializeResponse {}

message Shutdown {}

message RuntimeSourceMessage {
  oneof payload {
    InitializeResponse initialize = 1;
    Shutdown shutdown = 2;
  }
}