kiwi-sdk 0.1.1

The Kiwi SDK allows you to write pluggable modules that hook into the Kiwi runtime.
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

interface intercept-types {
    // Plugin context
    record context {
        auth: option<list<u8>>,
        connection: connection-ctx,
        event: event-ctx,
    }

    variant connection-ctx {
        websocket(websocket),
    }

    variant event-ctx {
        kafka(kafka-event-ctx),
        counter(counter-event-ctx),
    }

    record counter-event-ctx {
        source-id: string,
        count: u64,
    }

    record kafka-event-ctx {
        payload: option<list<u8>>,
        source-id: string,
        topic: string,
        timestamp: option<u64>,
        partition: u32,
        offset: u64,
    }

    record websocket {
        addr: option<string>,
    }

    variant transformed-payload {
        kafka(option<list<u8>>),
        counter(u64),
    }

    variant action {
        forward,
        discard,
        transform(transformed-payload),
    }
}