message

Oct 16, 2023

Changes in this version

+ type DeleteRecord struct

+ SyncTime time.Time

+ TableName string

+ TableRelations TableRelations

+ WhereClause PredicateGroups

+ type Predicate struct

+ Column string

+ Operator string

+ Record arrow.Record

+ type PredicateGroup struct

+ GroupingType string

+ Predicates Predicates

+ type PredicateGroups []PredicateGroup

+ type Predicates []Predicate

+ type SyncDeleteRecord struct

+ func (*SyncDeleteRecord) IsSyncMessage() bool

+ func (m SyncDeleteRecord) GetTable() *schema.Table

+ type TableRelation struct

+ ParentTable string

+ TableName string

+ type TableRelations []TableRelation

+ type WriteDeleteRecord struct

+ func (*WriteDeleteRecord) IsWriteMessage() bool

+ func (m WriteDeleteRecord) GetTable() *schema.Table

+ type WriteDeleteRecords []*WriteDeleteRecord

Jul 12, 2023

Changes in this version

+ type SyncInsert struct

+ Record arrow.Record

+ func (*SyncInsert) IsSyncMessage() bool

+ func (m *SyncInsert) GetTable() *schema.Table

+ type SyncInserts []*SyncInsert

+ func (m SyncInserts) Exists(tableName string) bool

+ func (m SyncInserts) GetRecords() []arrow.Record

+ func (m SyncInserts) GetRecordsForTable(table *schema.Table) []arrow.Record

+ type SyncMessage interface

+ GetTable func() *schema.Table

+ IsSyncMessage func() bool

+ type SyncMessages []SyncMessage

+ func (messages SyncMessages) GetInserts() SyncInserts

+ func (messages SyncMessages) InsertItems() int64

+ type SyncMigrateTable struct

+ Table *schema.Table

+ func (*SyncMigrateTable) IsSyncMessage() bool

+ func (m SyncMigrateTable) GetTable() *schema.Table

+ type SyncMigrateTables []*SyncMigrateTable

+ func (m SyncMigrateTables) Exists(tableName string) bool

+ type WriteDeleteStale struct

+ SourceName string

+ SyncTime time.Time

+ TableName string

+ func (*WriteDeleteStale) IsWriteMessage() bool

+ func (m WriteDeleteStale) GetTable() *schema.Table

+ type WriteDeleteStales []*WriteDeleteStale

+ func (m WriteDeleteStales) Exists(tableName string) bool

+ type WriteInsert struct

+ Record arrow.Record

+ func (*WriteInsert) IsWriteMessage() bool

+ func (m *WriteInsert) GetTable() *schema.Table

+ type WriteInserts []*WriteInsert

+ func (m WriteInserts) Exists(tableName string) bool

+ func (m WriteInserts) GetRecords() []arrow.Record

+ func (m WriteInserts) GetRecordsForTable(table *schema.Table) []arrow.Record

+ type WriteMessage interface

+ GetTable func() *schema.Table

+ IsWriteMessage func() bool

+ type WriteMessages []WriteMessage

+ func (messages WriteMessages) GetInserts() WriteInserts

+ func (messages WriteMessages) InsertItems() int64

+ type WriteMigrateTable struct

+ MigrateForce bool

+ Table *schema.Table

+ func (*WriteMigrateTable) IsWriteMessage() bool

+ func (m WriteMigrateTable) GetTable() *schema.Table

+ type WriteMigrateTables []*WriteMigrateTable

+ func (m WriteMigrateTables) Exists(tableName string) bool

+ func (m WriteMigrateTables) GetMessageByTable(tableName string) *WriteMigrateTable