Versions in this module Expand all Collapse all v0 v0.1.0 Mar 17, 2023 Changes in this version + var ErrFlattenColumnedEntity = errors.New("empty column entity input") + var ErrIndexEntity = errors.New("empty entity index") + func AddQuickFilter(flightName string, id uint64, data []byte) error + func BuildIndexFromColumnizedEntities(entities []*codec.ColumnedEntity) ([]byte, error) + func Exchange(dir string, exchange *flight.FlightData, transientID uint64, data []byte, ...) (*flight.FlightData, error) + func QueryCluster(dir string, stmt *ssql.Statement, hosts []string, local int, ...) ([]byte, error) + func QueryLocal(dir string, stmt *ssql.Statement, transientID uint64, transientBuf []byte, ...) ([]byte, error) + func SplitIndexQuickFilter(data []byte) ([]byte, []byte) + func StatementToArrowSchema(stmt *ssql.Statement, logger nats.Logger) ([]byte, error) + type Callback struct + Send func(header, body []byte) bool