command

Documentation

Index

• Constants
• Variables
• func DataTypeToSQL(dtype DataType, typeSize int64) string
• func DataTypeToSQLNew(dtype DataType, typeSize int64) (string, int64)
• func SQLEncodeData(data interface{}, datatype DataType, semtype string) string
• type Command
  • func NewCommand(ce *change.Event, schemaPassFilter []*regexp.Regexp, schemaPrefix string) (*Command, error)
  • func (c Command) String() string
• type CommandColumn
• type CommandList
• type DataType
  • func MakeDataType(dtype string) DataType
  • func MakeDataTypeNew(dataType string, charMaxLen int64) (DataType, int64)
  • func (d DataType) String() string
• type Operation
  • func (o Operation) String() string

Constants

const (
	UnknownType = iota
	VarcharType
	IntegerType
	FloatType
	BooleanType
	DateType
	TimeType
	TimetzType
	TimestampType
	TimestamptzType
	JSONType
)

Variables

var Tenants []string

Functions

func DataTypeToSQL

func DataTypeToSQL(dtype DataType, typeSize int64) string

func DataTypeToSQLNew

func DataTypeToSQLNew(dtype DataType, typeSize int64) (string, int64)

func SQLEncodeData

func SQLEncodeData(data interface{}, datatype DataType, semtype string) string

Types

type Command

type Command struct {
	Op              Operation
	SchemaName      string
	TableName       string
	Origin          string
	Column          []CommandColumn
	ChangeEvent     *change.Event
	SourceTimestamp string
}

func NewCommand

func NewCommand(ce *change.Event, schemaPassFilter []*regexp.Regexp, schemaPrefix string) (*Command, error)

Returns nil, nil in some cases.

func (Command) String

func (c Command) String() string

type CommandColumn

type CommandColumn struct {
	Name         string
	DType        DataType
	DTypeSize    int64
	SemanticType string
	Data         interface{}
	EncodedData  string
	PrimaryKey   int
}

type CommandList

type CommandList struct {
	Cmd []Command
}

type DataType

type DataType int

func MakeDataType

func MakeDataType(dtype string) DataType

func MakeDataTypeNew

func MakeDataTypeNew(dataType string, charMaxLen int64) (DataType, int64)

func (DataType) String

func (d DataType) String() string

type Operation

type Operation int

const (
	MergeOp Operation = iota
	DeleteOp
)

func (Operation) String

func (o Operation) String() string