Versions in this module Expand all Collapse all v0 v0.1.1 Jul 6, 2023 Changes in this version + const OutputStyleJson + const OutputStylePlain + const OutputStyleTable + func BytesHash64(b []byte) int64 + func CreateTLSConfig(caPath, certPath, keyPath string, insecureSkipVerify bool) (*tls.Config, error) + func DecodeRow(b []byte) (map[int64][]byte, error) + func EncodeRow(cols [][]byte, colIDs []int64, valBuf []byte) ([]byte, error) + func Fatal(args ...interface{}) + func Fatalf(format string, args ...interface{}) + func FloatToOneString(f interface{}) string + func Hash64(n int64) int64 + func IntToString(i interface{}) string + func RandBytes(r *rand.Rand, b []byte) + func RenderJson(w io.Writer, headers []string, values [][]string) + func RenderString(w io.Writer, format string, headers []string, values [][]string) + func RenderTable(w io.Writer, headers []string, values [][]string) + func Slice(s string) (b []byte) + func String(b []byte) (s string) + func StringHash64(s string) int64 + type BufPool struct + func NewBufPool() *BufPool + func (b *BufPool) Get() []byte + func (b *BufPool) Put(buf []byte) + type ConcurrentMap struct + func New(shardCount int) ConcurrentMap + func (m ConcurrentMap) Count() int + func (m ConcurrentMap) Get(key int) (int64, bool) + func (m ConcurrentMap) GetShard(key int) *ConcurrentMapShared + func (m ConcurrentMap) Has(key int) bool + func (m ConcurrentMap) IsEmpty() bool + func (m ConcurrentMap) Items() map[int]int64 + func (m ConcurrentMap) Iter() <-chan Tuple + func (m ConcurrentMap) IterBuffered() <-chan Tuple + func (m ConcurrentMap) IterCb(fn IterCb) + func (m ConcurrentMap) Keys() []int + func (m ConcurrentMap) MSet(data map[int]int64) + func (m ConcurrentMap) MarshalJSON() ([]byte, error) + func (m ConcurrentMap) Pop(key int) (v int64, exists bool) + func (m ConcurrentMap) Remove(key int) + func (m ConcurrentMap) RemoveCb(key int, cb RemoveCb) bool + func (m ConcurrentMap) Set(key int, value int64) + func (m ConcurrentMap) SetIfAbsent(key int, value int64) bool + func (m ConcurrentMap) Upsert(key int, value int64, cb UpsertCb) (res int64) + type ConcurrentMapShared struct + type FieldPair struct + Field string + Value []byte + type FieldPairs []FieldPair + func NewFieldPairs(values map[string][]byte) FieldPairs + func (s FieldPairs) Len() int + func (s FieldPairs) Less(i, j int) bool + func (s FieldPairs) Swap(i, j int) + type IterCb func(key int, v int64) + type RemoveCb func(key int, v int64, exists bool) bool + type RowCodec struct + func NewRowCodec(p *properties.Properties) *RowCodec + func (r *RowCodec) Decode(row []byte, fields []string) (map[string][]byte, error) + func (r *RowCodec) Encode(buf []byte, values map[string][]byte) ([]byte, error) + type SpinLock struct + func (sl *SpinLock) Lock() + func (sl *SpinLock) String() string + func (sl *SpinLock) TryLock() bool + func (sl *SpinLock) Unlock() + type Tuple struct + Key int + Val int64 + type UpsertCb func(exist bool, valueInMap int64, newValue int64) int64