rust_bridge

Documentation

Index

• Variables
• 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

Variables

var (
	ErrFlattenColumnedEntity = errors.New("empty column entity input")
	ErrIndexEntity           = errors.New("empty entity index")
)

Functions

func AddQuickFilter

func AddQuickFilter(flightName string, id uint64, data []byte) error

func BuildIndexFromColumnizedEntities

func BuildIndexFromColumnizedEntities(entities []*codec.ColumnedEntity) ([]byte, error)

func Exchange

func Exchange(dir string, exchange *flight.FlightData, transientID uint64, data []byte, streaming bool, onFlightData func([]byte, []byte) bool) (*flight.FlightData, error)

exchange local data

func QueryCluster

func QueryCluster(dir string, stmt *ssql.Statement, hosts []string, local int,
	transientID uint64, transientBuf []byte, logger nats.Logger) ([]byte, error)

func QueryLocal

func QueryLocal(dir string, stmt *ssql.Statement, transientID uint64, transientBuf []byte, logger nats.Logger) ([]byte, error)

func SplitIndexQuickFilter

func SplitIndexQuickFilter(data []byte) ([]byte, []byte)

/ returns quick filter and index

func StatementToArrowSchema

func StatementToArrowSchema(stmt *ssql.Statement, logger nats.Logger) ([]byte, error)

Types

type Callback

type Callback struct {
	// Send should return true on failure, false otherwise
	Send func(header, body []byte) bool
}