modulepackage
0.0.0-20221027022642-8479a82b9799
Repository: https://github.com/fudorec/kdbgo.git
Documentation: pkg.go.dev
# README
Go driver for kdb+
This is an implementation of kdb+ driver native in Go. It implements Q IPC protocol.
Can be used both as a client(Go program connects to kdb+ process) and as a server(kdb+ connects to Go program). In server mode no execution capabilities are available.
For documentations and examples see godoc
# Functions
Atom constructs generic K atom with given type.
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
Compress b using Q IPC compression.
No description provided by the author
No description provided by the author
Decode deserialises data from src in q ipc format.
DialKDB connects to host:port using supplied user:password.
DialKDBTimeout connects to host:port using supplied user:password.
DialTLS connects to host:port using TLS with cfg provided.
DialUnix connects to port using unix domain sockets.
Encode data to ipc format as msgtype(sync/async/response) to specified writer.
Error constructs K error object from Go error.
Float wraps float64 as K.
FloatV wraps float64 as K.
No description provided by the author
No description provided by the author
process clients requests.
Int wraps int32 as K.
IntV wraps int32 slice as K.
Long wraps int64 as K.
LongV wraps int64 slice as K.
No description provided by the author
NewFunc creates K function with body in ctx namespace.
NewList constructs generic list(type 0) from list of K arguments.
NewRuntimeError initializes a new RuntimeError with a message.
No description provided by the author
NewUnsupportedTypeError initializes a new UnsupportedTypeError with a message.
Real wraps float32 as K.
RealV wraps float32 slice as K.
No description provided by the author
No description provided by the author
No description provided by the author
Symbol wraps string as K.
SymbolV wraps string slice as K.
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
Uncompress byte array compressed with Q IPC compression.
UnmarshalDict decodes dict to a struct.
UnmarshalDictToMap decodes dict into map[string]interface{}.
UnmarshalTable decodes table to array of structs.
# Constants
Constants for recognised request types.
Constants for recognised attributes.
generic type.
1 boolean char.
1 char char.
composition.
4 date int days from 2000.01.01.
dynamic loaded libraries - not available in IPC.
4 real float.
f'.
f\:.
f/:.
indicates error with 0 terminated string as a text.
8 float double.
function types.
binary primitive.
ternary (operator).
unary primitive.
1 byte char.
2 short short.
4 int int.
8 long long.
4 month int months from 2000.01.01.
8 timespan long nanoseconds.
f/.
8 timestamp long nanoseconds from 2000.01.01.
f':.
projection.
* symbol char*.
f\.
4 time int millisecond.
4 minute int.
4 second int.
8 datetime double deprecated - DO NOT USE.
Nh is a short nil.
Ni is an int nil.
Nj is a long nil.
Constants for recognised attributes.
Constants for recognised attributes.
Constants for recognised request types.
sorted dict - acts as a step function.
Constants for recognised attributes.
Constants for recognised request types.
Constants for recognised attributes.
16 guid U.
Wh is a short infinity.
Wi is an int infinity.
Wj is a long infinity.
2 element generic list with 0 as keys and 1 as values.
pointer to dictionary containing string keys(column names) and values.
# Variables
No description provided by the author
ErrBadHeader to indicate invalid header.
ErrSyncRequest cannot process sync requests.
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
Ne is a real nil.
Nf is a double nil.
No description provided by the author
No description provided by the author
We is a real infinity.
Wf is a double infinity.
# Structs
Dict represents ordered key->value mapping.
Function represents function in kdb+.
K structure.
KDBConn establishes connection and communicates using Q IPC protocol.
RuntimeError is a runtime error thrown by a Q engine.
Table represents table type in kdb.
UnsupportedTypeError is an error returned when encoding or decoding a type that is not supported by kdb.