Documentation
¶
Index ¶
- Constants
- func GetSlotEpochTimings(slot phase0.Slot, wallclock *ethwallclock.EthereumBeaconChain) (*xatu.SlotV2, *xatu.EpochV2)
- type BlockClassificationDeriver
- func (b *BlockClassificationDeriver) ActivationFork() string
- func (b *BlockClassificationDeriver) CannonType() xatu.CannonType
- func (b *BlockClassificationDeriver) Name() string
- func (b *BlockClassificationDeriver) OnEventsDerived(ctx context.Context, ...)
- func (b *BlockClassificationDeriver) Start(ctx context.Context) error
- func (b *BlockClassificationDeriver) Stop(ctx context.Context) error
- type BlockClassificationDeriverConfig
Constants ¶
View Source
const (
BlockClassificationName = xatu.CannonType_BLOCKPRINT_BLOCK_CLASSIFICATION
)
Variables ¶
This section is empty.
Functions ¶
func GetSlotEpochTimings ¶
func GetSlotEpochTimings(slot phase0.Slot, wallclock *ethwallclock.EthereumBeaconChain) (*xatu.SlotV2, *xatu.EpochV2)
Types ¶
type BlockClassificationDeriver ¶
type BlockClassificationDeriver struct {
// contains filtered or unexported fields
}
func NewBlockClassificationDeriver ¶
func NewBlockClassificationDeriver(log logrus.FieldLogger, config *BlockClassificationDeriverConfig, iter *iterator.BlockprintIterator, beacon *ethereum.BeaconNode, clientMeta *xatu.ClientMeta, client *aBlockprint.Client) *BlockClassificationDeriver
func (*BlockClassificationDeriver) ActivationFork ¶ added in v0.0.140
func (b *BlockClassificationDeriver) ActivationFork() string
func (*BlockClassificationDeriver) CannonType ¶
func (b *BlockClassificationDeriver) CannonType() xatu.CannonType
func (*BlockClassificationDeriver) Name ¶
func (b *BlockClassificationDeriver) Name() string
func (*BlockClassificationDeriver) OnEventsDerived ¶
func (b *BlockClassificationDeriver) OnEventsDerived(ctx context.Context, fn func(ctx context.Context, events []*xatu.DecoratedEvent) error)
type BlockClassificationDeriverConfig ¶
type BlockClassificationDeriverConfig struct {
Enabled bool `yaml:"enabled" default:"false"`
Endpoint string `yaml:"endpoint" default:"http://localhost:8080"`
Headers map[string]string `yaml:"headers"`
BatchSize int `yaml:"batchSize" default:"50"`
}
func (*BlockClassificationDeriverConfig) Validate ¶
func (c *BlockClassificationDeriverConfig) Validate() error
Source Files
Click to show internal directories.
Click to hide internal directories.