Versions in this module Expand all Collapse all v0 v0.1.0 May 8, 2024 Changes in this version + const MaxRetries + const RetryInterval + type AggregatorRpcClient struct + func NewAggregatorRpcClient(aggregatorIpPortAddr string, logger logging.Logger) (*AggregatorRpcClient, error) + func (c *AggregatorRpcClient) SendSignedTaskResponseToAggregator(signedTaskResponse *types.SignedTaskResponse) + type Operator struct + Address ethcommon.Address + Config config.OperatorConfig + KeyPair *bls.KeyPair + Logger logging.Logger + NewTaskCreatedChan chan *servicemanager.ContractAlignedLayerServiceManagerNewTaskCreated + OperatorId eigentypes.OperatorId + PrivKey *ecdsa.PrivateKey + Socket string + Timeout time.Duration + func NewOperatorFromConfig(configuration config.OperatorConfig) (*Operator, error) + func (o *Operator) ProcessNewTaskCreatedLog(...) *servicemanager.AlignedLayerServiceManagerTaskResponse + func (o *Operator) SignTaskResponse(taskResponse *servicemanager.AlignedLayerServiceManagerTaskResponse) (*bls.Signature, error) + func (o *Operator) Start(ctx context.Context) error + func (o *Operator) SubscribeToNewTasks() event.Subscription