pkg

Jan 2, 2025

Changes in this version

type TaskSentToEthereumMessage

+ EffectiveGasPrice string

+ type TaskSetGasPriceMessage struct

+ GasPrice string

+ MerkleRoot string

type Telemetry

+ func (t *Telemetry) TaskSetGasPrice(batchMerkleRoot [32]byte, gasPrice string)

Nov 27, 2024

Changes in this version

type Aggregator

+ func (agg *Aggregator) GetTaskIndexRetryable(batchIdentifierHash [32]byte, config *retry.RetryParams) (uint32, error)

Nov 20, 2024

Changes in this version

+ const MaxSentTxRetries

+ const QUORUM_NUMBER

+ const QUORUM_THRESHOLD

+ type Aggregator struct

+ AggregatorConfig *config.AggregatorConfig

+ NewBatchChan chan *servicemanager.ContractAlignedLayerServiceManagerNewBatchV3

+ func NewAggregator(aggregatorConfig config.AggregatorConfig) (*Aggregator, error)

+ func (agg *Aggregator) AddNewTask(batchMerkleRoot [32]byte, senderAddress [20]byte, taskCreatedBlock uint32)

+ func (agg *Aggregator) ClearTasksFromMaps()

+ func (agg *Aggregator) GetTaskIndex(batchIdentifierHash [32]byte) (uint32, error)

+ func (agg *Aggregator) InitializeNewTaskRetryable(batchIndex uint32, taskCreatedBlock uint32, quorumNums eigentypes.QuorumNums, ...) error

+ func (agg *Aggregator) ProcessNewSignature(ctx context.Context, taskIndex uint32, taskResponse interface{}, ...) error

+ func (agg *Aggregator) ProcessOperatorSignedTaskResponseV2(signedTaskResponse *types.SignedTaskResponse, reply *uint8) error

+ func (agg *Aggregator) ServeOperators() error

+ func (agg *Aggregator) ServerRunning(_ *struct{}, reply *int64) error

+ func (agg *Aggregator) Start(ctx context.Context) error

+ func (agg *Aggregator) SubscribeToNewTasks() error

+ type BatchData struct

+ BatchMerkleRoot [32]byte

+ SenderAddress [20]byte

+ type OperatorResponseMessage struct

+ MerkleRoot string

+ OperatorId string

+ type QuorumReachedMessage struct

+ MerkleRoot string

+ type TaskErrorMessage struct

+ MerkleRoot string

+ TaskError string

+ type TaskGasPriceBumpMessage struct

+ BumpedGasPrice string

+ MerkleRoot string

+ type TaskResponses = []types.SignedTaskResponse

+ type TaskSentToEthereumMessage struct

+ MerkleRoot string

+ TxHash string

+ type Telemetry struct

+ func NewTelemetry(serverAddress string, logger logging.Logger) *Telemetry

+ func (t *Telemetry) BumpedTaskGasPrice(batchMerkleRoot [32]byte, bumpedGasPrice string)

+ func (t *Telemetry) FinishTrace(batchMerkleRoot [32]byte)

+ func (t *Telemetry) InitNewTrace(batchMerkleRoot [32]byte)

+ func (t *Telemetry) LogOperatorResponse(batchMerkleRoot [32]byte, operatorId [32]byte)

+ func (t *Telemetry) LogQuorumReached(batchMerkleRoot [32]byte)

+ func (t *Telemetry) LogTaskError(batchMerkleRoot [32]byte, taskError error)

+ func (t *Telemetry) TaskSentToEthereum(batchMerkleRoot [32]byte, txHash string)

+ type TraceMessage struct

+ MerkleRoot string