common

Documentation

Index

• func SliceToAddresses(slice []string) []common.Address
• func WeiToEther(wei *big.Int) *big.Float
• type DLQ
  • func NewTransitDLQ(size int) *DLQ[core.TransitData]
  • func (d *DLQ[E]) Add(entry *E) error
  • func (d *DLQ[E]) Empty() bool
  • func (d *DLQ[E]) Pop() (*E, error)
  • func (d *DLQ[E]) PopAll() []*E
  • func (d *DLQ[E]) Size() int

Functions

func SliceToAddresses

func SliceToAddresses(slice []string) []common.Address

SliceToAddresses ... Converts a slice of strings to a slice of addresses

func WeiToEther

func WeiToEther(wei *big.Int) *big.Float

WeiToEther ... Converts wei to ether

Types

type DLQ

type DLQ[E any] struct {
	// contains filtered or unexported fields
}

DLQ ... Dead Letter Queue construct Used to store ETL events that failed to be processed

func NewTransitDLQ

func NewTransitDLQ(size int) *DLQ[core.TransitData]

NewTransitDLQ ... Initializer

func (*DLQ[E]) Add

func (d *DLQ[E]) Add(entry *E) error

Add ... Adds an entry to the DLQ if it is not full

func (*DLQ[E]) Empty

func (d *DLQ[E]) Empty() bool

Empty ... Checks if the DLQ is empty

func (*DLQ[E]) Pop

func (d *DLQ[E]) Pop() (*E, error)

Pop ... Removes the first element from the DLQ, typically for re-processing

func (*DLQ[E]) PopAll

func (d *DLQ[E]) PopAll() []*E

PopAll ... Removes all elements from the DLQ, typically for re-processing

func (*DLQ[E]) Size

func (d *DLQ[E]) Size() int

Size ... Returns the size of the DLQ