-
Notifications
You must be signed in to change notification settings - Fork 931
/
pool.go
27 lines (22 loc) · 939 Bytes
/
pool.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
package synccommittee
import (
types "github.com/prysmaticlabs/prysm/v3/consensus-types/primitives"
ethpb "github.com/prysmaticlabs/prysm/v3/proto/prysm/v1alpha1"
)
var _ = Pool(&Store{})
// Pool defines the necessary methods for Prysm sync pool to serve
// validators. In the current design, aggregated attestations
// are used by proposers and sync committee messages are used by
// sync aggregators.
type Pool interface {
// Methods for Sync Contributions.
SaveSyncCommitteeContribution(contr *ethpb.SyncCommitteeContribution) error
SyncCommitteeContributions(slot types.Slot) ([]*ethpb.SyncCommitteeContribution, error)
// Methods for Sync Committee Messages.
SaveSyncCommitteeMessage(sig *ethpb.SyncCommitteeMessage) error
SyncCommitteeMessages(slot types.Slot) ([]*ethpb.SyncCommitteeMessage, error)
}
// NewPool returns the sync committee store fulfilling the pool interface.
func NewPool() Pool {
return NewStore()
}