Documentation
¶
Index ¶
- func NewArrowFlight(path string) handler.ArrowFlightHandler
- type CloudQuery
- func (*CloudQuery) Close() error
- 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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewArrowFlight ¶
func NewArrowFlight(path string) handler.ArrowFlightHandler
Types ¶
type CloudQuery ¶
type CloudQuery struct{}
func (*CloudQuery) Close ¶
func (*CloudQuery) Close() error
Close should implement the closing of the handler
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
Source Files
Click to show internal directories.
Click to hide internal directories.