utils

Documentation

Index

• Variables
• func E36() *big.Int
• func Ethers(value int64) *big.Int
• func GetOHLCVChannelID(bt, qt common.Address, unit string, duration int64) string
• func GetOrderBookChannelID(bt, qt common.Address) string
• func GetPairKey(bt, qt common.Address) string
• func GetTickChannelID(bt, qt common.Address, unit string, duration int64) string
• func GetTradeChannelID(bt, qt common.Address) string
• func JSON(x interface{}) string
• func MaxIntMap(m map[string]int) (string, int)
• func NewColoredLogger() *logging.Logger
• func NewErrorLogger() *logging.Logger
• func NewFileLogger(module string, logFile string) *logging.Logger
• func NewLogger(module string, logFile string) *logging.Logger
• func NewMainLogger() *logging.Logger
• func NewStandardOutputLogger() *logging.Logger
• func PrintError(msg string, err error)
• func PrintJSON(x interface{})
• func Retry(retries int, fn func() error) error
• func ToDecimal(value *big.Int) float64
• func UintToPaddedString(num int64) string
• func Use(...interface{})

Variables

var APILogger = NewLogger("api", "./logs/api.log")

var EngineLogger = NewLogger("engine", "./logs/engine.log")

var ErrorLogger = NewErrorLogger()

var Logger = NewLogger("main", "./logs/main.log")

var MainLogger = NewMainLogger()

var OperatorMessagesLogger = NewFileLogger("operator", "./logs/operator.log")

var RabbitLogger = NewLogger("rabbitmq", "./logs/rabbit.log")

var StdoutLogger = NewStandardOutputLogger()

var TerminalLogger = NewColoredLogger()

var WebsocketMessagesLogger = NewFileLogger("websocket", "./logs/websocket.log")

Functions

func E36

func E36() *big.Int

func Ethers

func Ethers(value int64) *big.Int

func GetOHLCVChannelID

func GetOHLCVChannelID(bt, qt common.Address, unit string, duration int64) string

func GetOrderBookChannelID

func GetOrderBookChannelID(bt, qt common.Address) string

func GetPairKey

func GetPairKey(bt, qt common.Address) string

GetPairKey return the pair key identifier corresponding to two

func GetTickChannelID

func GetTickChannelID(bt, qt common.Address, unit string, duration int64) string

GetTickChannelID is used to get the channel id for OHLCV data streaming it takes pairname, duration and units of data streaming

func GetTradeChannelID

func GetTradeChannelID(bt, qt common.Address) string

func JSON

func JSON(x interface{}) string

func MaxIntMap

func MaxIntMap(m map[string]int) (string, int)

func NewColoredLogger

func NewColoredLogger() *logging.Logger

func NewErrorLogger

func NewErrorLogger() *logging.Logger

func NewFileLogger

func NewFileLogger(module string, logFile string) *logging.Logger

NewFileLogger creates a logging utility that outputs to the file passed as argument but but does not output to stdout.

func NewLogger

func NewLogger(module string, logFile string) *logging.Logger

func NewMainLogger

func NewMainLogger() *logging.Logger

func NewStandardOutputLogger

func NewStandardOutputLogger() *logging.Logger

func PrintError

func PrintError(msg string, err error)

func PrintJSON

func PrintJSON(x interface{})

func Retry

func Retry(retries int, fn func() error) error

func ToDecimal

func ToDecimal(value *big.Int) float64

func UintToPaddedString

func UintToPaddedString(num int64) string

UintToPaddedString converts an int to string of length 19 by padding with 0

func Use

func Use(...interface{})

Util function to handle unused variables while testing