message

Documentation

Index

• type DeleteRecord
• type Predicate
• type PredicateGroup
• type PredicateGroups
• type Predicates
• type SyncDeleteRecord
  • func (m SyncDeleteRecord) GetTable() *schema.Table
  • func (*SyncDeleteRecord) IsSyncMessage() bool
• type SyncInsert
  • func (m *SyncInsert) GetTable() *schema.Table
  • func (*SyncInsert) IsSyncMessage() bool
• type SyncInserts
  • func (m SyncInserts) Exists(tableName string) bool
  • func (m SyncInserts) GetRecords() []arrow.Record
  • func (m SyncInserts) GetRecordsForTable(table *schema.Table) []arrow.Record
• type SyncMessage
• type SyncMessages
  • func (messages SyncMessages) GetInserts() SyncInserts
  • func (messages SyncMessages) InsertItems() int64
• type SyncMigrateTable
  • func (m SyncMigrateTable) GetTable() *schema.Table
  • func (*SyncMigrateTable) IsSyncMessage() bool
• type SyncMigrateTables
  • func (m SyncMigrateTables) Exists(tableName string) bool
• type TableRelation
• type TableRelations
• type WriteDeleteRecord
  • func (m WriteDeleteRecord) GetTable() *schema.Table
  • func (*WriteDeleteRecord) IsWriteMessage() bool
• type WriteDeleteRecords
• type WriteDeleteStale
  • func (m WriteDeleteStale) GetTable() *schema.Table
  • func (*WriteDeleteStale) IsWriteMessage() bool
• type WriteDeleteStales
  • func (m WriteDeleteStales) Exists(tableName string) bool
• type WriteInsert
  • func (m *WriteInsert) GetTable() *schema.Table
  • func (*WriteInsert) IsWriteMessage() bool
• type WriteInserts
  • func (m WriteInserts) Exists(tableName string) bool
  • func (m WriteInserts) GetRecords() []arrow.Record
  • func (m WriteInserts) GetRecordsForTable(table *schema.Table) []arrow.Record
• type WriteMessage
• type WriteMessages
  • func (messages WriteMessages) GetInserts() WriteInserts
  • func (messages WriteMessages) InsertItems() int64
• type WriteMigrateTable
  • func (m WriteMigrateTable) GetTable() *schema.Table
  • func (*WriteMigrateTable) IsWriteMessage() bool
• type WriteMigrateTables
  • func (m WriteMigrateTables) Exists(tableName string) bool
  • func (m WriteMigrateTables) GetMessageByTable(tableName string) *WriteMigrateTable

Types

type DeleteRecord

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

type Predicate

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

type PredicateGroup

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

type PredicateGroups

type PredicateGroups []PredicateGroup

type Predicates

type Predicates []Predicate

type SyncDeleteRecord

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
}

func (SyncDeleteRecord) GetTable

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

func (*SyncDeleteRecord) IsSyncMessage

func (*SyncDeleteRecord) IsSyncMessage() bool

type SyncInsert

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

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) GetRecords

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

func (SyncInserts) GetRecordsForTable

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

Get all records for a single table

type SyncMessage

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

type SyncMessages

type SyncMessages []SyncMessage

func (SyncMessages) GetInserts

func (messages SyncMessages) GetInserts() SyncInserts

func (SyncMessages) InsertItems

func (messages SyncMessages) InsertItems() int64

type SyncMigrateTable

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

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 TableRelation

type TableRelation struct {
	TableName   string
	ParentTable string
}

type TableRelations

type TableRelations []TableRelation

type WriteDeleteRecord

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

func (WriteDeleteRecord) GetTable

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

func (*WriteDeleteRecord) IsWriteMessage

func (*WriteDeleteRecord) IsWriteMessage() bool

type WriteDeleteRecords

type WriteDeleteRecords []*WriteDeleteRecord

type WriteDeleteStale

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

WriteDeleteStale 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 indicates 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 WriteDeleteStales

type WriteDeleteStales []*WriteDeleteStale

func (WriteDeleteStales) Exists

func (m WriteDeleteStales) Exists(tableName string) bool

type WriteInsert

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

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) GetRecords

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

func (WriteInserts) GetRecordsForTable

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

type WriteMessage

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

type WriteMessages

type WriteMessages []WriteMessage

func (WriteMessages) GetInserts

func (messages WriteMessages) GetInserts() WriteInserts

func (WriteMessages) InsertItems

func (messages WriteMessages) InsertItems() int64

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

func (WriteMigrateTables) GetMessageByTable

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