chutils

Mar 26, 2024

Changes in this version

+ func ReadFS(defDir embed.FS, startDir string) (defs map[string]string, err error)

+ func ReadOS(dir string) (defs map[string]string, err error)

+ func StrToCol(inStr, sep string, skipFirst bool) (keyval.KeyVal, error)

type ChField

+ func NewChFieldKV(kv keyval.KeyVal) ChField

type FieldDef

+ func NewFieldDefKV(kv keyval.KeyVal) (fd *FieldDef, err error)

type LegalValues

+ func NewLegalKV(kv keyval.KeyVal) *LegalValues

type TableDef

+ func NewTableDefKV(defs map[string]string) (td *TableDef, err error)

Jul 18, 2023

Changes in this version

+ func GetSystemField(table, sysField, field string, conn *Connect) (fieldVal string, err error)

+ func GetSystemFields(conn *Connect, sysField string, table ...string) (map[string]string, error)

Jul 6, 2023

Changes in this version

+ func GetComment(table, field string, conn *Connect) (comment string, err error)

Jun 22, 2023

Changes in this version

+ func GetComments(conn *Connect, table ...string) (map[string]string, error)

Jun 14, 2023

Changes in this version

+ func CommentColumn(table, column, comment string, conn *Connect) error

+ func CommentFds(table string, fds map[int]*FieldDef, conn *Connect)

Apr 20, 2023

Changes in this version

type TableDef

+ func (td *TableDef) Copy(noLegal bool) *TableDef

+ func (td *TableDef) FieldList() []string

Apr 3, 2023

Changes in this version

type Connect

+ func (conn *Connect) Execute(qry string) error

+ type ConnectOpt func(conn *Connect)

+ func WithTimeOut(timeOutMinutes int64) ConnectOpt

Sep 12, 2022

Changes in this version

+ func WriteArray(el interface{}, char string, sdelim string) (line []byte)

+ func WriteElement(el interface{}, char string, sdelim string) []byte

Jun 20, 2022

Changes in this version

type Output

+ Text func() string

Jun 7, 2022

Changes in this version

type FieldDef

+ Drop bool

May 26, 2022

Changes in this version

type Status

+ const VDefault

May 26, 2022

Changes in this version

type FieldDef

+ Default interface{}

May 23, 2022

Changes in this version

+ const OuterArray

+ const OuterLowCardinality

+ const OuterNullable

type ChField

+ Funcs OuterFuncs

+ func (ch ChField) String() string

+ type OuterFunc int

+ func (o OuterFunc) String() string

+ type OuterFuncs []OuterFunc

+ func (o OuterFuncs) Has(target OuterFunc) bool

May 16, 2022

Changes in this version

+ var DateFormats = []string

+ var DateMissing = time.Date(1970, 1, 2, 0, 0, 0, 0, time.UTC)

+ var FloatMissing = -1.0

+ var IntMissing = -1

+ var StringMissing = "!"

+ func Concur(nWorker int, rdrs []Input, wrtrs []Output, ...) error

+ func Export(rdr Input, wrtr Output) error

+ func Load(rdr Input, wrtr Output) (err error)

+ func Wrapper(e error, text string) error

+ type ChField struct

+ Base ChType

+ Format string

+ Length int

+ OuterFunc string

+ func NewChField(base ChType, length int, outerFunc string, Format string) (*ChField, error)

+ func (t ChField) Converter(inValue interface{}, missing interface{}) (interface{}, Status)

+ type ChType int

+ const ChDate

+ const ChFixedString

+ const ChFloat

+ const ChInt

+ const ChString

+ const ChUnknown

+ func FindType(newVal string, target *ChField) (res ChType)

+ func (t ChType) String() string

+ type Connect struct

+ Host string

+ Http string

+ Password string

+ User string

+ func NewConnect(http string, host string, user string, password string) (con *Connect, err error)

+ func (c Connect) String() string

+ type EngineType int

+ const Memory

+ const MergeTree

+ func (i EngineType) String() string

+ type ErrType int

+ const ErrDateFormat

+ const ErrFieldCount

+ const ErrFields

+ const ErrInput

+ const ErrOutput

+ const ErrRWNum

+ const ErrSQL

+ const ErrSeek

+ const ErrStr

+ const ErrUnknown

+ func (i ErrType) Error() string

+ func (i ErrType) String() string

+ type FieldDef struct

+ ChSpec ChField

+ Description string

+ Legal *LegalValues

+ Missing interface{}

+ Name string

+ Width int

+ func NewFieldDef(name string, chSpec ChField, description string, legal *LegalValues, ...) *FieldDef

+ func (fd *FieldDef) CheckRange(checkVal interface{}) (interface{}, Status)

+ func (fd *FieldDef) Validator(inValue interface{}) (outVal interface{}, status Status)

+ type Input interface

+ Close func() error

+ CountLines func() (numLines int, err error)

+ Read func(nTarget int, validate bool) (data []Row, valid []Valid, err error)

+ Reset func() error

+ Seek func(lineNo int) error

+ TableSpec func() *TableDef

+ type LegalValues struct

+ HighLimit interface{}

+ Levels *map[string]int

+ LowLimit interface{}

+ func NewLegalValues() *LegalValues

+ type Output interface

+ Close func() error

+ EOL func() rune

+ Insert func() error

+ Name func() string

+ Separator func() rune

+ Write func(b []byte) (n int, err error)

+ type Row []interface

+ type Status int

+ const VPass

+ const VTypeFail

+ const VValueFail

+ func (i Status) String() string

+ type TableDef struct

+ Engine EngineType

+ FieldDefs map[int]*FieldDef

+ Key string

+ func NewTableDef(key string, engine EngineType, fielddefs map[int]*FieldDef) *TableDef

+ func (td *TableDef) Check() error

+ func (td *TableDef) Create(conn *Connect, table string) error

+ func (td *TableDef) Get(name string) (int, *FieldDef, error)

+ func (td *TableDef) Impute(rdr Input, rowsToExamine int, tol float64) (err error)

+ func (td *TableDef) Nest(nestName string, field1 string, field2 string) error

+ type Valid []Status