Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type SyncInsert ¶
func (*SyncInsert) GetTable ¶
func (m *SyncInsert) GetTable() *schema.Table
func (*SyncInsert) IsSyncMessage ¶
func (*SyncInsert) IsSyncMessage() bool
type SyncInserts ¶
type SyncInserts []*SyncInsert
func (SyncInserts) Exists ¶
func (m SyncInserts) Exists(tableName string) bool
func (SyncInserts) GetRecordsForTable ¶
func (m SyncInserts) GetRecordsForTable(table *schema.Table) []arrow.Record
type SyncMessage ¶
type SyncMessages ¶
type SyncMessages []SyncMessage
func (SyncMessages) InsertItems ¶
func (messages SyncMessages) InsertItems() int64
func (SyncMessages) InsertMessage ¶
func (messages SyncMessages) InsertMessage() SyncInserts
type SyncMigrateTable ¶
func (SyncMigrateTable) GetTable ¶
func (m SyncMigrateTable) GetTable() *schema.Table
func (*SyncMigrateTable) IsSyncMessage ¶
func (*SyncMigrateTable) IsSyncMessage() bool
type SyncMigrateTables ¶
type SyncMigrateTables []*SyncMigrateTable
func (SyncMigrateTables) Exists ¶
func (m SyncMigrateTables) Exists(tableName string) bool
type WriteDeleteStale ¶
type WriteDeleteStale struct { Table *schema.Table SourceName string SyncTime time.Time // contains filtered or unexported fields }
DeleteStale is a pretty specific message which requires the destination to be aware of a CLI use-case thus it might be deprecated in the future in favour of MessageDelete or MessageRawQuery The message indeciates that the destination needs to run something like "DELETE FROM table WHERE _cq_source_name=$1 and sync_time < $2"
func (WriteDeleteStale) GetTable ¶
func (m WriteDeleteStale) GetTable() *schema.Table
func (*WriteDeleteStale) IsWriteMessage ¶
func (*WriteDeleteStale) IsWriteMessage() bool
type WriteInsert ¶
func (*WriteInsert) GetTable ¶
func (m *WriteInsert) GetTable() *schema.Table
func (*WriteInsert) IsWriteMessage ¶
func (*WriteInsert) IsWriteMessage() bool
type WriteInserts ¶
type WriteInserts []*WriteInsert
func (WriteInserts) Exists ¶
func (m WriteInserts) Exists(tableName string) bool
func (WriteInserts) GetRecordsForTable ¶
func (m WriteInserts) GetRecordsForTable(table *schema.Table) []arrow.Record
type WriteMessage ¶
type WriteMessages ¶
type WriteMessages []WriteMessage
func (WriteMessages) InsertItems ¶
func (messages WriteMessages) InsertItems() int64
func (WriteMessages) InsertMessage ¶
func (messages WriteMessages) InsertMessage() WriteInserts
type WriteMigrateTable ¶
type WriteMigrateTable struct { Table *schema.Table MigrateForce bool // contains filtered or unexported fields }
func (WriteMigrateTable) GetTable ¶
func (m WriteMigrateTable) GetTable() *schema.Table
func (*WriteMigrateTable) IsWriteMessage ¶
func (*WriteMigrateTable) IsWriteMessage() bool
type WriteMigrateTables ¶
type WriteMigrateTables []*WriteMigrateTable
func (WriteMigrateTables) Exists ¶
func (m WriteMigrateTables) Exists(tableName string) bool
Click to show internal directories.
Click to hide internal directories.