blockprint

Documentation

Index

• Constants
• func GetSlotEpochTimings(slot phase0.Slot, wallclock *ethwallclock.EthereumBeaconChain) (*xatu.SlotV2, *xatu.EpochV2)
• type BlockClassificationDeriver
  • func NewBlockClassificationDeriver(log logrus.FieldLogger, config *BlockClassificationDeriverConfig, ...) *BlockClassificationDeriver
  • func (b *BlockClassificationDeriver) ActivationFork() spec.DataVersion
  • 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
  • func (c *BlockClassificationDeriverConfig) Validate() error

Constants

const (
	BlockClassificationName = xatu.CannonType_BLOCKPRINT_BLOCK_CLASSIFICATION
)

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

func (b *BlockClassificationDeriver) ActivationFork() spec.DataVersion

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)

func (*BlockClassificationDeriver) Start

func (b *BlockClassificationDeriver) Start(ctx context.Context) error

func (*BlockClassificationDeriver) Stop

func (b *BlockClassificationDeriver) Stop(ctx context.Context) 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