Documentation ¶
Index ¶
- Constants
- type Aggregator
- func (agg *Aggregator) AddNewTask(batchMerkleRoot [32]byte, senderAddress [20]byte, taskCreatedBlock uint32)
- 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
- type TaskResponses
Constants ¶
View Source
const MaxSentTxRetries = 5
View Source
const QUORUM_NUMBER = byte(0)
FIXME(marian): Read this from Aligned contract directly
View Source
const QUORUM_THRESHOLD = byte(67)
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Aggregator ¶
type Aggregator struct { AggregatorConfig *config.AggregatorConfig NewBatchChan chan *servicemanager.ContractAlignedLayerServiceManagerNewBatchV3 // contains filtered or unexported fields }
func NewAggregator ¶
func NewAggregator(aggregatorConfig config.AggregatorConfig) (*Aggregator, error)
func (*Aggregator) AddNewTask ¶
func (agg *Aggregator) AddNewTask(batchMerkleRoot [32]byte, senderAddress [20]byte, taskCreatedBlock uint32)
func (*Aggregator) ProcessOperatorSignedTaskResponseV2 ¶ added in v0.5.0
func (agg *Aggregator) ProcessOperatorSignedTaskResponseV2(signedTaskResponse *types.SignedTaskResponse, reply *uint8) error
Aggregator Methods This is the list of methods that the Aggregator exposes to the Operator The Operator can call these methods to interact with the Aggregator This methods are automatically registered by the RPC server This takes a response an adds it to the internal. If reaching the quorum, it sends the aggregated signatures to ethereum Returns:
- 0: Success
- 1: Error
func (*Aggregator) ServeOperators ¶
func (agg *Aggregator) ServeOperators() error
func (*Aggregator) ServerRunning ¶
func (agg *Aggregator) ServerRunning(_ *struct{}, reply *int64) error
Dummy method to check if the server is running TODO: Remove this method in prod
func (*Aggregator) SubscribeToNewTasks ¶
func (agg *Aggregator) SubscribeToNewTasks() error
type BatchData ¶ added in v0.5.0
BatchData stores the data of a batch, for use in map BatchIdentifierHash -> BatchData
type TaskResponses ¶ added in v0.1.3
type TaskResponses = []types.SignedTaskResponse
Aggregator stores TaskResponse for a task here
Click to show internal directories.
Click to hide internal directories.