handler

Documentation

Index

• type ArrowFlightHandler
• type CloudQueryHandler
• type Handler
• type Table

Types

type ArrowFlightHandler

type ArrowFlightHandler interface {
	DoGet(ctx context.Context, table *Table, r chan<- arrow.Record) error
	DoPut(ctx context.Context, r arrow.Record) error
	LookupTable(ctx context.Context, tableName string) (*Table, error)
}

type CloudQueryHandler

type CloudQueryHandler interface {
	MigrateTable(ctx context.Context, msg message.WriteMigrateTables) error
	DeleteRecord(ctx context.Context, msg message.WriteDeleteRecords) error
	DeleteStale(ctx context.Context, msg message.WriteDeleteStales) error
}

type Handler

type Handler struct {
	CloudQueryHandler
	ArrowFlightHandler
}

type Table

type Table struct {
	Name   string
	Schema *arrow.Schema
}