Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

bidcollect

package

Go to main page

Versions in this module

v1

v1.9.0

Jul 26, 2024

v1.8.2

Jul 25, 2024

Changes in this version

+ const SourceTypeDataAPI

+ const SourceTypeGetHeader

+ const SourceTypeUltrasoundStream

+ var CommonBidCSVFields = []string

+ type BidCollector struct

+ func NewBidCollector(opts *BidCollectorOpts) *BidCollector

+ func (c *BidCollector) MustStart()

+ type BidCollectorOpts struct

+ BeaconNodeURI string

+ CollectDataAPI bool

+ CollectGetHeader bool

+ CollectUltrasoundStream bool

+ Log *logrus.Entry

+ OutDir string

+ OutputTSV bool

+ Relays []common.RelayEntry

+ UID string

+ type BidProcessor struct

+ func NewBidProcessor(opts *BidProcessorOpts) *BidProcessor

+ func (c *BidProcessor) Start()

+ type BidProcessorOpts struct

+ Log *logrus.Entry

+ OutDir string

+ OutputTSV bool

+ UID string

+ type CommonBid struct

+ BlockFeeRecipient string

+ BlockHash string

+ BlockNumber uint64

+ BuilderPubkey string

+ OptimisticSubmission bool

+ ParentHash string

+ ProposerFeeRecipient string

+ ProposerPubkey string

+ ReceivedAtMs int64

+ Relay string

+ Slot uint64

+ SourceType int

+ TimestampMs int64

+ Value string

+ func DataAPIToCommonBids(bids DataAPIPollerBidsMsg) []*CommonBid

+ func GetHeaderToCommonBid(bid GetHeaderPollerBidsMsg) *CommonBid

+ func UltrasoundStreamToCommonBid(bid *UltrasoundStreamBidsMsg) *CommonBid

+ func (bid *CommonBid) ToCSVFields() []string

+ func (bid *CommonBid) ToCSVLine(separator string) string

+ func (bid *CommonBid) UniqueKey() string

+ func (bid *CommonBid) ValueAsBigInt() *big.Int

+ type DataAPIPoller struct

+ BidC chan DataAPIPollerBidsMsg

+ Log *logrus.Entry

+ Relays []common.RelayEntry

+ func NewDataAPIPoller(opts *DataAPIPollerOpts) *DataAPIPoller

+ func (poller *DataAPIPoller) Start()

+ type DataAPIPollerBidsMsg struct

+ Bids []relaycommon.BidTraceV2WithTimestampJSON

+ ReceivedAt time.Time

+ Relay common.RelayEntry

+ type DataAPIPollerOpts struct

+ BidC chan DataAPIPollerBidsMsg

+ Log *logrus.Entry

+ Relays []common.RelayEntry

+ type GetHeaderPoller struct

+ func NewGetHeaderPoller(opts *GetHeaderPollerOpts) *GetHeaderPoller

+ func (poller *GetHeaderPoller) Start()

+ type GetHeaderPollerBidsMsg struct

+ Bid types.GetHeaderResponse

+ ReceivedAt time.Time

+ Relay common.RelayEntry

+ Slot uint64

+ type GetHeaderPollerOpts struct

+ BeaconURI string

+ BidC chan GetHeaderPollerBidsMsg

+ Log *logrus.Entry

+ Relays []common.RelayEntry

+ type OutFiles struct

+ FAll *os.File

+ FTop *os.File

+ type UltrasoundStreamBidsMsg struct

+ Bid common.UltrasoundStreamBid

+ ReceivedAt time.Time

+ Relay string

+ type UltrasoundStreamConnection struct

+ func NewUltrasoundStreamConnection(opts UltrasoundStreamOpts) *UltrasoundStreamConnection

+ func (ustream *UltrasoundStreamConnection) Start()

+ type UltrasoundStreamOpts struct

+ BidC chan UltrasoundStreamBidsMsg

+ Log *logrus.Entry

v1.8.0-alpha1

Jun 13, 2024