Versions in this module Expand all Collapse all v0 v0.5.2 Aug 24, 2024 Changes in this version + var DEBUG_FLUSH = false + var DEBUG_SYBIL = os.Getenv("DEBUG_SYBIL") != "" + var ENV_FLAG = os.Getenv("DEBUG") + var FIELD_SEPARATOR = string([]byte{ ... }) + var FILTER_SEPARATOR = string([]byte{ ... }) + var FLAGS = FlagDefs + var SYBIL_BIN = "sybil" + func Debug(args ...interface{}) + func Error(args ...interface{}) + func ListTables(config *SybilConfig) []string + func Print(args ...interface{}) + func SetBinPath(binPath string) + func Warn(args ...interface{}) + type FlagDefs struct + DEBUG bool + type SybilConfig struct + Dir string + Table string + type SybilFilter struct + Field string + Op string + Value string + type SybilMapRecord map[string]interface + type SybilQuery struct + Config *SybilConfig + Flags []string + IntFilters []SybilFilter + Ints []string + ReadLog bool + Results string + SetFilters []SybilFilter + Sets []string + StrFilters []SybilFilter + Strs []string + TimeBucket int + TimeCol string + func (sq *SybilQuery) Aggregate(field string) *SybilQuery + func (sq *SybilQuery) Execute() ([]SybilResult, error) + func (sq *SybilQuery) GroupBy(field string) *SybilQuery + func (sq *SybilQuery) Hist() *SybilQuery + func (sq *SybilQuery) IntFilterEq(field string, value int) *SybilQuery + func (sq *SybilQuery) IntFilterGt(field string, value int) *SybilQuery + func (sq *SybilQuery) IntFilterLt(field string, value int) *SybilQuery + func (sq *SybilQuery) IntFilterNeq(field string, value int) *SybilQuery + func (sq *SybilQuery) Limit(limit int) *SybilQuery + func (sq *SybilQuery) LogHist() *SybilQuery + func (sq *SybilQuery) ReadRowLog(v bool) *SybilQuery + func (sq *SybilQuery) Rollup() *SybilQuery + func (sq *SybilQuery) Samples() *SybilQuery + func (sq *SybilQuery) StrFilterEq(field string, value string) *SybilQuery + func (sq *SybilQuery) StrFilterRegex(field string, value string) *SybilQuery + func (sq *SybilQuery) TimeSeries(timeCol string, bucket int) *SybilQuery + func (sq *SybilQuery) WeightCol(field string) *SybilQuery + type SybilRecord struct + Ints map[string]int + Sets map[string][]string + Strs map[string]string + func NewRecord() *SybilRecord + func (r *SybilRecord) Int(field string, value int) *SybilRecord + func (r *SybilRecord) JSON() []byte + func (r *SybilRecord) Set(field string, value []string) *SybilRecord + func (r *SybilRecord) Str(field string, value string) *SybilRecord + type SybilResult map[string]interface + func (sr SybilResult) Int(field string) (int, bool) + func (sr SybilResult) Set(field string) (map[string]string, bool) + func (sr SybilResult) Str(field string) (string, bool) + type SybilTable struct + Config *SybilConfig + NewRecords []interface{} + func NewTable(config *SybilConfig) *SybilTable + func (t *SybilTable) AddJSONRecords(records [][]byte) + func (t *SybilTable) AddMapRecords(records []map[string]interface{}) + func (t *SybilTable) AddRecords(records interface{}) + func (t *SybilTable) AddStructRecords(records []interface{}) + func (t *SybilTable) AddSybilMapRecords(records []SybilMapRecord) + func (t *SybilTable) DigestRecords() + func (t *SybilTable) FlushRecords() + func (t *SybilTable) GetTableInfo() *sybil.TableInfo + func (t *SybilTable) Query() *SybilQuery
Go to main page