core

type ActionType string

type DDLActionType string

type DDLMsg struct {
	Action       DDLActionType
	NewTable     metas.Table
	DdlStatement metas.DdlStatement
}

type DMLMsg struct {
	Action       ActionType
	Data         map[string]interface{}
	Old          map[string]interface{}
	TableVersion uint
}

type Input interface {
	NewInput(metas *Metas)
	Start(pos Position, in chan *Msg)
	Close()
}

type InputMeta interface {
	LoadMeta(routers []*metas.Router) error
	GetMeta(*metas.Router) (*metas.Table, error)
	// GetAll() map[string]*metas.Table
	GetVersion(schema string, tableName string, version uint) (*metas.Table, error)
	// Add(*metas.Table) error
	// Update(newTable *metas.Table) error
	// Delete(string, string) error
	Save() error
	Close()
}

type Metas struct {
	Input   InputMeta
	Output  OutputMeta
	Routers *metas.Routers
}

type Msg struct {
	Database     string
	Table        string
	Type         MsgType
	DmlMsg       *DMLMsg
	Timestamp    time.Time
	InputContext struct {
		Pos string
	}
}

type MsgType string

type Output interface {
	NewOutput(metas *Metas)
	Start(out chan *Msg, pos Position)
	Close()
}

type OutputMeta interface {
	LoadMeta(routers []*metas.Router) error
	GetMeta(*metas.Router) (interface{}, error)
	// GetAll() map[string]*metas.Table
	// GetVersion(schema string, tableName string, version uint) (*metas.Table, error)
	// Add(*metas.Table) error
	// Update(newTable *metas.Table) error
	// Delete(string, string) error
	Save() error
	Close()
}

type Position interface {
	LoadPosition(name string) string
	Start()
	Update(v string) error
	Save() error
	Get() string
	Close()
}

type Transform interface {
	NewTransform(config map[string]interface{}) error
	Transform(msg *Msg) bool
}