chainio

Documentation

Index

• Constants
• type AvsReader
  • func NewAvsReaderFromConfig(baseConfig *config.BaseConfig, ecdsaConfig *config.EcdsaConfig) (*AvsReader, error)
  • func (r *AvsReader) GetErc20Mock(tokenAddr gethcommon.Address) (*contractERC20Mock.ContractERC20Mock, error)
  • func (r *AvsReader) IsOperatorRegistered(address gethcommon.Address) (bool, error)
• type AvsServiceBindings
  • func NewAvsServiceBindings(serviceManagerAddr, blsOperatorStateRetrieverAddr gethcommon.Address, ...) (*AvsServiceBindings, error)
• type AvsSubscriber
  • func NewAvsSubscriberFromConfig(baseConfig *config.BaseConfig) (*AvsSubscriber, error)
  • func (s *AvsSubscriber) SubscribeToNewTasks(...) (event.Subscription, error)
• type AvsWriter
  • func NewAvsWriterFromConfig(baseConfig *config.BaseConfig, ecdsaConfig *config.EcdsaConfig) (*AvsWriter, error)
  • func (w *AvsWriter) SendAggregatedResponse(batchMerkleRoot [32]byte, ...) (*common.Hash, error)
  • func (w *AvsWriter) SendTask(context context.Context, batchMerkleRoot [32]byte, batchDataPointer string) error

Constants

const (
	MaxRetries    = 100
	RetryInterval = 1 * time.Second
)

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) 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.ContractAlignedLayerServiceManagerNewBatch) (event.Subscription, error)

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(batchMerkleRoot [32]byte, nonSignerStakesAndSignature servicemanager.IBLSSignatureCheckerNonSignerStakesAndSignature) (*common.Hash, error)

func (*AvsWriter) SendTask

func (w *AvsWriter) SendTask(context context.Context, batchMerkleRoot [32]byte, batchDataPointer string) error