master

Documentation

Index

• Constants
• func AllNodes(search string, page, rows int) (et.List, error)
• func DefineNodes() error
• func DeleteNodeById(id string) (et.Item, error)
• func GetNodeById(id string) (et.Item, error)
• func InitDefine() error
• func UpSertNode(id string, mode int, driver, host string, port int, ...) (et.Item, error)
• type Master
  • func (c *Master) GetNodeByID(id string) *Node
  • func (c *Master) GetSyncById(idT string) (et.Item, error)
  • func (c *Master) LoadNode(params et.Json) error
  • func (c *Master) LoadNodeById(id string) error
  • func (c *Master) LoadNodes() error
  • func (c *Master) SetSync(schema, table, action, node, idT string, data et.Json, query string) (int, error)
  • func (c *Master) UnloadNodeById(id string) error
• type Node
  • func NewNode(params *et.Json) (*Node, error)
  • func (c *Node) DelSyncByIndex(index int) error
  • func (c *Node) GetSyncByIdT(idT string) (et.Item, error)
  • func (c *Node) InsertValues(data et.Json) (fields, values string)
  • func (c *Node) LatIndex() int
  • func (n *Node) Scan(data *et.Json) error
  • func (c *Node) SqlField(schema, table string, data et.Json) string
  • func (c *Node) SyncIdT(idT string) error
  • func (c *Node) SyncMasterToNode() error
  • func (c *Node) SyncNode() error
  • func (c *Node) SyncNodeToMaster() error
  • func (c *Node) SyncQuery(query string, index int) error
  • func (c *Node) SyncRecord(schema, table, idT string, _data et.Json, action string, _index int) error
  • func (c *Node) ToSql(schema, table, idT string, data et.Json, action string) (string, bool)
  • func (c *Node) UpsertValues(data et.Json) (fields, values, fieldValue string)

Constants

const NodeStatusActive = 1

const NodeStatusError = 4

const NodeStatusIdle = 0

const NodeStatusSync = 3

const NodeStatusWorking = 2

Functions

func AllNodes

func AllNodes(search string, page, rows int) (et.List, error)

func DefineNodes

func DefineNodes() error

func DeleteNodeById

func DeleteNodeById(id string) (et.Item, error)

func GetNodeById

func GetNodeById(id string) (et.Item, error)

* * Mode * Handler for CRUD data

func InitDefine

func InitDefine() error

func UpSertNode

func UpSertNode(id string, mode int, driver, host string, port int, dbname, user, password string) (et.Item, error)

Types

type Master

type Master struct {
	InitNodes  bool
	InitSecret bool
	Nodes      []Node
}

* * *

func (*Master) GetNodeByID

func (c *Master) GetNodeByID(id string) *Node

func (*Master) GetSyncById

func (c *Master) GetSyncById(idT string) (et.Item, error)

func (*Master) LoadNode

func (c *Master) LoadNode(params et.Json) error

func (*Master) LoadNodeById

func (c *Master) LoadNodeById(id string) error

func (*Master) LoadNodes

func (c *Master) LoadNodes() error

func (*Master) SetSync

func (c *Master) SetSync(schema, table, action, node, idT string, data et.Json, query string) (int, error)

func (*Master) UnloadNodeById

func (c *Master) UnloadNodeById(id string) error

type Node

type Node struct {
	Db          int
	URL         string
	Date_make   time.Time `json:"date_make"`
	Date_update time.Time `json:"date_update"`
	Id          string    `json:"_id"`
	Mode        int       `json:"mode"`
	Data        et.Json   `json:"_data"`
	Status      int       `json:"status"`
	Index       int       `json:"index"`
}

func NewNode

func NewNode(params *et.Json) (*Node, error)

func (*Node) DelSyncByIndex

func (c *Node) DelSyncByIndex(index int) error

func (*Node) GetSyncByIdT

func (c *Node) GetSyncByIdT(idT string) (et.Item, error)

func (*Node) InsertValues

func (c *Node) InsertValues(data et.Json) (fields, values string)

func (*Node) LatIndex

func (c *Node) LatIndex() int

func (*Node) Scan

func (n *Node) Scan(data *et.Json) error

func (*Node) SqlField

func (c *Node) SqlField(schema, table string, data et.Json) string

func (*Node) SyncIdT

func (c *Node) SyncIdT(idT string) error

func (*Node) SyncMasterToNode

func (c *Node) SyncMasterToNode() error

func (*Node) SyncNode

func (c *Node) SyncNode() error

func (*Node) SyncNodeToMaster

func (c *Node) SyncNodeToMaster() error

func (*Node) SyncQuery

func (c *Node) SyncQuery(query string, index int) error

func (*Node) SyncRecord

func (c *Node) SyncRecord(schema, table, idT string, _data et.Json, action string, _index int) error

func (*Node) ToSql

func (c *Node) ToSql(schema, table, idT string, data et.Json, action string) (string, bool)

func (*Node) UpsertValues

func (c *Node) UpsertValues(data et.Json) (fields, values, fieldValue string)