certusone
/
tpuproxy
mirror of https://github.com/certusone/tpuproxy.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

gossip: improve schema

This commit is contained in:
Richard Patel 2022-09-08 10:42:11 +02:00
parent 275d51581c
commit 7b0291dd85
2 changed files with 54 additions and 46 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

48
pkg/gossip/schema.go
View File

@ -1939,8 +1939,8 @@ func BincodeDeserializeMessage(input []byte) (Message, error) {
} }
type Message__PullRequest struct { type Message__PullRequest struct {
Field0 CrdsFilter Filter CrdsFilter
Field1 CrdsValue Value CrdsValue
} }
func (*Message__PullRequest) isMessage() {} func (*Message__PullRequest) isMessage() {}
@ -1950,10 +1950,10 @@ func (obj *Message__PullRequest) Serialize(serializer serde.Serializer) error {
return err return err
} }
serializer.SerializeVariantIndex(0) serializer.SerializeVariantIndex(0)
if err := obj.Field0.Serialize(serializer); err != nil { if err := obj.Filter.Serialize(serializer); err != nil {
return err return err
} }
if err := obj.Field1.Serialize(serializer); err != nil { if err := obj.Value.Serialize(serializer); err != nil {
return err return err
} }
serializer.DecreaseContainerDepth() serializer.DecreaseContainerDepth()
@ -1977,12 +1977,12 @@ func load_Message__PullRequest(deserializer serde.Deserializer) (Message__PullRe
return obj, err return obj, err
} }
if val, err := DeserializeCrdsFilter(deserializer); err == nil { if val, err := DeserializeCrdsFilter(deserializer); err == nil {
obj.Field0 = val obj.Filter = val
} else { } else {
return obj, err return obj, err
} }
if val, err := DeserializeCrdsValue(deserializer); err == nil { if val, err := DeserializeCrdsValue(deserializer); err == nil {
obj.Field1 = val obj.Value = val
} else { } else {
return obj, err return obj, err
} }
@ -1991,8 +1991,8 @@ func load_Message__PullRequest(deserializer serde.Deserializer) (Message__PullRe
} }
type Message__PullResponse struct { type Message__PullResponse struct {
Field0 Pubkey Pubkey Pubkey
Field1 []CrdsValue Values []CrdsValue
} }
func (*Message__PullResponse) isMessage() {} func (*Message__PullResponse) isMessage() {}
@ -2002,10 +2002,10 @@ func (obj *Message__PullResponse) Serialize(serializer serde.Serializer) error {
return err return err
} }
serializer.SerializeVariantIndex(1) serializer.SerializeVariantIndex(1)
if err := obj.Field0.Serialize(serializer); err != nil { if err := obj.Pubkey.Serialize(serializer); err != nil {
return err return err
} }
if err := serialize_vector_CrdsValue(obj.Field1, serializer); err != nil { if err := serialize_vector_CrdsValue(obj.Values, serializer); err != nil {
return err return err
} }
serializer.DecreaseContainerDepth() serializer.DecreaseContainerDepth()
@ -2029,12 +2029,12 @@ func load_Message__PullResponse(deserializer serde.Deserializer) (Message__PullR
return obj, err return obj, err
} }
if val, err := DeserializePubkey(deserializer); err == nil { if val, err := DeserializePubkey(deserializer); err == nil {
obj.Field0 = val obj.Pubkey = val
} else { } else {
return obj, err return obj, err
} }
if val, err := deserialize_vector_CrdsValue(deserializer); err == nil { if val, err := deserialize_vector_CrdsValue(deserializer); err == nil {
obj.Field1 = val obj.Values = val
} else { } else {
return obj, err return obj, err
} }
@ -2043,8 +2043,8 @@ func load_Message__PullResponse(deserializer serde.Deserializer) (Message__PullR
} }
type Message__PushMessage struct { type Message__PushMessage struct {
Field0 Pubkey Pubkey Pubkey
Field1 []CrdsValue Values []CrdsValue
} }
func (*Message__PushMessage) isMessage() {} func (*Message__PushMessage) isMessage() {}
@ -2054,10 +2054,10 @@ func (obj *Message__PushMessage) Serialize(serializer serde.Serializer) error {
return err return err
} }
serializer.SerializeVariantIndex(2) serializer.SerializeVariantIndex(2)
if err := obj.Field0.Serialize(serializer); err != nil { if err := obj.Pubkey.Serialize(serializer); err != nil {
return err return err
} }
if err := serialize_vector_CrdsValue(obj.Field1, serializer); err != nil { if err := serialize_vector_CrdsValue(obj.Values, serializer); err != nil {
return err return err
} }
serializer.DecreaseContainerDepth() serializer.DecreaseContainerDepth()
@ -2081,12 +2081,12 @@ func load_Message__PushMessage(deserializer serde.Deserializer) (Message__PushMe
return obj, err return obj, err
} }
if val, err := DeserializePubkey(deserializer); err == nil { if val, err := DeserializePubkey(deserializer); err == nil {
obj.Field0 = val obj.Pubkey = val
} else { } else {
return obj, err return obj, err
} }
if val, err := deserialize_vector_CrdsValue(deserializer); err == nil { if val, err := deserialize_vector_CrdsValue(deserializer); err == nil {
obj.Field1 = val obj.Values = val
} else { } else {
return obj, err return obj, err
} }
@ -2095,8 +2095,8 @@ func load_Message__PushMessage(deserializer serde.Deserializer) (Message__PushMe
} }
type Message__PruneMessage struct { type Message__PruneMessage struct {
Field0 Pubkey Pubkey Pubkey
Field1 PruneData Data PruneData
} }
func (*Message__PruneMessage) isMessage() {} func (*Message__PruneMessage) isMessage() {}
@ -2106,10 +2106,10 @@ func (obj *Message__PruneMessage) Serialize(serializer serde.Serializer) error {
return err return err
} }
serializer.SerializeVariantIndex(3) serializer.SerializeVariantIndex(3)
if err := obj.Field0.Serialize(serializer); err != nil { if err := obj.Pubkey.Serialize(serializer); err != nil {
return err return err
} }
if err := obj.Field1.Serialize(serializer); err != nil { if err := obj.Data.Serialize(serializer); err != nil {
return err return err
} }
serializer.DecreaseContainerDepth() serializer.DecreaseContainerDepth()
@ -2133,12 +2133,12 @@ func load_Message__PruneMessage(deserializer serde.Deserializer) (Message__Prune
return obj, err return obj, err
} }
if val, err := DeserializePubkey(deserializer); err == nil { if val, err := DeserializePubkey(deserializer); err == nil {
obj.Field0 = val obj.Pubkey = val
} else { } else {
return obj, err return obj, err
} }
if val, err := DeserializePruneData(deserializer); err == nil { if val, err := DeserializePruneData(deserializer); err == nil {
obj.Field1 = val obj.Data = val
} else { } else {
return obj, err return obj, err
} }

52
pkg/gossip/schema.yaml
View File

@ -39,26 +39,34 @@ Message:
ENUM: ENUM:
0: 0:
PullRequest: PullRequest:
TUPLE: STRUCT:
- TYPENAME: CrdsFilter - filter:
- TYPENAME: CrdsValue TYPENAME: CrdsFilter
- value:
TYPENAME: CrdsValue
1: 1:
PullResponse: PullResponse:
TUPLE: STRUCT:
- TYPENAME: Pubkey - pubkey:
- SEQ: TYPENAME: Pubkey
TYPENAME: CrdsValue - values:
SEQ:
TYPENAME: CrdsValue
2: 2:
PushMessage: PushMessage:
TUPLE: STRUCT:
- TYPENAME: Pubkey - pubkey:
- SEQ: TYPENAME: Pubkey
TYPENAME: CrdsValue - values:
SEQ:
TYPENAME: CrdsValue
3: 3:
PruneMessage: PruneMessage:
TUPLE: STRUCT:
- TYPENAME: Pubkey - pubkey:
- TYPENAME: PruneData TYPENAME: Pubkey
- data:
TYPENAME: PruneData
4: 4:
Ping: Ping:
NEWTYPE: NEWTYPE:
@ -67,6 +75,14 @@ Message:
Pong: Pong:
NEWTYPE: NEWTYPE:
TYPENAME: Ping TYPENAME: Ping
Ping:
STRUCT:
- from:
TYPENAME: Pubkey
- token:
TYPENAME: Hash
- signature:
TYPENAME: Signature
# ------------------------ # ------------------------
# CRDS # CRDS
@ -321,11 +337,3 @@ PruneData:
- destination: - destination:
TYPENAME: Pubkey TYPENAME: Pubkey
- wallclock: U64 - wallclock: U64
Ping:
STRUCT:
- from:
TYPENAME: Pubkey
- token:
TYPENAME: Hash
- signature:
TYPENAME: Signature