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

pkg

package

Go to main page

Versions in this module

v0

v0.14.0

Jan 20, 2025

v0.13.0

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)

v0.12.2

Dec 18, 2024

v0.12.1

Nov 29, 2024

v0.12.0

Nov 27, 2024

Changes in this version

type Aggregator

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

v0.11.2

Nov 20, 2024

v0.11.1

Nov 20, 2024

v0.11.0

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