Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ArrowFlight ¶
type ArrowFlight struct{}
func (*ArrowFlight) DoGet ¶
DoGet should implement retrieval of records and sending them to the channel
func (*ArrowFlight) LookupTable ¶
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
Click to show internal directories.
Click to hide internal directories.