master

Documentation

Index

• Constants
• func AllNodes(search string, page, rows int) (e.List, error)
• func DefineNodes() error
• func DeleteNodeById(id string) (e.Item, error)
• func GetNodeById(id string) (e.Item, error)
• func InitMaster() error
• type Master
  • func (c *Master) GetNodeByID(id string) *Node
  • func (c *Master) GetSyncById(idT string) (e.Item, error)
  • func (c *Master) LoadNode(params e.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 e.Json, query string) (int, error)
  • func (c *Master) UnloadNodeById(id string) error
• type Node
  • func NewNode(params *e.Json) (*Node, error)
  • func (c *Node) DelSyncByIndex(index int) error
  • func (c *Node) GetSyncByIdT(idT string) (e.Item, error)
  • func (c *Node) InsertValues(data e.Json) (fields, values string)
  • func (c *Node) LatIndex() int
  • func (n *Node) Scan(data *e.Json) error
  • func (c *Node) SqlField(schema, table string, data e.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 e.Json, action string, _index int) error
  • func (c *Node) ToSql(schema, table, idT string, data e.Json, action string) (string, bool)
  • func (c *Node) UpsertValues(data e.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) (e.List, error)

func DefineNodes

func DefineNodes() error

func DeleteNodeById

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

func GetNodeById

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

* * Mode * Handler for CRUD data

func InitMaster

func InitMaster() 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) (e.Item, error)

func (*Master) LoadNode

func (c *Master) LoadNode(params e.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 e.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        e.Json    `json:"_data"`
	Status      int       `json:"status"`
	Index       int       `json:"index"`
	Synced      *core.Collection
}

func NewNode

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

func (*Node) DelSyncByIndex

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

func (*Node) GetSyncByIdT

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

func (*Node) InsertValues

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

func (*Node) LatIndex

func (c *Node) LatIndex() int

func (*Node) Scan

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

func (*Node) SqlField

func (c *Node) SqlField(schema, table string, data e.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 e.Json, action string, _index int) error

func (*Node) ToSql

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

func (*Node) UpsertValues

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