utils

Documentation

Index

• Constants
• func CommonAddressHexRepair(address *common.Address) string
• 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 ListenCloser
• type ListenCloserFactory
• type RetrySleeper
  • func NewRetrySleeper(retries uint64, sleepDuration time.Duration, sleepDurationMax time.Duration) *RetrySleeper
  • func (r *RetrySleeper) Inc()
• type Running
  • func NewRunning() Running
• type UniqueID
  • func NewMemoryUniqueID() UniqueID
• type Worker
  • func NewWorker(queueSize int, queueCnt int, processor func(int, interface{})) Worker

Constants

const (
	KeyValueBootstrap = "bootstrap"
)

Functions

func CommonAddressHexRepair

func CommonAddressHexRepair(address *common.Address) string

Types

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 ListenCloser

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

ListenCloser listens for messages until it's asked to close

type ListenCloserFactory

type ListenCloserFactory func(*servicesctrl.Control, cfg.Config, int, int) ListenCloser

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 UniqueID

type UniqueID interface {
	Get(id string) (bool, error)
	Put(id string) error
}

func NewMemoryUniqueID

func NewMemoryUniqueID() UniqueID

type Worker

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

func NewWorker

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