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
}

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