Documentation
¶
Index ¶
- type AvsReader
- type AvsServiceBindings
- type AvsSubscriber
- type AvsWriter
- func (w *AvsWriter) SendAggregatedResponse(ctx context.Context, task servicemanager.AlignedLayerServiceManagerTask, ...) (*gethtypes.Receipt, error)
- func (w *AvsWriter) SendTask(context context.Context, provingSystemId common.ProvingSystemId, proof []byte, ...) (servicemanager.AlignedLayerServiceManagerTask, uint32, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AvsReader ¶
type AvsReader struct {
sdkavsregistry.AvsRegistryReader
AvsContractBindings *AvsServiceBindings
// contains filtered or unexported fields
}
func NewAvsReaderFromConfig ¶
func NewAvsReaderFromConfig(baseConfig *config.BaseConfig, ecdsaConfig *config.EcdsaConfig) (*AvsReader, error)
func (*AvsReader) GetErc20Mock ¶
func (r *AvsReader) GetErc20Mock(tokenAddr gethcommon.Address) (*contractERC20Mock.ContractERC20Mock, error)
func (*AvsReader) GetNewTaskCreated ¶
func (r *AvsReader) GetNewTaskCreated(taskIndex uint32) (*contractAlignedLayerServiceManager.ContractAlignedLayerServiceManagerNewTaskCreated, error)
func (*AvsReader) IsOperatorRegistered ¶
func (r *AvsReader) IsOperatorRegistered(address gethcommon.Address) (bool, error)
type AvsServiceBindings ¶
type AvsServiceBindings struct {
ServiceManager *csservicemanager.ContractAlignedLayerServiceManager
// contains filtered or unexported fields
}
func NewAvsServiceBindings ¶
func NewAvsServiceBindings(serviceManagerAddr, blsOperatorStateRetrieverAddr gethcommon.Address, ethclient eth.Client, logger logging.Logger) (*AvsServiceBindings, error)
type AvsSubscriber ¶
type AvsSubscriber struct {
AvsContractBindings *AvsServiceBindings
// contains filtered or unexported fields
}
Subscribers use a ws connection instead of http connection like Readers kind of stupid that the geth client doesn't have a unified interface for both... it takes a single url, so the bindings, even though they have watcher functions, those can't be used with the http connection... seems very very stupid. Am I missing something?
func NewAvsSubscriberFromConfig ¶
func NewAvsSubscriberFromConfig(baseConfig *config.BaseConfig) (*AvsSubscriber, error)
func (*AvsSubscriber) SubscribeToNewTasks ¶
func (s *AvsSubscriber) SubscribeToNewTasks(newTaskCreatedChan chan *servicemanager.ContractAlignedLayerServiceManagerNewTaskCreated) event.Subscription
type AvsWriter ¶
type AvsWriter struct {
avsregistry.AvsRegistryWriter
AvsContractBindings *AvsServiceBindings
Signer signer.Signer
Client eth.Client
// contains filtered or unexported fields
}
func NewAvsWriterFromConfig ¶
func NewAvsWriterFromConfig(baseConfig *config.BaseConfig, ecdsaConfig *config.EcdsaConfig) (*AvsWriter, error)
func (*AvsWriter) SendAggregatedResponse ¶
func (w *AvsWriter) SendAggregatedResponse(ctx context.Context, task servicemanager.AlignedLayerServiceManagerTask, taskResponse servicemanager.AlignedLayerServiceManagerTaskResponse, nonSignerStakesAndSignature servicemanager.IBLSSignatureCheckerNonSignerStakesAndSignature) (*gethtypes.Receipt, error)
func (*AvsWriter) SendTask ¶
func (w *AvsWriter) SendTask(context context.Context, provingSystemId common.ProvingSystemId, proof []byte, publicInput []byte, verificationKey []byte, quorumNumbers types.QuorumNums, quorumThresholdPercentages types.QuorumThresholdPercentages, fee *big.Int) (servicemanager.AlignedLayerServiceManagerTask, uint32, error)
Source Files
Click to show internal directories.
Click to hide internal directories.