message

Documentation

Index

• type DeleteStale
  • func (m DeleteStale) GetTable() *schema.Table
• type Insert
  • func (m *Insert) GetTable() *schema.Table
• type Inserts
  • func (m Inserts) Exists(tableName string) bool
  • func (m Inserts) GetRecordsForTable(table *schema.Table) []arrow.Record
• type Message
• type Messages
  • func (messages Messages) InsertItems() int64
  • func (messages Messages) InsertMessage() Inserts
• type MigrateTable
  • func (m MigrateTable) GetTable() *schema.Table
• type MigrateTables
  • func (m MigrateTables) Exists(tableName string) bool

Types

type DeleteStale

type DeleteStale struct {
	Table      *schema.Table
	SourceName string
	SyncTime   time.Time
}

DeleteStale 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 indeciates that the destination needs to run something like "DELETE FROM table WHERE _cq_source_name=$1 and sync_time < $2"

func (DeleteStale) GetTable

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

type Insert

type Insert struct {
	Record arrow.Record
}

func (*Insert) GetTable

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

type Inserts

type Inserts []*Insert

func (Inserts) Exists

func (m Inserts) Exists(tableName string) bool

func (Inserts) GetRecordsForTable

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

type Message

type Message interface {
	GetTable() *schema.Table
}

type Messages

type Messages []Message

func (Messages) InsertItems

func (messages Messages) InsertItems() int64

func (Messages) InsertMessage

func (messages Messages) InsertMessage() Inserts

type MigrateTable

type MigrateTable struct {
	Table *schema.Table
}

func (MigrateTable) GetTable

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

type MigrateTables

type MigrateTables []*MigrateTable

func (MigrateTables) Exists

func (m MigrateTables) Exists(tableName string) bool