Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type DBProvider ¶
DBProvider takes a DBContext and returns an instantiated DB.
type OperatorStakeInfo ¶
type OperatorStateInfo ¶
type OperatorStateInfo struct {
Operators map[types.OperatorID]common.Address
GroupStakes map[types.GroupNumber]*big.Int
GroupOperatorMap map[types.GroupNumber][]OperatorStakeInfo
}
type RPCClientAggregator ¶
type RPCClientAggregator struct {
// contains filtered or unexported fields
}
RPCClientAggregator is an implementation that interacts with the aggregator via RPC
func NewRPCClientAggregator ¶
func NewRPCClientAggregator(address string) (*RPCClientAggregator, error)
NewRPCClientAggregator creates a new instance of RPCClientAggregator
func (*RPCClientAggregator) CollectResponseSignature ¶
func (ra *RPCClientAggregator) CollectResponseSignature(response *aggTypes.ResponseWithSignature, validatedResponseCh chan<- aggTypes.ValidatedResponse) error
CollectResponseSignature implements the CollectResponseSignature method of the Aggregator interface
type RPCServerAggregator ¶
type RPCServerAggregator struct {
service.BaseService
Logger log.Logger
// contains filtered or unexported fields
}
RPCServerAggregator is an RPC implementation of the Aggregator interface
func NewRPCServerAggregator ¶
func NewRPCServerAggregator( ctx context.Context, cfg *config.Config, aggConfig *aggregator.AggregatorConfig, logger log.Logger, ) (*RPCServerAggregator, error)
func (*RPCServerAggregator) CollectResponseSignature ¶
func (ra *RPCServerAggregator) CollectResponseSignature(response *aggregator.ResponseWithSignature, result *aggregator.ValidatedResponse) error
func (*RPCServerAggregator) IsRunning ¶
func (ra *RPCServerAggregator) IsRunning() bool
func (*RPCServerAggregator) OnStart ¶
func (ra *RPCServerAggregator) OnStart() error
func (*RPCServerAggregator) OnStop ¶
func (ra *RPCServerAggregator) OnStop()
type ResultDigest ¶
type ResultDigest [32]byte
Click to show internal directories.
Click to hide internal directories.