converter

Documentation

Index

• type Converter
  • func New(filePath string, sqlDb *sql.DB) (*Converter, error)
  • func (conv *Converter) Close()
  • func (conv *Converter) FullName() string
  • func (conv *Converter) Inserted(doc Document) error
  • func (conv *Converter) ProcessOplogRecord(oplogRecord Document) error
• type Document
• type Map
  • func LoadAll(sqlDb *sql.DB) (Map, error)
  • func (converters Map) Names() []string

Types

type Converter

type Converter struct {
	DbName   string
	ColName  string
	LuaState *lua.LState
	// contains filtered or unexported fields
}

Converter load LUA for handle mongo opload record

func New

func New(filePath string, sqlDb *sql.DB) (*Converter, error)

New create new converter

func (*Converter) Close

func (conv *Converter) Close()

Close converter (LuaState)

func (*Converter) FullName

func (conv *Converter) FullName() string

FullName return databse name + collection name

func (*Converter) Inserted

func (conv *Converter) Inserted(doc Document) error

Inserted handler new records

func (*Converter) ProcessOplogRecord

func (conv *Converter) ProcessOplogRecord(oplogRecord Document) error

ProcessOplogRecord accept oplog record and process with operation callback

type Document

type Document map[string]interface{}

Document is record of oplog collection

type Map

type Map map[string]*Converter

Map string to Converter

func LoadAll

func LoadAll(sqlDb *sql.DB) (Map, error)

LoadAll converters

func (Map) Names

func (converters Map) Names() []string

Names of converter collections