message

type DeleteRecord struct {
	TableName      string
	TableRelations TableRelations
	WhereClause    PredicateGroups
	SyncTime       time.Time
}

type Predicate struct {
	Operator string
	Column   string
	Record   arrow.RecordBatch
}

type PredicateGroup struct {
	// This will be AND or OR
	GroupingType string
	Predicates   Predicates
}

type PredicateGroups []PredicateGroup

type Predicates []Predicate

type SyncDeleteRecord struct {

	// TODO: Instead of using this struct we should derive the DeletionKeys and parent/child relation from the schema.Table itself
	DeleteRecord
	// contains filtered or unexported fields
}

type SyncError struct {
	TableName string
	Error     string
	// contains filtered or unexported fields
}

type SyncInsert struct {
	Record arrow.RecordBatch
	// contains filtered or unexported fields
}

type SyncInserts []*SyncInsert

type SyncMessage interface {
	GetTable() *schema.Table
	IsSyncMessage() bool
}

type SyncMessages []SyncMessage

type SyncMigrateTable struct {
	Table *schema.Table
	// contains filtered or unexported fields
}

type SyncMigrateTables []*SyncMigrateTable

type TableRelation struct {
	TableName   string
	ParentTable string
}

type TableRelations []TableRelation

type WriteDeleteRecord struct {
	DeleteRecord
	// contains filtered or unexported fields
}

type WriteDeleteRecords []*WriteDeleteRecord

type WriteDeleteStale struct {
	TableName  string
	SourceName string
	SyncTime   time.Time
	// contains filtered or unexported fields
}

type WriteDeleteStales []*WriteDeleteStale

type WriteInsert struct {
	Record arrow.RecordBatch
	// contains filtered or unexported fields
}

type WriteInserts []*WriteInsert

type WriteMessage interface {
	GetTable() *schema.Table
	IsWriteMessage() bool
}

type WriteMessages []WriteMessage

type WriteMigrateTable struct {
	Table        *schema.Table
	MigrateForce bool
	// contains filtered or unexported fields
}

type WriteMigrateTables []*WriteMigrateTable