message

package
v4.44.1 Latest Latest
Warning

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

 Go to latest Published: May 31, 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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.