utils

Documentation

Index

• Constants
• func CommonAddressHexRepair(address *common.Address) string
• func ErrIsDuplicateEntryError(err error) bool
• func ErrIsLockError(err error) bool
• func ForceParseTimeParam(dsn string) (string, error)
• type Collector
  • func NewCollectors(collectors ...Collector) Collector
  • func NewCounterIncCollect(key string) Collector
  • func NewCounterObserveMillisCollect(key string) Collector
  • func NewHistogramCollect(key string) Collector
  • func NewSuccessFailCounterAdd(keySuccess string, keyFail string, count float64) Collector
  • func NewSuccessFailCounterInc(keySuccess string, keyFail string) Collector
• type Conn
  • func New(eventer *EventRcvr, conf cfg.DB, ro bool) (*Conn, error)
  • func (c *Conn) Close(context.Context) error
  • func (c *Conn) NewSession(name string, timeout time.Duration) (*dbr.Session, error)
  • func (c *Conn) NewSessionForEventReceiver(er dbr.EventReceiver) *dbr.Session
  • func (c *Conn) SetConnMaxIdleTime(d time.Duration)
  • func (c *Conn) SetConnMaxLifetime(d time.Duration)
  • func (c *Conn) SetMaxIdleConns(n int)
  • func (c *Conn) SetMaxOpenConns(n int)
• type Connections
  • func NewDBFromConfig(conf cfg.Services, ro bool) (*Connections, error)
  • func (c Connections) Close() error
  • func (c Connections) DB() *Conn
  • func (c Connections) Stream() *EventRcvr
• type CounterID
  • func NewCounterID() *CounterID
  • func (c *CounterID) Add(v string, delta int64)
  • func (c *CounterID) Clone() map[string]int64
  • func (c *CounterID) Inc(v string)
• type EventRcvr
  • func (e *EventRcvr) NewJob(s string) dbr.EventReceiver
  • func (e *EventRcvr) SetLog(logger logging.Logger)
• type ExecIface
• type GenesisContainer
  • func NewGenesisContainer(networkID uint32) (*GenesisContainer, error)
• type IndexedList
  • func NewIndexedList(maxSize int) IndexedList
• type LCache
  • func NewTTLMap() *LCache
  • func (m *LCache) Get(k string) ([]byte, bool)
  • func (m *LCache) Put(k string, v []byte, ttl time.Duration)
  • func (m *LCache) Stop()
• type ListenCloser
• type Metrics
  • func (m *Metrics) CounterAdd(name string, v float64) error
  • func (m *Metrics) CounterInc(name string) error
  • func (m *Metrics) CounterInit(name string, help string)
  • func (m *Metrics) HistogramInit(name string, help string, buckets []float64)
  • func (m *Metrics) HistogramObserve(name string, v float64) error
  • func (m *Metrics) Init()
• type RetrySleeper
  • func NewRetrySleeper(retries uint64, sleepDuration time.Duration, sleepDurationMax time.Duration) *RetrySleeper
  • func (r *RetrySleeper) Inc()
• type Running
  • func NewRunning() Running
• type Worker
  • func NewWorker(queueSize int, queueCnt int, processor func(int, interface{})) Worker

Constants

const (
	DriverMysql     = "mysql"
	DriverNone      = ""
	RequiredVersion = 47
)

const (
	DeadlockDBErrorMessage = "Deadlock found when trying to get lock; try restarting transaction"
	TimeoutDBErrorMessage  = "Lock wait timeout exceeded; try restarting transaction"
)

const (
	KeyValueBootstrap = "bootstrap"
)

Functions

func CommonAddressHexRepair

func CommonAddressHexRepair(address *common.Address) string

func ErrIsDuplicateEntryError

func ErrIsDuplicateEntryError(err error) bool

func ErrIsLockError

func ErrIsLockError(err error) bool

func ForceParseTimeParam

func ForceParseTimeParam(dsn string) (string, error)

Types

type Collector

type Collector interface {
	Error()
	Collect() error
}

func NewCollectors

func NewCollectors(collectors ...Collector) Collector

func NewCounterIncCollect

func NewCounterIncCollect(key string) Collector

func NewCounterObserveMillisCollect

func NewCounterObserveMillisCollect(key string) Collector

func NewHistogramCollect

func NewHistogramCollect(key string) Collector

func NewSuccessFailCounterAdd

func NewSuccessFailCounterAdd(keySuccess string, keyFail string, count float64) Collector

func NewSuccessFailCounterInc

func NewSuccessFailCounterInc(keySuccess string, keyFail string) Collector

type Conn

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

Conn is a wrapper around a dbr connection and a health stream

func New

func New(eventer *EventRcvr, conf cfg.DB, ro bool) (*Conn, error)

New creates a new DB for the given config

func (*Conn) Close

func (c *Conn) Close(context.Context) error

func (*Conn) NewSession

func (c *Conn) NewSession(name string, timeout time.Duration) (*dbr.Session, error)

func (*Conn) NewSessionForEventReceiver

func (c *Conn) NewSessionForEventReceiver(er dbr.EventReceiver) *dbr.Session

func (*Conn) SetConnMaxIdleTime

func (c *Conn) SetConnMaxIdleTime(d time.Duration)

func (*Conn) SetConnMaxLifetime

func (c *Conn) SetConnMaxLifetime(d time.Duration)

func (*Conn) SetMaxIdleConns

func (c *Conn) SetMaxIdleConns(n int)

func (*Conn) SetMaxOpenConns

func (c *Conn) SetMaxOpenConns(n int)

type Connections

type Connections struct {
	Eventer *EventRcvr
	// contains filtered or unexported fields
}

func NewDBFromConfig

func NewDBFromConfig(conf cfg.Services, ro bool) (*Connections, error)

func (Connections) Close

func (c Connections) Close() error

func (Connections) DB

func (c Connections) DB() *Conn

func (Connections) Stream

func (c Connections) Stream() *EventRcvr

type CounterID

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

func NewCounterID

func NewCounterID() *CounterID

func (*CounterID) Add

func (c *CounterID) Add(v string, delta int64)

func (*CounterID) Clone

func (c *CounterID) Clone() map[string]int64

func (*CounterID) Inc

func (c *CounterID) Inc(v string)

type EventRcvr

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

func (*EventRcvr) NewJob

func (e *EventRcvr) NewJob(s string) dbr.EventReceiver

func (*EventRcvr) SetLog

func (e *EventRcvr) SetLog(logger logging.Logger)

type ExecIface

type ExecIface interface {
	Exec()
}

type GenesisContainer

type GenesisContainer struct {
	NetworkID       uint32
	Time            uint64
	XChainGenesisTx *txs.Tx
	XChainID        ids.ID
	DjtxAssetID     ids.ID
	GenesisBytes    []byte
}

func NewGenesisContainer

func NewGenesisContainer(networkID uint32) (*GenesisContainer, error)

type IndexedList

type IndexedList interface {
	PushFront(key, val interface{})
	Exists(key interface{}) bool
}

func NewIndexedList

func NewIndexedList(maxSize int) IndexedList

type LCache

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

func NewTTLMap

func NewTTLMap() *LCache

func (*LCache) Get

func (m *LCache) Get(k string) ([]byte, bool)

func (*LCache) Put

func (m *LCache) Put(k string, v []byte, ttl time.Duration)

func (*LCache) Stop

func (m *LCache) Stop()

type ListenCloser

type ListenCloser interface {
	Listen() error
	Close() error
}

ListenCloser listens for messages until it's asked to close

type Metrics

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

var (
	Prometheus Metrics
)

func (*Metrics) CounterAdd

func (m *Metrics) CounterAdd(name string, v float64) error

func (*Metrics) CounterInc

func (m *Metrics) CounterInc(name string) error

func (*Metrics) CounterInit

func (m *Metrics) CounterInit(name string, help string)

func (*Metrics) HistogramInit

func (m *Metrics) HistogramInit(name string, help string, buckets []float64)

func (*Metrics) HistogramObserve

func (m *Metrics) HistogramObserve(name string, v float64) error

func (*Metrics) Init

func (m *Metrics) Init()

type RetrySleeper

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

func NewRetrySleeper

func NewRetrySleeper(retries uint64, sleepDuration time.Duration, sleepDurationMax time.Duration) *RetrySleeper

func (*RetrySleeper) Inc

func (r *RetrySleeper) Inc()

type Running

type Running interface {
	Close()
	IsStopped() bool
}

func NewRunning

func NewRunning() Running

type Worker

type Worker interface {
	Enque(job interface{})
	TryEnque(job interface{})
	Finish(sleepTime time.Duration)
	JobCnt() int64
	IsFinished() bool
}

func NewWorker

func NewWorker(queueSize int, queueCnt int, processor func(int, interface{})) Worker