utils

Documentation

Index

• Constants
• func GetBlockNumber(url string) (uint64, error)
• func PeekUrlHost(rawURL string) (string, error)
• func PrettyElapsed(elapsed time.Duration) string
• func ReplacePort(originalURL string, newPort string) (string, error)
• func SafeStartGoroutine(do func())
• func StartAction(action func(), wg *sync.WaitGroup)
• func StartDeamon(do func())
• type SizedWaitGroup
  • func NewSizedWaitGroup(limit int) SizedWaitGroup
  • func (s *SizedWaitGroup) Add()
  • func (s *SizedWaitGroup) AddWithContext(ctx context.Context) error
  • func (s *SizedWaitGroup) Done()
  • func (s *SizedWaitGroup) Wait()

Constants

const (
	BlockChainRpc = "https://evmrpc-testnet.0g.ai"
)

Functions

func GetBlockNumber

func GetBlockNumber(url string) (uint64, error)

func PeekUrlHost

func PeekUrlHost(rawURL string) (string, error)

func PrettyElapsed

func PrettyElapsed(elapsed time.Duration) string

func ReplacePort

func ReplacePort(originalURL string, newPort string) (string, error)

func SafeStartGoroutine

func SafeStartGoroutine(do func())

func StartAction

func StartAction(action func(), wg *sync.WaitGroup)

func StartDeamon

func StartDeamon(do func())

Types

type SizedWaitGroup

type SizedWaitGroup struct {
	Size int
	// contains filtered or unexported fields
}

func NewSizedWaitGroup

func NewSizedWaitGroup(limit int) SizedWaitGroup

func (*SizedWaitGroup) Add

func (s *SizedWaitGroup) Add()

func (*SizedWaitGroup) AddWithContext

func (s *SizedWaitGroup) AddWithContext(ctx context.Context) error

func (*SizedWaitGroup) Done

func (s *SizedWaitGroup) Done()

func (*SizedWaitGroup) Wait

func (s *SizedWaitGroup) Wait()