Documentation
¶
Index ¶
- Constants
- type AggregatorRpcClient
- type Operator
- 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
Constants ¶
View Source
const ( MaxRetries = 10 RetryInterval = 10 * time.Second )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AggregatorRpcClient ¶
type AggregatorRpcClient struct {
// contains filtered or unexported fields
}
AggregatorRpcClient is the client to communicate with the aggregator via RPC
func NewAggregatorRpcClient ¶
func NewAggregatorRpcClient(aggregatorIpPortAddr string, logger logging.Logger) (*AggregatorRpcClient, error)
func (*AggregatorRpcClient) SendSignedTaskResponseToAggregator ¶
func (c *AggregatorRpcClient) SendSignedTaskResponseToAggregator(signedTaskResponse *types.SignedTaskResponse)
SendSignedTaskResponseToAggregator is the method called by operators via RPC to send their signed task response.
type Operator ¶
type Operator struct {
Config config.OperatorConfig
Address ethcommon.Address
Socket string
Timeout time.Duration
PrivKey *ecdsa.PrivateKey
KeyPair *bls.KeyPair
OperatorId eigentypes.OperatorId
NewTaskCreatedChan chan *servicemanager.ContractAlignedLayerServiceManagerNewTaskCreated
Logger logging.Logger
// contains filtered or unexported fields
}
func NewOperatorFromConfig ¶
func NewOperatorFromConfig(configuration config.OperatorConfig) (*Operator, error)
func (*Operator) ProcessNewTaskCreatedLog ¶
func (o *Operator) ProcessNewTaskCreatedLog(newTaskCreatedLog *servicemanager.ContractAlignedLayerServiceManagerNewTaskCreated) *servicemanager.AlignedLayerServiceManagerTaskResponse
Takes a NewTaskCreatedLog struct as input and returns a TaskResponseHeader struct. The TaskResponseHeader struct is the struct that is signed and sent to the contract as a task response.
func (*Operator) SignTaskResponse ¶
func (o *Operator) SignTaskResponse(taskResponse *servicemanager.AlignedLayerServiceManagerTaskResponse) (*bls.Signature, error)
func (*Operator) SubscribeToNewTasks ¶
func (o *Operator) SubscribeToNewTasks() event.Subscription
Source Files
Click to show internal directories.
Click to hide internal directories.