bidcollect

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

type BidCollectorOpts struct {
	Log *logrus.Entry
	UID string

	CollectUltrasoundStream bool
	CollectGetHeader        bool
	CollectDataAPI          bool

	Relays        []common.RelayEntry
	BeaconNodeURI string // for getHeader

	OutDir    string
	OutputTSV bool

	RedisAddr string
	UseRedis  bool
}

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

type BidProcessorOpts struct {
	Log       *logrus.Entry
	UID       string
	OutDir    string
	OutputTSV bool
	RedisAddr string
	UseRedis  bool
}

type DataAPIPoller struct {
	Log    *logrus.Entry
	BidC   chan DataAPIPollerBidsMsg
	Relays []common.RelayEntry
}

type DataAPIPollerBidsMsg struct {
	Bids       []relaycommon.BidTraceV2WithTimestampJSON
	Relay      common.RelayEntry
	ReceivedAt time.Time
}

type DataAPIPollerOpts struct {
	Log    *logrus.Entry
	BidC   chan DataAPIPollerBidsMsg
	Relays []common.RelayEntry
}

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

type GetHeaderPollerBidsMsg struct {
	Slot       uint64
	Bid        types.GetHeaderResponse
	Relay      common.RelayEntry
	ReceivedAt time.Time
}

type GetHeaderPollerOpts struct {
	Log       *logrus.Entry
	BidC      chan GetHeaderPollerBidsMsg
	BeaconURI string
	Relays    []common.RelayEntry
}

type OutFiles struct {
	FAll *os.File
	FTop *os.File
}

type UltrasoundStreamBidsMsg struct {
	Bid        common.UltrasoundStreamBid
	Relay      string
	ReceivedAt time.Time
}

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

type UltrasoundStreamOpts struct {
	Log  *logrus.Entry
	BidC chan UltrasoundStreamBidsMsg
}