node

Documentation

Index

• func Validator(cv reflect.Value) (bool, error)
• type GlobalConfig
  • func LoadConfig(file string) *GlobalConfig
• type Node
  • func NewNode(logger *zap.Logger, globalConfig *GlobalConfig) *Node
  • func (n *Node) Start()
  • func (n *Node) Stop()
  • func (n *Node) Wait()

Functions

func Validator

func Validator(cv reflect.Value) (bool, error)

Types

type GlobalConfig

type GlobalConfig struct {
	Title            string `required:"true"`
	Log              zap.Config
	Mysql            dao.MysqlOptions
	Redis            redis.RedisOptions
	OrderManager     ordermanager.OrderManagerOptions
	Gateway          gateway.GateWayOptions
	Accessor         accessor.AccessorOptions
	LoopringProtocol loopringaccessor.LoopringProtocolOptions
	Market           util.MarketOptions
	MarketCap        marketcap.MarketCapOptions
	GatewayFilters   gateway.GatewayFiltersOptions
	UserManager      usermanager.UserManagerOptions
	ZkLock           zklock.ZkLockConfig
	Sns              sns.SnsConfig
	Kafka            kafka.KafkaOptions
	MotanServer      motan.MotanServerOptions
	Jsonrpc          gateway.JsonrpcOptions
	Websocket        gateway.WebsocketOptions
	AccountManager   accountmanager.AccountManagerOptions
	MyToken          market.MyTokenConfig
}

func LoadConfig

func LoadConfig(file string) *GlobalConfig

type Node

type Node struct {
	// contains filtered or unexported fields
}

func NewNode

func NewNode(logger *zap.Logger, globalConfig *GlobalConfig) *Node

func (*Node) Start

func (n *Node) Start()

func (*Node) Stop

func (n *Node) Stop()

todo release zklock and kafka producers and consumers

func (*Node) Wait

func (n *Node) Wait()