kdb 0.3.0

Idiomatic, High performance API for using KDB+ and Q from Rust
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
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150

use std::fmt;
#[derive(Copy, Clone, PartialEq, Eq, Debug)]
pub struct TypeCode(pub(crate) u8);

impl TypeCode {
    pub const BOOLEAN: Self = TypeCode(1);
    pub const GUID: Self = TypeCode(2);
    pub const BYTE: Self = TypeCode(4);
    pub const SHORT: Self = TypeCode(5);
    pub const INT: Self = TypeCode(6);
    pub const LONG: Self = TypeCode(7);
    pub const REAL: Self = TypeCode(8);
    pub const FLOAT: Self = TypeCode(9);
    pub const CHAR: Self = TypeCode(10);
    pub const SYMBOL: Self = TypeCode(11);
    pub const TIMESTAMP: Self = TypeCode(12);
    pub const MONTH: Self = TypeCode(13);
    pub const DATE: Self = TypeCode(14);
    pub const DATE_TIME: Self = TypeCode(15);
    pub const TIMESPAN: Self = TypeCode(16);
    pub const MINUTE: Self = TypeCode(17);
    pub const SECOND: Self = TypeCode(18);
    pub const TIME: Self = TypeCode(19);

    pub const fn as_list(self) -> KTypeCode {
        KTypeCode(self.0 as i8)
    }
    pub const fn as_atom(self) -> KTypeCode {
        KTypeCode(-(self.0 as i8))
    }
}

#[repr(transparent)]
#[derive(Clone, Copy, Eq, PartialEq, PartialOrd)]
pub struct KTypeCode(i8);

impl From<KTypeCode> for i32 {
    fn from(kt: KTypeCode) -> i32 {
        kt.0 as i32
    }
}

impl fmt::Display for KTypeCode {
    fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
        match *self {
            MIXED_LIST => write!(f, "mixed list"),
            BOOLEAN_ATOM => write!(f, "boolean atom"),
            GUID_ATOM => write!(f, "guid atom"),
            BYTE_ATOM => write!(f, "byte atom"),
            SHORT_ATOM => write!(f, "short atom"),
            INT_ATOM => write!(f, "int atom"),
            LONG_ATOM => write!(f, "long atom"),
            REAL_ATOM => write!(f, "real atom"),
            FLOAT_ATOM => write!(f, "float atom"),
            CHAR_ATOM => write!(f, "char atom"),
            SYMBOL_ATOM => write!(f, "symbol atom"),
            TIMESTAMP_ATOM => write!(f, "timestamp atom"),
            MONTH_ATOM => write!(f, "month atom"),
            DATE_ATOM => write!(f, "date atom"),
            DATE_TIME_ATOM => write!(f, "dateTime atom"),
            TIMESPAN_ATOM => write!(f, "timespan atom"),
            MINUTE_ATOM => write!(f, "minute atom"),
            SECOND_ATOM => write!(f, "second atom"),
            TIME_ATOM => write!(f, "time atom"),
            BOOLEAN_LIST => write!(f, "boolean list"),
            GUID_LIST => write!(f, "guid list"),
            BYTE_LIST => write!(f, "byte list"),
            SHORT_LIST => write!(f, "short list"),
            INT_LIST => write!(f, "int list"),
            LONG_LIST => write!(f, "long list"),
            REAL_LIST => write!(f, "real list"),
            FLOAT_LIST => write!(f, "float list"),
            CHAR_LIST => write!(f, "char list"),
            SYMBOL_LIST => write!(f, "symbol list"),
            TIMESTAMP_LIST => write!(f, "timestamp list"),
            MONTH_LIST => write!(f, "month list"),
            DATE_LIST => write!(f, "date list"),
            DATE_TIME_LIST => write!(f, "datetime list"),
            TIMESPAN_LIST => write!(f, "timespan list"),
            MINUTE_LIST => write!(f, "minute list"),
            SECOND_LIST => write!(f, "second list"),
            TIME_LIST => write!(f, "time list"),
            TABLE => write!(f, "table"),
            DICT => write!(f, "dict"),
            ERROR => write!(f, "error"),
            _ => write!(f, "Unknown"),
        }
    }
}

impl KTypeCode {
    pub(crate) fn atom_size(self) -> usize {
        match KTypeCode(self.0.abs()) {
            BOOLEAN_LIST | BYTE_LIST | CHAR_LIST => 1,
            SHORT_LIST => 2,
            INT_LIST | REAL_LIST | DATE_LIST | MINUTE_LIST | SECOND_LIST | MONTH_LIST | TIME_LIST => 4,
            LONG_LIST | FLOAT_LIST | DATE_TIME_LIST | TIMESTAMP_LIST | TIMESPAN_LIST => 8,
            GUID_LIST => 24, // Guid has an 8 byte length as well as 16 bytes for the guid
            SYMBOL_LIST | MIXED_LIST | TABLE | DICT | ERROR => std::mem::size_of::<*const u8>(),
            _ => panic!("Unknown K type: {}", self.0),
        }
    }
}

impl fmt::Debug for KTypeCode {
    fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
        write!(f, "{}({})", self, self.0)
    }
}

pub const MIXED_LIST: KTypeCode = KTypeCode(0);
pub const BOOLEAN_ATOM: KTypeCode = KTypeCode(-1);
pub const GUID_ATOM: KTypeCode = KTypeCode(-2);
pub const BYTE_ATOM: KTypeCode = KTypeCode(-4);
pub const SHORT_ATOM: KTypeCode = KTypeCode(-5);
pub const INT_ATOM: KTypeCode = KTypeCode(-6);
pub const LONG_ATOM: KTypeCode = KTypeCode(-7);
pub const REAL_ATOM: KTypeCode = KTypeCode(-8);
pub const FLOAT_ATOM: KTypeCode = KTypeCode(-9);
pub const CHAR_ATOM: KTypeCode = KTypeCode(-10);
pub const SYMBOL_ATOM: KTypeCode = KTypeCode(-11);
pub const TIMESTAMP_ATOM: KTypeCode = KTypeCode(-12);
pub const MONTH_ATOM: KTypeCode = KTypeCode(-13);
pub const DATE_ATOM: KTypeCode = KTypeCode(-14);
pub const DATE_TIME_ATOM: KTypeCode = KTypeCode(-15);
pub const TIMESPAN_ATOM: KTypeCode = KTypeCode(-16);
pub const MINUTE_ATOM: KTypeCode = KTypeCode(-17);
pub const SECOND_ATOM: KTypeCode = KTypeCode(-18);
pub const TIME_ATOM: KTypeCode = KTypeCode(-19);
pub const BOOLEAN_LIST: KTypeCode = KTypeCode(1);
pub const GUID_LIST: KTypeCode = KTypeCode(2);
pub const BYTE_LIST: KTypeCode = KTypeCode(4);
pub const SHORT_LIST: KTypeCode = KTypeCode(5);
pub const INT_LIST: KTypeCode = KTypeCode(6);
pub const LONG_LIST: KTypeCode = KTypeCode(7);
pub const REAL_LIST: KTypeCode = KTypeCode(8);
pub const FLOAT_LIST: KTypeCode = KTypeCode(9);
pub const CHAR_LIST: KTypeCode = KTypeCode(10);
pub const SYMBOL_LIST: KTypeCode = KTypeCode(11);
pub const TIMESTAMP_LIST: KTypeCode = KTypeCode(12);
pub const MONTH_LIST: KTypeCode = KTypeCode(13);
pub const DATE_LIST: KTypeCode = KTypeCode(14);
pub const DATE_TIME_LIST: KTypeCode = KTypeCode(15);
pub const TIMESPAN_LIST: KTypeCode = KTypeCode(16);
pub const MINUTE_LIST: KTypeCode = KTypeCode(17);
pub const SECOND_LIST: KTypeCode = KTypeCode(18);
pub const TIME_LIST: KTypeCode = KTypeCode(19);
pub const TABLE: KTypeCode = KTypeCode(98);
pub const DICT: KTypeCode = KTypeCode(99);
pub const ERROR: KTypeCode = KTypeCode(-128);