numaflow 0.5.0

Rust SDK for Numaflow
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20

syntax = "proto3";

package metadata;

// Metadata is the metadata of the message
message Metadata {
  // PreviousVertex is the name of the previous vertex
  string previous_vertex = 1;
  // SystemMetadata is the system metadata of the message
  // Key of the map is the group name
  map<string, KeyValueGroup> sys_metadata = 2;
  // UserMetadata is the user metadata of the message
  // Key of the map is the group name
  map<string, KeyValueGroup> user_metadata = 3;
}

// KeyValueGroup is a group of key-value pairs for a given group.
message KeyValueGroup {
  map<string, bytes> key_value = 1;
}