gossip: add Crds Pubkey accessor

This commit is contained in:
Richard Patel 2022-09-08 18:57:57 +02:00
parent 9a94d4e982
commit 6bad7ba959
1 changed files with 45 additions and 0 deletions

View File

@ -605,6 +605,7 @@ type CrdsData interface {
isCrdsData()
Serialize(serializer serde.Serializer) error
BincodeSerialize() ([]byte, error)
Pubkey() *Pubkey
}
func DeserializeCrdsData(deserializer serde.Deserializer) (CrdsData, error) {
@ -738,6 +739,10 @@ func (obj *CrdsData__ContactInfo) BincodeSerialize() ([]byte, error) {
return serializer.GetBytes(), nil
}
func (obj *CrdsData__ContactInfo) Pubkey() *Pubkey {
return &obj.Value.Id
}
func load_CrdsData__ContactInfo(deserializer serde.Deserializer) (CrdsData__ContactInfo, error) {
var obj CrdsData__ContactInfo
if err := deserializer.IncreaseContainerDepth(); err != nil {
@ -785,6 +790,10 @@ func (obj *CrdsData__Vote) BincodeSerialize() ([]byte, error) {
return serializer.GetBytes(), nil
}
func (obj *CrdsData__Vote) Pubkey() *Pubkey {
return &obj.Field1.From
}
func load_CrdsData__Vote(deserializer serde.Deserializer) (CrdsData__Vote, error) {
var obj CrdsData__Vote
if err := deserializer.IncreaseContainerDepth(); err != nil {
@ -837,6 +846,10 @@ func (obj *CrdsData__LowestSlot) BincodeSerialize() ([]byte, error) {
return serializer.GetBytes(), nil
}
func (obj *CrdsData__LowestSlot) Pubkey() *Pubkey {
return &obj.Field1.From
}
func load_CrdsData__LowestSlot(deserializer serde.Deserializer) (CrdsData__LowestSlot, error) {
var obj CrdsData__LowestSlot
if err := deserializer.IncreaseContainerDepth(); err != nil {
@ -885,6 +898,10 @@ func (obj *CrdsData__SnapshotHashes) BincodeSerialize() ([]byte, error) {
return serializer.GetBytes(), nil
}
func (obj *CrdsData__SnapshotHashes) Pubkey() *Pubkey {
return &obj.Value.From
}
func load_CrdsData__SnapshotHashes(deserializer serde.Deserializer) (CrdsData__SnapshotHashes, error) {
var obj CrdsData__SnapshotHashes
if err := deserializer.IncreaseContainerDepth(); err != nil {
@ -928,6 +945,10 @@ func (obj *CrdsData__AccountsHashes) BincodeSerialize() ([]byte, error) {
return serializer.GetBytes(), nil
}
func (obj *CrdsData__AccountsHashes) Pubkey() *Pubkey {
return &obj.Value.From
}
func load_CrdsData__AccountsHashes(deserializer serde.Deserializer) (CrdsData__AccountsHashes, error) {
var obj CrdsData__AccountsHashes
if err := deserializer.IncreaseContainerDepth(); err != nil {
@ -975,6 +996,10 @@ func (obj *CrdsData__EpochSlots) BincodeSerialize() ([]byte, error) {
return serializer.GetBytes(), nil
}
func (obj *CrdsData__EpochSlots) Pubkey() *Pubkey {
return &obj.Field1.From
}
func load_CrdsData__EpochSlots(deserializer serde.Deserializer) (CrdsData__EpochSlots, error) {
var obj CrdsData__EpochSlots
if err := deserializer.IncreaseContainerDepth(); err != nil {
@ -1043,6 +1068,10 @@ func (obj *CrdsData__LegacyVersion) BincodeSerialize() ([]byte, error) {
return serializer.GetBytes(), nil
}
func (obj *CrdsData__LegacyVersion) Pubkey() *Pubkey {
return &obj.From
}
func load_CrdsData__LegacyVersion(deserializer serde.Deserializer) (CrdsData__LegacyVersion, error) {
var obj CrdsData__LegacyVersion
if err := deserializer.IncreaseContainerDepth(); err != nil {
@ -1135,6 +1164,10 @@ func (obj *CrdsData__Version) BincodeSerialize() ([]byte, error) {
return serializer.GetBytes(), nil
}
func (obj *CrdsData__Version) Pubkey() *Pubkey {
return &obj.From
}
func load_CrdsData__Version(deserializer serde.Deserializer) (CrdsData__Version, error) {
var obj CrdsData__Version
if err := deserializer.IncreaseContainerDepth(); err != nil {
@ -1220,6 +1253,10 @@ func (obj *CrdsData__NodeInstance) BincodeSerialize() ([]byte, error) {
return serializer.GetBytes(), nil
}
func (obj *CrdsData__NodeInstance) Pubkey() *Pubkey {
return &obj.From
}
func load_CrdsData__NodeInstance(deserializer serde.Deserializer) (CrdsData__NodeInstance, error) {
var obj CrdsData__NodeInstance
if err := deserializer.IncreaseContainerDepth(); err != nil {
@ -1282,6 +1319,10 @@ func (obj *CrdsData__DuplicateShred) BincodeSerialize() ([]byte, error) {
return serializer.GetBytes(), nil
}
func (obj *CrdsData__DuplicateShred) Pubkey() *Pubkey {
return &obj.Field1.From
}
func load_CrdsData__DuplicateShred(deserializer serde.Deserializer) (CrdsData__DuplicateShred, error) {
var obj CrdsData__DuplicateShred
if err := deserializer.IncreaseContainerDepth(); err != nil {
@ -1330,6 +1371,10 @@ func (obj *CrdsData__IncrementalSnapshotHashes) BincodeSerialize() ([]byte, erro
return serializer.GetBytes(), nil
}
func (obj *CrdsData__IncrementalSnapshotHashes) Pubkey() *Pubkey {
return &obj.Value.From
}
func load_CrdsData__IncrementalSnapshotHashes(deserializer serde.Deserializer) (CrdsData__IncrementalSnapshotHashes, error) {
var obj CrdsData__IncrementalSnapshotHashes
if err := deserializer.IncreaseContainerDepth(); err != nil {