sdf-context-guest 0.11.0

guest crate for sdf operator ctx
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
58
59
60
61
62
63
64
65

package sdf:context;

interface types {

    type window = tuple<timestamp, timestamp>;

    type timestamp = s64;

    record service-metadata {
        dataflow-name: string,
        service-name: string,
        states: list<tuple<string, state>>,
    }

    variant state {
        owned,
        ref(string)
    }

    record operator-metadata {
        service-metadata: service-metadata,
        operator-name: string
    }

    variant key {
        %string(string),
        %u64(u64),
        i64(s64),
        %bool(bool)
    } 
}

interface operator-context {
    use types.{ window as window-type, key as key-type, operator-metadata as operator-metadata-type };

    use sdf:df/lazy.{ df-value };
    use sdf:row-state/row.{ row-value };
    use sdf:value-state/values.{ value32, list32};

    // get window
    window: func() -> window-type;

    // get key
    key: func() -> option<key-type>;

    // service name
    operator-metadata: func() -> operator-metadata-type;
    
    // get row value for state name
    get-row-value: func(state-name: string) -> option<row-value>;

    // get value32
    get-value32: func(state-name: string) -> option<value32>;

    // get list32
    get-list32: func(state-name: string) -> option<list32>;

    // call sql
    sql: func(sql: string) -> result<df-value,string>;

}

world context-world {
    import operator-context;
}