noophandler

Documentation

Index

• type ArrowFlight
  • func (*ArrowFlight) DoGet(ctx context.Context, table *handler.Table, r chan<- arrow.Record) error
  • func (*ArrowFlight) DoPut(ctx context.Context, r arrow.Record) error
  • func (*ArrowFlight) LookupTable(ctx context.Context, tableName string) (*handler.Table, error)
• type CloudQuery
  • func (*CloudQuery) DeleteRecord(ctx context.Context, msg message.WriteDeleteRecords) error
  • func (*CloudQuery) DeleteStale(ctx context.Context, msg message.WriteDeleteStales) error
  • func (*CloudQuery) MigrateTable(ctx context.Context, msg message.WriteMigrateTables) error

Types

type ArrowFlight

type ArrowFlight struct{}

func (*ArrowFlight) DoGet

func (*ArrowFlight) DoGet(ctx context.Context, table *handler.Table, r chan<- arrow.Record) error

DoGet should implement retrieval of records and sending them to the channel

func (*ArrowFlight) DoPut

func (*ArrowFlight) DoPut(ctx context.Context, r arrow.Record) error

DoPut should implement the insertion of a record

func (*ArrowFlight) LookupTable

func (*ArrowFlight) LookupTable(ctx context.Context, tableName string) (*handler.Table, error)

LookupTable should implement the retrieval of a table

type CloudQuery

type CloudQuery struct{}

func (*CloudQuery) DeleteRecord

func (*CloudQuery) DeleteRecord(ctx context.Context, msg message.WriteDeleteRecords) error

DeleteRecord should implement the deletion of a records

func (*CloudQuery) DeleteStale

func (*CloudQuery) DeleteStale(ctx context.Context, msg message.WriteDeleteStales) error

DeleteStale should implement the deletion of stale records

func (*CloudQuery) MigrateTable

func (*CloudQuery) MigrateTable(ctx context.Context, msg message.WriteMigrateTables) error

MigrateTable should implement the migration of a table