rpc

type AggregatorDVSInteractor struct {
	// contains filtered or unexported fields
}

type AggregatorDVSInteractorer interface {
	GetOperatorsDVSStateAtBlock(groupNumbers types.GroupNumbers, blockNumber uint32) (map[types.OperatorID]types.OperatorDVSState, error)
	GetGroupsDVSStateAtBlock(groupNumbers types.GroupNumbers, blockNumber uint32) (map[types.GroupNumber]types.GroupDVSState, error)
	GetOperatorInfoByID(operatorID types.OperatorID) (types.OperatorInfo, error)

	GetCheckSignaturesIndices(blockNumber uint32, groupNumbers types.GroupNumbers, nonSignerOperatorIds []types.OperatorID) (types.CheckSignaturesIndices, error)
	// contains filtered or unexported methods
}

type DBContext struct {
	ID     string
	Config *config.Config
}

type DBProvider func(*DBContext) (dbm.DB, error)

type OperatorStakeInfo struct {
	Operator   common.Address
	OperatorID types.OperatorID
	Stake      *big.Int
}

type OperatorStateInfo struct {
	Operators        map[types.OperatorID]common.Address
	GroupStakes      map[types.GroupNumber]*big.Int
	GroupOperatorMap map[types.GroupNumber][]OperatorStakeInfo
}

type RPCClientAggregator struct {
	// contains filtered or unexported fields
}

type RPCServerAggregator struct {
	service.BaseService

	Logger log.Logger
	// contains filtered or unexported fields
}

type ResultDigest [32]byte

type Task struct {
	// contains filtered or unexported fields
}