rust_bridge

package module

v0.1.0 Latest Latest Go to latest Published: Mar 17, 2023 License: Apache-2.0 Imports: 11 Imported by: 1

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/chronowave/rust-bridge

Links

Open Source Insights

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

Constants ¶

This section is empty.

Variables ¶

View Source

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
}

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
callback

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL