sraplica

package

v0.0.0-...-ffdd182 Latest Latest Go to latest Published: Nov 26, 2019 License: GPL-3.0 Imports: 15 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/hhh9786/gosanitized

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
func Delete(cLog *ChangeLog)
func ErrorLog(err error) error
func ErrorPanic(err error)
func GetDestConfig() *mysql.Config
func GetSourceConfig() *mysql.Config
func InitDestDb() *sql.DB
func InitRaplication()
func InitSync()
func Insert(cLog *ChangeLog)
func SchemaAltered(b []byte)
func Update(cLog *ChangeLog)
type AssociateArray
type ChangeLog
type Column
type IndexedArray
type MyEvent
type MyEventHandler
- func (h *MyEventHandler) OnDDL(nextPos m.Position, queryEvent *replication.QueryEvent) error
- func (h *MyEventHandler) OnRow(e *c.RowsEvent) error
type SensitiveTables
- func GetTablesToFilter(confDir string) SensitiveTables
type Table

Constants ¶

This section is empty.

Variables ¶

View Source

var DestConfig *mysql.Config

View Source

var DestDb *sql.DB

View Source

var SourceConfig *mysql.Config

Functions ¶

func Delete ¶

func Delete(cLog *ChangeLog)

func ErrorLog ¶

func ErrorLog(err error) error

func ErrorPanic ¶

func ErrorPanic(err error)

ErrorPanic -

func GetDestConfig ¶

func GetDestConfig() *mysql.Config

GetSourceConfig - gets config variables from environment variables or die

func GetSourceConfig ¶

func GetSourceConfig() *mysql.Config

GetSourceConfig - gets config variables from environment variables or die

func InitDestDb ¶

func InitDestDb() *sql.DB

func InitRaplication ¶

func InitRaplication()

func InitSync ¶

func InitSync()

func Insert ¶

func Insert(cLog *ChangeLog)

func SchemaAltered ¶

func SchemaAltered(b []byte)

func Update ¶

func Update(cLog *ChangeLog)

Types ¶

type AssociateArray ¶

type AssociateArray map[string]interface{}

AssociateArray -

type ChangeLog ¶

type ChangeLog struct {
	BinlogTimestamp uint32
	Keys            AssociateArray
	Timestamp       int64
	TableName       string
	ChangeType      string
	Columns         AssociateArray
}

ChangeLog -

type Column ¶

type Column struct {
	Value  string
	Custom bool
}

type IndexedArray ¶

type IndexedArray []interface{}

IndexedArray -

type MyEvent ¶

type MyEvent struct {
	c.RowsEvent
}

MyEvent struct

type MyEventHandler ¶

type MyEventHandler struct {
	c.DummyEventHandler
}

MyEventHandler struct

func (*MyEventHandler) OnDDL ¶

func (h *MyEventHandler) OnDDL(nextPos m.Position, queryEvent *replication.QueryEvent) error

OnDDL will handle schema changes

func (*MyEventHandler) OnRow ¶

func (h *MyEventHandler) OnRow(e *c.RowsEvent) error

type SensitiveTables ¶

type SensitiveTables map[string]*Table

var Tables SensitiveTables

func GetTablesToFilter ¶

func GetTablesToFilter(confDir string) SensitiveTables

type Table ¶

type Table struct {
	Name string
	Cols map[string]*Column
}

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL