message

package
v4.61.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 3, 2024 License: MPL-2.0 Imports: 4 Imported by: 91

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type DeleteRecord added in v4.13.0

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

type Predicate added in v4.13.0

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

type PredicateGroup added in v4.13.0

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

type PredicateGroups added in v4.13.0

type PredicateGroups []PredicateGroup

type Predicates added in v4.13.0

type Predicates []Predicate

type SyncDeleteRecord added in v4.13.0

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 added in v4.13.0

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

func (*SyncDeleteRecord) IsSyncMessage added in v4.13.0

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 added in v4.13.0

type TableRelation struct {
	TableName   string
	ParentTable string
}

type TableRelations added in v4.13.0

type TableRelations []TableRelation

type WriteDeleteRecord added in v4.13.0

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

func (WriteDeleteRecord) GetTable added in v4.13.0

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

func (*WriteDeleteRecord) IsWriteMessage added in v4.13.0

func (*WriteDeleteRecord) IsWriteMessage() bool

type WriteDeleteRecords added in v4.13.0

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL