chainio

Documentation

Index

• func AbiEncodeBN254G1Point(point *txtaskmanager.BN254G1Point) ([]byte, error)
• func AbiEncodeBN254G2Point(point *txtaskmanager.BN254G2Point) ([]byte, error)
• func AbiEncodeNonSignerStakesAndSignature(data *txtaskmanager.IBLSSignatureCheckerNonSignerStakesAndSignature) ([]byte, error)
• func AbiEncodeOperatorDirectedRewardsSubmission(submission *txservicemanager.IRewardsCoordinatorTypesRewardsSubmission) ([]byte, error)
• func AbiEncodeOperatorKickParams(params *registrycoordinator.IRegistryCoordinatorOperatorKickParam) ([]byte, error)
• func AbiEncodePubkeyRegistrationParams(params *registrycoordinator.IBLSApkRegistryPubkeyRegistrationParams) ([]byte, error)
• func AbiEncodeQuorumStakeTotals(totals *txtaskmanager.IBLSSignatureCheckerQuorumStakeTotals) ([]byte, error)
• func AbiEncodeRewardsSubmission(submission *txservicemanager.IRewardsCoordinatorTypesRewardsSubmission) ([]byte, error)
• func AbiEncodeSignatureWithSaltAndExpiry(sig *registrycoordinator.ISignatureUtilsSignatureWithSaltAndExpiry) ([]byte, error)
• func AbiEncodeTaskResponse(h *txtaskmanager.ITriggerXTaskManagerTaskResponse) ([]byte, error)
• func GetTaskResponseDigest(h *txtaskmanager.ITriggerXTaskManagerTaskResponse) ([32]byte, error)
• type AvsManagersBindings
  • func NewAvsManagersBindings(registryCoordinatorAddr, operatorStateRetrieverAddr common.Address, ...) (*AvsManagersBindings, error)
  • func (b *AvsManagersBindings) GetErc20Mock(tokenAddr common.Address) (*erc20mock.ContractERC20Mock, error)
• type AvsSubscriber
  • func BuildAvsSubscriber(registryCoordinatorAddr, blsOperatorStateRetrieverAddr gethcommon.Address, ...) (*AvsSubscriber, error)
  • func BuildAvsSubscriberFromConfig(config *config.Config) (*AvsSubscriber, error)
  • func NewAvsSubscriber(avsContractBindings *AvsManagersBindings, logger sdklogging.Logger) *AvsSubscriber
  • func (s *AvsSubscriber) ParseKeeperBlacklisted(rawLog types.Log) (*txservicemanager.ContractTriggerXServiceManagerKeeperBlacklisted, error)
  • func (s *AvsSubscriber) ParseKeeperDeregistered(rawLog types.Log) (*txservicemanager.ContractTriggerXServiceManagerKeeperRemoved, error)
  • func (s *AvsSubscriber) ParseKeeperRegistered(rawLog types.Log) (*txservicemanager.ContractTriggerXServiceManagerKeeperAdded, error)
  • func (s *AvsSubscriber) ParseKeeperUnblacklisted(rawLog types.Log) (*txservicemanager.ContractTriggerXServiceManagerKeeperUnblacklisted, error)
  • func (s *AvsSubscriber) ParseStakeRemoved(rawLog types.Log) (*stakeregistry.ContractTriggerXStakeRegistryStakeRemoved, error)
  • func (s *AvsSubscriber) ParseTaskCreated(rawLog types.Log) (*txtaskmanager.ContractTriggerXTaskManagerTaskCreated, error)
  • func (s *AvsSubscriber) ParseTaskResponded(rawLog types.Log) (*txtaskmanager.ContractTriggerXTaskManagerTaskResponded, error)
  • func (s *AvsSubscriber) SubscribeToKeeperBlacklisted(...) event.Subscription
  • func (s *AvsSubscriber) SubscribeToKeeperDeregistered(...) event.Subscription
  • func (s *AvsSubscriber) SubscribeToKeeperRegistered(...) event.Subscription
  • func (s *AvsSubscriber) SubscribeToKeeperUnblacklisted(...) event.Subscription
  • func (s *AvsSubscriber) SubscribeToNewTasks(newTaskCreatedChan chan *txtaskmanager.ContractTriggerXTaskManagerTaskCreated) event.Subscription
  • func (s *AvsSubscriber) SubscribeToStakeRemoved(stakeRemovedChan chan *stakeregistry.ContractTriggerXStakeRegistryStakeRemoved) event.Subscription
  • func (s *AvsSubscriber) SubscribeToTaskResponses(taskResponseChan chan *txtaskmanager.ContractTriggerXTaskManagerTaskResponded) event.Subscription
• type AvsSubscriberer

Functions

func AbiEncodeBN254G1Point

func AbiEncodeBN254G1Point(point *txtaskmanager.BN254G1Point) ([]byte, error)

ABI encoding for BN254 point types

func AbiEncodeBN254G2Point

func AbiEncodeBN254G2Point(point *txtaskmanager.BN254G2Point) ([]byte, error)

func AbiEncodeNonSignerStakesAndSignature

func AbiEncodeNonSignerStakesAndSignature(data *txtaskmanager.IBLSSignatureCheckerNonSignerStakesAndSignature) ([]byte, error)

ABI encoding for BLS signature checking types

func AbiEncodeOperatorDirectedRewardsSubmission

func AbiEncodeOperatorDirectedRewardsSubmission(submission *txservicemanager.IRewardsCoordinatorTypesRewardsSubmission) ([]byte, error)

func AbiEncodeOperatorKickParams

func AbiEncodeOperatorKickParams(params *registrycoordinator.IRegistryCoordinatorOperatorKickParam) ([]byte, error)

func AbiEncodePubkeyRegistrationParams

func AbiEncodePubkeyRegistrationParams(params *registrycoordinator.IBLSApkRegistryPubkeyRegistrationParams) ([]byte, error)

ABI encoding for BLS registry types

func AbiEncodeQuorumStakeTotals

func AbiEncodeQuorumStakeTotals(totals *txtaskmanager.IBLSSignatureCheckerQuorumStakeTotals) ([]byte, error)

func AbiEncodeRewardsSubmission

func AbiEncodeRewardsSubmission(submission *txservicemanager.IRewardsCoordinatorTypesRewardsSubmission) ([]byte, error)

ABI encoding for rewards types

func AbiEncodeSignatureWithSaltAndExpiry

func AbiEncodeSignatureWithSaltAndExpiry(sig *registrycoordinator.ISignatureUtilsSignatureWithSaltAndExpiry) ([]byte, error)

ABI encoding for signature types

func AbiEncodeTaskResponse

func AbiEncodeTaskResponse(h *txtaskmanager.ITriggerXTaskManagerTaskResponse) ([]byte, error)

this hardcodes abi.encode() for txtaskmanager.ITriggerXTaskManagerTaskResponse

func GetTaskResponseDigest

func GetTaskResponseDigest(h *txtaskmanager.ITriggerXTaskManagerTaskResponse) ([32]byte, error)

GetTaskResponseDigest returns the hash of the TaskResponse, which is what operators sign over

Types

type AvsManagersBindings

type AvsManagersBindings struct {
	TaskManager         *txtaskmanager.ContractTriggerXTaskManager
	ServiceManager      *txservicemanager.ContractTriggerXServiceManager
	StakeRegistry       *stakeregistry.ContractTriggerXStakeRegistry
	RegistryCoordinator *regcoord.ContractRegistryCoordinator
	// contains filtered or unexported fields
}

func NewAvsManagersBindings

func NewAvsManagersBindings(registryCoordinatorAddr, operatorStateRetrieverAddr common.Address, ethclient sdkcommon.EthClientInterface, logger logging.Logger) (*AvsManagersBindings, error)

func (*AvsManagersBindings) GetErc20Mock

func (b *AvsManagersBindings) GetErc20Mock(tokenAddr common.Address) (*erc20mock.ContractERC20Mock, error)

type AvsSubscriber

type AvsSubscriber struct {
	AvsContractBindings *AvsManagersBindings
	// contains filtered or unexported fields
}

func BuildAvsSubscriber

func BuildAvsSubscriber(registryCoordinatorAddr, blsOperatorStateRetrieverAddr gethcommon.Address, ethclient sdkcommon.EthClientInterface, logger sdklogging.Logger) (*AvsSubscriber, error)

func BuildAvsSubscriberFromConfig

func BuildAvsSubscriberFromConfig(config *config.Config) (*AvsSubscriber, error)

func NewAvsSubscriber

func NewAvsSubscriber(avsContractBindings *AvsManagersBindings, logger sdklogging.Logger) *AvsSubscriber

func (*AvsSubscriber) ParseKeeperBlacklisted

func (s *AvsSubscriber) ParseKeeperBlacklisted(rawLog types.Log) (*txservicemanager.ContractTriggerXServiceManagerKeeperBlacklisted, error)

func (*AvsSubscriber) ParseKeeperDeregistered

func (s *AvsSubscriber) ParseKeeperDeregistered(rawLog types.Log) (*txservicemanager.ContractTriggerXServiceManagerKeeperRemoved, error)

func (*AvsSubscriber) ParseKeeperRegistered

func (s *AvsSubscriber) ParseKeeperRegistered(rawLog types.Log) (*txservicemanager.ContractTriggerXServiceManagerKeeperAdded, error)

func (*AvsSubscriber) ParseKeeperUnblacklisted

func (s *AvsSubscriber) ParseKeeperUnblacklisted(rawLog types.Log) (*txservicemanager.ContractTriggerXServiceManagerKeeperUnblacklisted, error)

func (*AvsSubscriber) ParseStakeRemoved

func (s *AvsSubscriber) ParseStakeRemoved(rawLog types.Log) (*stakeregistry.ContractTriggerXStakeRegistryStakeRemoved, error)

func (*AvsSubscriber) ParseTaskCreated

func (s *AvsSubscriber) ParseTaskCreated(rawLog types.Log) (*txtaskmanager.ContractTriggerXTaskManagerTaskCreated, error)

func (*AvsSubscriber) ParseTaskResponded

func (s *AvsSubscriber) ParseTaskResponded(rawLog types.Log) (*txtaskmanager.ContractTriggerXTaskManagerTaskResponded, error)

func (*AvsSubscriber) SubscribeToKeeperBlacklisted

func (s *AvsSubscriber) SubscribeToKeeperBlacklisted(keeperBlacklistedChan chan *txservicemanager.ContractTriggerXServiceManagerKeeperBlacklisted) event.Subscription

func (*AvsSubscriber) SubscribeToKeeperDeregistered

func (s *AvsSubscriber) SubscribeToKeeperDeregistered(keeperDeregisteredChan chan *txservicemanager.ContractTriggerXServiceManagerKeeperRemoved) event.Subscription

func (*AvsSubscriber) SubscribeToKeeperRegistered

func (s *AvsSubscriber) SubscribeToKeeperRegistered(keeperRegisteredChan chan *txservicemanager.ContractTriggerXServiceManagerKeeperAdded) event.Subscription

func (*AvsSubscriber) SubscribeToKeeperUnblacklisted

func (s *AvsSubscriber) SubscribeToKeeperUnblacklisted(keeperUnblacklistedChan chan *txservicemanager.ContractTriggerXServiceManagerKeeperUnblacklisted) event.Subscription

func (*AvsSubscriber) SubscribeToNewTasks

func (s *AvsSubscriber) SubscribeToNewTasks(newTaskCreatedChan chan *txtaskmanager.ContractTriggerXTaskManagerTaskCreated) event.Subscription

func (*AvsSubscriber) SubscribeToStakeRemoved

func (s *AvsSubscriber) SubscribeToStakeRemoved(stakeRemovedChan chan *stakeregistry.ContractTriggerXStakeRegistryStakeRemoved) event.Subscription

func (*AvsSubscriber) SubscribeToTaskResponses

func (s *AvsSubscriber) SubscribeToTaskResponses(taskResponseChan chan *txtaskmanager.ContractTriggerXTaskManagerTaskResponded) event.Subscription

type AvsSubscriberer

type AvsSubscriberer interface {
	// TriggerXTaskManager Events
	SubscribeToNewTasks(newTaskCreatedChan chan *txtaskmanager.ContractTriggerXTaskManagerTaskCreated) event.Subscription
	SubscribeToTaskResponses(taskResponseLogs chan *txtaskmanager.ContractTriggerXTaskManagerTaskResponded) event.Subscription

	// TriggerXServiceManager Events
	SubscribeToKeeperRegistered(keeperRegisteredChan chan *txservicemanager.ContractTriggerXServiceManagerKeeperAdded) event.Subscription
	SubscribeToKeeperDeregistered(keeperDeregisteredChan chan *txservicemanager.ContractTriggerXServiceManagerKeeperRemoved) event.Subscription
	SubscribeToKeeperBlacklisted(keeperBlacklistedChan chan *txservicemanager.ContractTriggerXServiceManagerKeeperBlacklisted) event.Subscription
	SubscribeToKeeperUnblacklisted(keeperUnblacklistedChan chan *txservicemanager.ContractTriggerXServiceManagerKeeperUnblacklisted) event.Subscription

	// TriggerXStakeRegistry Events
	SubscribeToStakeRemoved(stakeRemovedChan chan *stakeregistry.ContractTriggerXStakeRegistryStakeRemoved) event.Subscription

	ParseTaskResponded(rawLog types.Log) (*txtaskmanager.ContractTriggerXTaskManagerTaskResponded, error)
	ParseTaskCreated(rawLog types.Log) (*txtaskmanager.ContractTriggerXTaskManagerTaskCreated, error)
	ParseKeeperRegistered(rawLog types.Log) (*txservicemanager.ContractTriggerXServiceManagerKeeperAdded, error)
	ParseKeeperDeregistered(rawLog types.Log) (*txservicemanager.ContractTriggerXServiceManagerKeeperRemoved, error)
	ParseKeeperBlacklisted(rawLog types.Log) (*txservicemanager.ContractTriggerXServiceManagerKeeperBlacklisted, error)
	ParseKeeperUnblacklisted(rawLog types.Log) (*txservicemanager.ContractTriggerXServiceManagerKeeperUnblacklisted, error)
	ParseStakeRemoved(rawLog types.Log) (*stakeregistry.ContractTriggerXStakeRegistryStakeRemoved, error)
}