gossipv1

package
v0.0.0-...-7ef1159 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 19, 2024 License: Apache-2.0 Imports: 4 Imported by: 40

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_gossip_v1_gossip_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type ChainGovernorConfig 

type ChainGovernorConfig struct {
	NodeName          string                       `protobuf:"bytes,1,opt,name=node_name,json=nodeName,proto3" json:"node_name,omitempty"`
	Counter           int64                        `protobuf:"varint,2,opt,name=counter,proto3" json:"counter,omitempty"`
	Timestamp         int64                        `protobuf:"varint,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Chains            []*ChainGovernorConfig_Chain `protobuf:"bytes,4,rep,name=chains,proto3" json:"chains,omitempty"`
	Tokens            []*ChainGovernorConfig_Token `protobuf:"bytes,5,rep,name=tokens,proto3" json:"tokens,omitempty"`
	FlowCancelEnabled bool                         `protobuf:"varint,6,opt,name=flow_cancel_enabled,json=flowCancelEnabled,proto3" json:"flow_cancel_enabled,omitempty"`
	// contains filtered or unexported fields
}

func (*ChainGovernorConfig) Descriptor deprecated 

func (*ChainGovernorConfig) Descriptor() ([]byte, []int)

Deprecated: Use ChainGovernorConfig.ProtoReflect.Descriptor instead.

func (*ChainGovernorConfig) GetChains 

func (x *ChainGovernorConfig) GetChains() []*ChainGovernorConfig_Chain

func (*ChainGovernorConfig) GetCounter 

func (x *ChainGovernorConfig) GetCounter() int64

func (*ChainGovernorConfig) GetFlowCancelEnabled 

func (x *ChainGovernorConfig) GetFlowCancelEnabled() bool

func (*ChainGovernorConfig) GetNodeName 

func (x *ChainGovernorConfig) GetNodeName() string

func (*ChainGovernorConfig) GetTimestamp 

func (x *ChainGovernorConfig) GetTimestamp() int64

func (*ChainGovernorConfig) GetTokens 

func (x *ChainGovernorConfig) GetTokens() []*ChainGovernorConfig_Token

func (*ChainGovernorConfig) ProtoMessage 

func (*ChainGovernorConfig) ProtoMessage()

func (*ChainGovernorConfig) ProtoReflect 

func (x *ChainGovernorConfig) ProtoReflect() protoreflect.Message

func (*ChainGovernorConfig) Reset 

func (x *ChainGovernorConfig) Reset()

func (*ChainGovernorConfig) String 

func (x *ChainGovernorConfig) String() string

type ChainGovernorConfig_Chain 

type ChainGovernorConfig_Chain struct {
	ChainId            uint32 `protobuf:"varint,1,opt,name=chain_id,json=chainId,proto3" json:"chain_id,omitempty"`
	NotionalLimit      uint64 `protobuf:"varint,2,opt,name=notional_limit,json=notionalLimit,proto3" json:"notional_limit,omitempty"`
	BigTransactionSize uint64 `protobuf:"varint,3,opt,name=big_transaction_size,json=bigTransactionSize,proto3" json:"big_transaction_size,omitempty"`
	// contains filtered or unexported fields
}

func (*ChainGovernorConfig_Chain) Descriptor deprecated 

func (*ChainGovernorConfig_Chain) Descriptor() ([]byte, []int)

Deprecated: Use ChainGovernorConfig_Chain.ProtoReflect.Descriptor instead.

func (*ChainGovernorConfig_Chain) GetBigTransactionSize 

func (x *ChainGovernorConfig_Chain) GetBigTransactionSize() uint64

func (*ChainGovernorConfig_Chain) GetChainId 

func (x *ChainGovernorConfig_Chain) GetChainId() uint32

func (*ChainGovernorConfig_Chain) GetNotionalLimit 

func (x *ChainGovernorConfig_Chain) GetNotionalLimit() uint64

func (*ChainGovernorConfig_Chain) ProtoMessage 

func (*ChainGovernorConfig_Chain) ProtoMessage()

func (*ChainGovernorConfig_Chain) ProtoReflect 

func (x *ChainGovernorConfig_Chain) ProtoReflect() protoreflect.Message

func (*ChainGovernorConfig_Chain) Reset 

func (x *ChainGovernorConfig_Chain) Reset()

func (*ChainGovernorConfig_Chain) String 

func (x *ChainGovernorConfig_Chain) String() string

type ChainGovernorConfig_Token 

type ChainGovernorConfig_Token struct {
	OriginChainId uint32  `protobuf:"varint,1,opt,name=origin_chain_id,json=originChainId,proto3" json:"origin_chain_id,omitempty"`
	OriginAddress string  `protobuf:"bytes,2,opt,name=origin_address,json=originAddress,proto3" json:"origin_address,omitempty"` // human-readable hex-encoded (leading 0x)
	Price         float32 `protobuf:"fixed32,3,opt,name=price,proto3" json:"price,omitempty"`
	// contains filtered or unexported fields
}

func (*ChainGovernorConfig_Token) Descriptor deprecated 

func (*ChainGovernorConfig_Token) Descriptor() ([]byte, []int)

Deprecated: Use ChainGovernorConfig_Token.ProtoReflect.Descriptor instead.

func (*ChainGovernorConfig_Token) GetOriginAddress 

func (x *ChainGovernorConfig_Token) GetOriginAddress() string

func (*ChainGovernorConfig_Token) GetOriginChainId 

func (x *ChainGovernorConfig_Token) GetOriginChainId() uint32

func (*ChainGovernorConfig_Token) GetPrice 

func (x *ChainGovernorConfig_Token) GetPrice() float32

func (*ChainGovernorConfig_Token) ProtoMessage 

func (*ChainGovernorConfig_Token) ProtoMessage()

func (*ChainGovernorConfig_Token) ProtoReflect 

func (x *ChainGovernorConfig_Token) ProtoReflect() protoreflect.Message

func (*ChainGovernorConfig_Token) Reset 

func (x *ChainGovernorConfig_Token) Reset()

func (*ChainGovernorConfig_Token) String 

func (x *ChainGovernorConfig_Token) String() string

type ChainGovernorStatus 

type ChainGovernorStatus struct {
	NodeName  string                       `protobuf:"bytes,1,opt,name=node_name,json=nodeName,proto3" json:"node_name,omitempty"`
	Counter   int64                        `protobuf:"varint,2,opt,name=counter,proto3" json:"counter,omitempty"`
	Timestamp int64                        `protobuf:"varint,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Chains    []*ChainGovernorStatus_Chain `protobuf:"bytes,4,rep,name=chains,proto3" json:"chains,omitempty"`
	// contains filtered or unexported fields
}

func (*ChainGovernorStatus) Descriptor deprecated 

func (*ChainGovernorStatus) Descriptor() ([]byte, []int)

Deprecated: Use ChainGovernorStatus.ProtoReflect.Descriptor instead.

func (*ChainGovernorStatus) GetChains 

func (x *ChainGovernorStatus) GetChains() []*ChainGovernorStatus_Chain

func (*ChainGovernorStatus) GetCounter 

func (x *ChainGovernorStatus) GetCounter() int64

func (*ChainGovernorStatus) GetNodeName 

func (x *ChainGovernorStatus) GetNodeName() string

func (*ChainGovernorStatus) GetTimestamp 

func (x *ChainGovernorStatus) GetTimestamp() int64

func (*ChainGovernorStatus) ProtoMessage 

func (*ChainGovernorStatus) ProtoMessage()

func (*ChainGovernorStatus) ProtoReflect 

func (x *ChainGovernorStatus) ProtoReflect() protoreflect.Message

func (*ChainGovernorStatus) Reset 

func (x *ChainGovernorStatus) Reset()

func (*ChainGovernorStatus) String 

func (x *ChainGovernorStatus) String() string

type ChainGovernorStatus_Chain 

type ChainGovernorStatus_Chain struct {
	ChainId                      uint32                         `protobuf:"varint,1,opt,name=chain_id,json=chainId,proto3" json:"chain_id,omitempty"`
	RemainingAvailableNotional   uint64                         `` /* 142-byte string literal not displayed */
	Emitters                     []*ChainGovernorStatus_Emitter `protobuf:"bytes,3,rep,name=emitters,proto3" json:"emitters,omitempty"`
	SmallTxNetNotionalValue      int64                          `` /* 137-byte string literal not displayed */
	SmallTxOutgoingNotionalValue uint64                         `` /* 152-byte string literal not displayed */
	FlowCancelNotionalValue      uint64                         `` /* 135-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ChainGovernorStatus_Chain) Descriptor deprecated 

func (*ChainGovernorStatus_Chain) Descriptor() ([]byte, []int)

Deprecated: Use ChainGovernorStatus_Chain.ProtoReflect.Descriptor instead.

func (*ChainGovernorStatus_Chain) GetChainId 

func (x *ChainGovernorStatus_Chain) GetChainId() uint32

func (*ChainGovernorStatus_Chain) GetEmitters 

func (x *ChainGovernorStatus_Chain) GetEmitters() []*ChainGovernorStatus_Emitter

func (*ChainGovernorStatus_Chain) GetFlowCancelNotionalValue 

func (x *ChainGovernorStatus_Chain) GetFlowCancelNotionalValue() uint64

func (*ChainGovernorStatus_Chain) GetRemainingAvailableNotional 

func (x *ChainGovernorStatus_Chain) GetRemainingAvailableNotional() uint64

func (*ChainGovernorStatus_Chain) GetSmallTxNetNotionalValue 

func (x *ChainGovernorStatus_Chain) GetSmallTxNetNotionalValue() int64

func (*ChainGovernorStatus_Chain) GetSmallTxOutgoingNotionalValue 

func (x *ChainGovernorStatus_Chain) GetSmallTxOutgoingNotionalValue() uint64

func (*ChainGovernorStatus_Chain) ProtoMessage 

func (*ChainGovernorStatus_Chain) ProtoMessage()

func (*ChainGovernorStatus_Chain) ProtoReflect 

func (x *ChainGovernorStatus_Chain) ProtoReflect() protoreflect.Message

func (*ChainGovernorStatus_Chain) Reset 

func (x *ChainGovernorStatus_Chain) Reset()

func (*ChainGovernorStatus_Chain) String 

func (x *ChainGovernorStatus_Chain) String() string

type ChainGovernorStatus_Emitter 

type ChainGovernorStatus_Emitter struct {
	EmitterAddress    string                             `protobuf:"bytes,1,opt,name=emitter_address,json=emitterAddress,proto3" json:"emitter_address,omitempty"` // human-readable hex-encoded (leading 0x)
	TotalEnqueuedVaas uint64                             `protobuf:"varint,2,opt,name=total_enqueued_vaas,json=totalEnqueuedVaas,proto3" json:"total_enqueued_vaas,omitempty"`
	EnqueuedVaas      []*ChainGovernorStatus_EnqueuedVAA `protobuf:"bytes,3,rep,name=enqueued_vaas,json=enqueuedVaas,proto3" json:"enqueued_vaas,omitempty"` // Only the first 20 will be included.
	// contains filtered or unexported fields
}

func (*ChainGovernorStatus_Emitter) Descriptor deprecated 

func (*ChainGovernorStatus_Emitter) Descriptor() ([]byte, []int)

Deprecated: Use ChainGovernorStatus_Emitter.ProtoReflect.Descriptor instead.

func (*ChainGovernorStatus_Emitter) GetEmitterAddress 

func (x *ChainGovernorStatus_Emitter) GetEmitterAddress() string

func (*ChainGovernorStatus_Emitter) GetEnqueuedVaas 

func (x *ChainGovernorStatus_Emitter) GetEnqueuedVaas() []*ChainGovernorStatus_EnqueuedVAA

func (*ChainGovernorStatus_Emitter) GetTotalEnqueuedVaas 

func (x *ChainGovernorStatus_Emitter) GetTotalEnqueuedVaas() uint64

func (*ChainGovernorStatus_Emitter) ProtoMessage 

func (*ChainGovernorStatus_Emitter) ProtoMessage()

func (*ChainGovernorStatus_Emitter) ProtoReflect 

func (x *ChainGovernorStatus_Emitter) ProtoReflect() protoreflect.Message

func (*ChainGovernorStatus_Emitter) Reset 

func (x *ChainGovernorStatus_Emitter) Reset()

func (*ChainGovernorStatus_Emitter) String 

func (x *ChainGovernorStatus_Emitter) String() string

type ChainGovernorStatus_EnqueuedVAA 

type ChainGovernorStatus_EnqueuedVAA struct {
	Sequence      uint64 `protobuf:"varint,1,opt,name=sequence,proto3" json:"sequence,omitempty"` // Chain and emitter address are assumed.
	ReleaseTime   uint32 `protobuf:"varint,2,opt,name=release_time,json=releaseTime,proto3" json:"release_time,omitempty"`
	NotionalValue uint64 `protobuf:"varint,3,opt,name=notional_value,json=notionalValue,proto3" json:"notional_value,omitempty"`
	TxHash        string `protobuf:"bytes,4,opt,name=tx_hash,json=txHash,proto3" json:"tx_hash,omitempty"`
	// contains filtered or unexported fields
}

func (*ChainGovernorStatus_EnqueuedVAA) Descriptor deprecated 

func (*ChainGovernorStatus_EnqueuedVAA) Descriptor() ([]byte, []int)

Deprecated: Use ChainGovernorStatus_EnqueuedVAA.ProtoReflect.Descriptor instead.

func (*ChainGovernorStatus_EnqueuedVAA) GetNotionalValue 

func (x *ChainGovernorStatus_EnqueuedVAA) GetNotionalValue() uint64

func (*ChainGovernorStatus_EnqueuedVAA) GetReleaseTime 

func (x *ChainGovernorStatus_EnqueuedVAA) GetReleaseTime() uint32

func (*ChainGovernorStatus_EnqueuedVAA) GetSequence 

func (x *ChainGovernorStatus_EnqueuedVAA) GetSequence() uint64

func (*ChainGovernorStatus_EnqueuedVAA) GetTxHash 

func (x *ChainGovernorStatus_EnqueuedVAA) GetTxHash() string

func (*ChainGovernorStatus_EnqueuedVAA) ProtoMessage 

func (*ChainGovernorStatus_EnqueuedVAA) ProtoMessage()

func (*ChainGovernorStatus_EnqueuedVAA) ProtoReflect 

func (x *ChainGovernorStatus_EnqueuedVAA) ProtoReflect() protoreflect.Message

func (*ChainGovernorStatus_EnqueuedVAA) Reset 

func (x *ChainGovernorStatus_EnqueuedVAA) Reset()

func (*ChainGovernorStatus_EnqueuedVAA) String 

func (x *ChainGovernorStatus_EnqueuedVAA) String() string

type GossipMessage 

type GossipMessage struct {

	// Types that are assignable to Message:
	//
	//	*GossipMessage_SignedObservation
	//	*GossipMessage_SignedHeartbeat
	//	*GossipMessage_SignedVaaWithQuorum
	//	*GossipMessage_SignedObservationRequest
	//	*GossipMessage_SignedChainGovernorConfig
	//	*GossipMessage_SignedChainGovernorStatus
	//	*GossipMessage_SignedQueryRequest
	//	*GossipMessage_SignedQueryResponse
	//	*GossipMessage_SignedObservationBatch
	Message isGossipMessage_Message `protobuf_oneof:"message"`
	// contains filtered or unexported fields
}

func (*GossipMessage) Descriptor deprecated 

func (*GossipMessage) Descriptor() ([]byte, []int)

Deprecated: Use GossipMessage.ProtoReflect.Descriptor instead.

func (*GossipMessage) GetMessage 

func (m *GossipMessage) GetMessage() isGossipMessage_Message

func (*GossipMessage) GetSignedChainGovernorConfig 

func (x *GossipMessage) GetSignedChainGovernorConfig() *SignedChainGovernorConfig

func (*GossipMessage) GetSignedChainGovernorStatus 

func (x *GossipMessage) GetSignedChainGovernorStatus() *SignedChainGovernorStatus

func (*GossipMessage) GetSignedHeartbeat 

func (x *GossipMessage) GetSignedHeartbeat() *SignedHeartbeat

func (*GossipMessage) GetSignedObservation 

func (x *GossipMessage) GetSignedObservation() *SignedObservation

func (*GossipMessage) GetSignedObservationBatch 

func (x *GossipMessage) GetSignedObservationBatch() *SignedObservationBatch

func (*GossipMessage) GetSignedObservationRequest 

func (x *GossipMessage) GetSignedObservationRequest() *SignedObservationRequest

func (*GossipMessage) GetSignedQueryRequest 

func (x *GossipMessage) GetSignedQueryRequest() *SignedQueryRequest

func (*GossipMessage) GetSignedQueryResponse 

func (x *GossipMessage) GetSignedQueryResponse() *SignedQueryResponse

func (*GossipMessage) GetSignedVaaWithQuorum 

func (x *GossipMessage) GetSignedVaaWithQuorum() *SignedVAAWithQuorum

func (*GossipMessage) ProtoMessage 

func (*GossipMessage) ProtoMessage()

func (*GossipMessage) ProtoReflect 

func (x *GossipMessage) ProtoReflect() protoreflect.Message

func (*GossipMessage) Reset 

func (x *GossipMessage) Reset()

func (*GossipMessage) String 

func (x *GossipMessage) String() string

type GossipMessage_SignedChainGovernorConfig 

type GossipMessage_SignedChainGovernorConfig struct {
	SignedChainGovernorConfig *SignedChainGovernorConfig `protobuf:"bytes,8,opt,name=signed_chain_governor_config,json=signedChainGovernorConfig,proto3,oneof"`
}

type GossipMessage_SignedChainGovernorStatus 

type GossipMessage_SignedChainGovernorStatus struct {
	SignedChainGovernorStatus *SignedChainGovernorStatus `protobuf:"bytes,9,opt,name=signed_chain_governor_status,json=signedChainGovernorStatus,proto3,oneof"`
}

type GossipMessage_SignedHeartbeat 

type GossipMessage_SignedHeartbeat struct {
	SignedHeartbeat *SignedHeartbeat `protobuf:"bytes,3,opt,name=signed_heartbeat,json=signedHeartbeat,proto3,oneof"`
}

type GossipMessage_SignedObservation 

type GossipMessage_SignedObservation struct {
	SignedObservation *SignedObservation `protobuf:"bytes,2,opt,name=signed_observation,json=signedObservation,proto3,oneof"`
}

type GossipMessage_SignedObservationBatch 

type GossipMessage_SignedObservationBatch struct {
	SignedObservationBatch *SignedObservationBatch `protobuf:"bytes,12,opt,name=signed_observation_batch,json=signedObservationBatch,proto3,oneof"`
}

type GossipMessage_SignedObservationRequest 

type GossipMessage_SignedObservationRequest struct {
	SignedObservationRequest *SignedObservationRequest `protobuf:"bytes,5,opt,name=signed_observation_request,json=signedObservationRequest,proto3,oneof"`
}

type GossipMessage_SignedQueryRequest 

type GossipMessage_SignedQueryRequest struct {
	SignedQueryRequest *SignedQueryRequest `protobuf:"bytes,10,opt,name=signed_query_request,json=signedQueryRequest,proto3,oneof"`
}

type GossipMessage_SignedQueryResponse 

type GossipMessage_SignedQueryResponse struct {
	SignedQueryResponse *SignedQueryResponse `protobuf:"bytes,11,opt,name=signed_query_response,json=signedQueryResponse,proto3,oneof"`
}

type GossipMessage_SignedVaaWithQuorum 

type GossipMessage_SignedVaaWithQuorum struct {
	SignedVaaWithQuorum *SignedVAAWithQuorum `protobuf:"bytes,4,opt,name=signed_vaa_with_quorum,json=signedVaaWithQuorum,proto3,oneof"`
}

type Heartbeat 

type Heartbeat struct {

	// The node's arbitrarily chosen, untrusted nodeName.
	NodeName string `protobuf:"bytes,1,opt,name=node_name,json=nodeName,proto3" json:"node_name,omitempty"`
	// A monotonic counter that resets to zero on startup.
	Counter int64 `protobuf:"varint,2,opt,name=counter,proto3" json:"counter,omitempty"`
	// UNIX wall time.
	Timestamp int64                `protobuf:"varint,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Networks  []*Heartbeat_Network `protobuf:"bytes,4,rep,name=networks,proto3" json:"networks,omitempty"`
	// Human-readable representation of the current bridge node release.
	Version string `protobuf:"bytes,5,opt,name=version,proto3" json:"version,omitempty"`
	// Human-readable representation of the guardian key's address.
	GuardianAddr string `protobuf:"bytes,6,opt,name=guardian_addr,json=guardianAddr,proto3" json:"guardian_addr,omitempty"`
	// UNIX boot timestamp.
	BootTimestamp int64 `protobuf:"varint,7,opt,name=boot_timestamp,json=bootTimestamp,proto3" json:"boot_timestamp,omitempty"`
	// List of features enabled on this node.
	Features []string `protobuf:"bytes,8,rep,name=features,proto3" json:"features,omitempty"`
	// (Optional) libp2p address of this node.
	P2PNodeId []byte `protobuf:"bytes,9,opt,name=p2p_node_id,json=p2pNodeId,proto3" json:"p2p_node_id,omitempty"`
	// contains filtered or unexported fields
}

P2P gossip heartbeats for network introspection purposes.

func (*Heartbeat) Descriptor deprecated 

func (*Heartbeat) Descriptor() ([]byte, []int)

Deprecated: Use Heartbeat.ProtoReflect.Descriptor instead.

func (*Heartbeat) GetBootTimestamp 

func (x *Heartbeat) GetBootTimestamp() int64

func (*Heartbeat) GetCounter 

func (x *Heartbeat) GetCounter() int64

func (*Heartbeat) GetFeatures 

func (x *Heartbeat) GetFeatures() []string

func (*Heartbeat) GetGuardianAddr 

func (x *Heartbeat) GetGuardianAddr() string

func (*Heartbeat) GetNetworks 

func (x *Heartbeat) GetNetworks() []*Heartbeat_Network

func (*Heartbeat) GetNodeName 

func (x *Heartbeat) GetNodeName() string

func (*Heartbeat) GetP2PNodeId 

func (x *Heartbeat) GetP2PNodeId() []byte

func (*Heartbeat) GetTimestamp 

func (x *Heartbeat) GetTimestamp() int64

func (*Heartbeat) GetVersion 

func (x *Heartbeat) GetVersion() string

func (*Heartbeat) ProtoMessage 

func (*Heartbeat) ProtoMessage()

func (*Heartbeat) ProtoReflect 

func (x *Heartbeat) ProtoReflect() protoreflect.Message

func (*Heartbeat) Reset 

func (x *Heartbeat) Reset()

func (*Heartbeat) String 

func (x *Heartbeat) String() string

type Heartbeat_Network 

type Heartbeat_Network struct {

	// Canonical chain ID.
	Id uint32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// Consensus height of the node.
	Height int64 `protobuf:"varint,2,opt,name=height,proto3" json:"height,omitempty"`
	// Chain-specific human-readable representation of the bridge contract address.
	ContractAddress string `protobuf:"bytes,3,opt,name=contract_address,json=contractAddress,proto3" json:"contract_address,omitempty"`
	// Connection error count
	ErrorCount uint64 `protobuf:"varint,4,opt,name=error_count,json=errorCount,proto3" json:"error_count,omitempty"`
	// Safe block height of the node, if supported.
	SafeHeight int64 `protobuf:"varint,5,opt,name=safe_height,json=safeHeight,proto3" json:"safe_height,omitempty"`
	// Finalized block height of the node, if supported.
	FinalizedHeight int64 `protobuf:"varint,6,opt,name=finalized_height,json=finalizedHeight,proto3" json:"finalized_height,omitempty"`
	// contains filtered or unexported fields
}

func (*Heartbeat_Network) Descriptor deprecated 

func (*Heartbeat_Network) Descriptor() ([]byte, []int)

Deprecated: Use Heartbeat_Network.ProtoReflect.Descriptor instead.

func (*Heartbeat_Network) GetContractAddress 

func (x *Heartbeat_Network) GetContractAddress() string

func (*Heartbeat_Network) GetErrorCount 

func (x *Heartbeat_Network) GetErrorCount() uint64

func (*Heartbeat_Network) GetFinalizedHeight 

func (x *Heartbeat_Network) GetFinalizedHeight() int64

func (*Heartbeat_Network) GetHeight 

func (x *Heartbeat_Network) GetHeight() int64

func (*Heartbeat_Network) GetId 

func (x *Heartbeat_Network) GetId() uint32

func (*Heartbeat_Network) GetSafeHeight 

func (x *Heartbeat_Network) GetSafeHeight() int64

func (*Heartbeat_Network) ProtoMessage 

func (*Heartbeat_Network) ProtoMessage()

func (*Heartbeat_Network) ProtoReflect 

func (x *Heartbeat_Network) ProtoReflect() protoreflect.Message

func (*Heartbeat_Network) Reset 

func (x *Heartbeat_Network) Reset()

func (*Heartbeat_Network) String 

func (x *Heartbeat_Network) String() string

type Observation 

type Observation struct {

	// The observation's deterministic, unique hash.
	Hash []byte `protobuf:"bytes,1,opt,name=hash,proto3" json:"hash,omitempty"`
	// ECSDA signature of the hash using the node's guardian key.
	Signature []byte `protobuf:"bytes,2,opt,name=signature,proto3" json:"signature,omitempty"`
	// Transaction hash this observation was made from.
	// Optional, included for observability.
	TxHash []byte `protobuf:"bytes,3,opt,name=tx_hash,json=txHash,proto3" json:"tx_hash,omitempty"`
	// Message ID (chain/emitter/seq) for this observation.
	// Optional, included for observability.
	MessageId string `protobuf:"bytes,4,opt,name=message_id,json=messageId,proto3" json:"message_id,omitempty"`
	// contains filtered or unexported fields
}

Observation defines a single observation that is contained in SignedObservationBatch

func (*Observation) Descriptor deprecated 

func (*Observation) Descriptor() ([]byte, []int)

Deprecated: Use Observation.ProtoReflect.Descriptor instead.

func (*Observation) GetHash 

func (x *Observation) GetHash() []byte

func (*Observation) GetMessageId 

func (x *Observation) GetMessageId() string

func (*Observation) GetSignature 

func (x *Observation) GetSignature() []byte

func (*Observation) GetTxHash 

func (x *Observation) GetTxHash() []byte

func (*Observation) ProtoMessage 

func (*Observation) ProtoMessage()

func (*Observation) ProtoReflect 

func (x *Observation) ProtoReflect() protoreflect.Message

func (*Observation) Reset 

func (x *Observation) Reset()

func (*Observation) String 

func (x *Observation) String() string

type ObservationRequest 

type ObservationRequest struct {
	ChainId uint32 `protobuf:"varint,1,opt,name=chain_id,json=chainId,proto3" json:"chain_id,omitempty"`
	TxHash  []byte `protobuf:"bytes,2,opt,name=tx_hash,json=txHash,proto3" json:"tx_hash,omitempty"`
	// contains filtered or unexported fields
}

func (*ObservationRequest) Descriptor deprecated 

func (*ObservationRequest) Descriptor() ([]byte, []int)

Deprecated: Use ObservationRequest.ProtoReflect.Descriptor instead.

func (*ObservationRequest) GetChainId 

func (x *ObservationRequest) GetChainId() uint32

func (*ObservationRequest) GetTxHash 

func (x *ObservationRequest) GetTxHash() []byte

func (*ObservationRequest) ProtoMessage 

func (*ObservationRequest) ProtoMessage()

func (*ObservationRequest) ProtoReflect 

func (x *ObservationRequest) ProtoReflect() protoreflect.Message

func (*ObservationRequest) Reset 

func (x *ObservationRequest) Reset()

func (*ObservationRequest) String 

func (x *ObservationRequest) String() string

type SignedChainGovernorConfig 

type SignedChainGovernorConfig struct {

	// Serialized ChainGovernorConfig message.
	Config []byte `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"`
	// ECDSA signature using the node's guardian key.
	Signature []byte `protobuf:"bytes,2,opt,name=signature,proto3" json:"signature,omitempty"`
	// Guardian address that signed this payload (truncated Eth address).
	GuardianAddr []byte `protobuf:"bytes,3,opt,name=guardian_addr,json=guardianAddr,proto3" json:"guardian_addr,omitempty"`
	// contains filtered or unexported fields
}

This message is published every five minutes.

func (*SignedChainGovernorConfig) Descriptor deprecated 

func (*SignedChainGovernorConfig) Descriptor() ([]byte, []int)

Deprecated: Use SignedChainGovernorConfig.ProtoReflect.Descriptor instead.

func (*SignedChainGovernorConfig) GetConfig 

func (x *SignedChainGovernorConfig) GetConfig() []byte

func (*SignedChainGovernorConfig) GetGuardianAddr 

func (x *SignedChainGovernorConfig) GetGuardianAddr() []byte

func (*SignedChainGovernorConfig) GetSignature 

func (x *SignedChainGovernorConfig) GetSignature() []byte

func (*SignedChainGovernorConfig) ProtoMessage 

func (*SignedChainGovernorConfig) ProtoMessage()

func (*SignedChainGovernorConfig) ProtoReflect 

func (x *SignedChainGovernorConfig) ProtoReflect() protoreflect.Message

func (*SignedChainGovernorConfig) Reset 

func (x *SignedChainGovernorConfig) Reset()

func (*SignedChainGovernorConfig) String 

func (x *SignedChainGovernorConfig) String() string

type SignedChainGovernorStatus 

type SignedChainGovernorStatus struct {

	// Serialized ChainGovernorStatus message.
	Status []byte `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// ECDSA signature using the node's guardian key.
	Signature []byte `protobuf:"bytes,2,opt,name=signature,proto3" json:"signature,omitempty"`
	// Guardian address that signed this payload (truncated Eth address).
	GuardianAddr []byte `protobuf:"bytes,3,opt,name=guardian_addr,json=guardianAddr,proto3" json:"guardian_addr,omitempty"`
	// contains filtered or unexported fields
}

This message is published every minute.

func (*SignedChainGovernorStatus) Descriptor deprecated 

func (*SignedChainGovernorStatus) Descriptor() ([]byte, []int)

Deprecated: Use SignedChainGovernorStatus.ProtoReflect.Descriptor instead.

func (*SignedChainGovernorStatus) GetGuardianAddr 

func (x *SignedChainGovernorStatus) GetGuardianAddr() []byte

func (*SignedChainGovernorStatus) GetSignature 

func (x *SignedChainGovernorStatus) GetSignature() []byte

func (*SignedChainGovernorStatus) GetStatus 

func (x *SignedChainGovernorStatus) GetStatus() []byte

func (*SignedChainGovernorStatus) ProtoMessage 

func (*SignedChainGovernorStatus) ProtoMessage()

func (*SignedChainGovernorStatus) ProtoReflect 

func (x *SignedChainGovernorStatus) ProtoReflect() protoreflect.Message

func (*SignedChainGovernorStatus) Reset 

func (x *SignedChainGovernorStatus) Reset()

func (*SignedChainGovernorStatus) String 

func (x *SignedChainGovernorStatus) String() string

type SignedHeartbeat 

type SignedHeartbeat struct {

	// Serialized Heartbeat message.
	Heartbeat []byte `protobuf:"bytes,1,opt,name=heartbeat,proto3" json:"heartbeat,omitempty"`
	// ECDSA signature using the node's guardian public key.
	Signature []byte `protobuf:"bytes,2,opt,name=signature,proto3" json:"signature,omitempty"`
	// Guardian address that signed this payload (truncated Eth address).
	// This is already contained in Heartbeat, however, we want to verify
	// the payload before we deserialize it.
	GuardianAddr []byte `protobuf:"bytes,3,opt,name=guardian_addr,json=guardianAddr,proto3" json:"guardian_addr,omitempty"`
	// contains filtered or unexported fields
}

func (*SignedHeartbeat) Descriptor deprecated 

func (*SignedHeartbeat) Descriptor() ([]byte, []int)

Deprecated: Use SignedHeartbeat.ProtoReflect.Descriptor instead.

func (*SignedHeartbeat) GetGuardianAddr 

func (x *SignedHeartbeat) GetGuardianAddr() []byte

func (*SignedHeartbeat) GetHeartbeat 

func (x *SignedHeartbeat) GetHeartbeat() []byte

func (*SignedHeartbeat) GetSignature 

func (x *SignedHeartbeat) GetSignature() []byte

func (*SignedHeartbeat) ProtoMessage 

func (*SignedHeartbeat) ProtoMessage()

func (*SignedHeartbeat) ProtoReflect 

func (x *SignedHeartbeat) ProtoReflect() protoreflect.Message

func (*SignedHeartbeat) Reset 

func (x *SignedHeartbeat) Reset()

func (*SignedHeartbeat) String 

func (x *SignedHeartbeat) String() string

type SignedObservation 

type SignedObservation struct {

	// Guardian pubkey as truncated eth address.
	Addr []byte `protobuf:"bytes,1,opt,name=addr,proto3" json:"addr,omitempty"`
	// The observation's deterministic, unique hash.
	Hash []byte `protobuf:"bytes,2,opt,name=hash,proto3" json:"hash,omitempty"`
	// ECSDA signature of the hash using the node's guardian key.
	Signature []byte `protobuf:"bytes,3,opt,name=signature,proto3" json:"signature,omitempty"`
	// Transaction hash this observation was made from.
	// Optional, included for observability.
	TxHash []byte `protobuf:"bytes,4,opt,name=tx_hash,json=txHash,proto3" json:"tx_hash,omitempty"`
	// Message ID (chain/emitter/seq) for this observation.
	// Optional, included for observability.
	MessageId string `protobuf:"bytes,5,opt,name=message_id,json=messageId,proto3" json:"message_id,omitempty"`
	// contains filtered or unexported fields
}

A SignedObservation is a signed statement by a given guardian node that they observed a given event.

Observations always result from an external, final event being observed. Examples are emitted messages in finalized blocks on a block or guardian set changes injected by node operators after reaching off-chain consensus.

The event is uniquely identified by its hashed (tx_hash, nonce, values...) tuple.

Other nodes will verify the signature. Once any node has observed a quorum of guardians submitting valid signatures for a given hash, they can be assembled into a VAA.

Messages without valid signature are dropped unceremoniously.

func (*SignedObservation) Descriptor deprecated 

func (*SignedObservation) Descriptor() ([]byte, []int)

Deprecated: Use SignedObservation.ProtoReflect.Descriptor instead.

func (*SignedObservation) GetAddr 

func (x *SignedObservation) GetAddr() []byte

func (*SignedObservation) GetHash 

func (x *SignedObservation) GetHash() []byte

func (*SignedObservation) GetMessageId 

func (x *SignedObservation) GetMessageId() string

func (*SignedObservation) GetSignature 

func (x *SignedObservation) GetSignature() []byte

func (*SignedObservation) GetTxHash 

func (x *SignedObservation) GetTxHash() []byte

func (*SignedObservation) ProtoMessage 

func (*SignedObservation) ProtoMessage()

func (*SignedObservation) ProtoReflect 

func (x *SignedObservation) ProtoReflect() protoreflect.Message

func (*SignedObservation) Reset 

func (x *SignedObservation) Reset()

func (*SignedObservation) String 

func (x *SignedObservation) String() string

type SignedObservationBatch 

type SignedObservationBatch struct {

	// Guardian pubkey as truncated eth address.
	Addr []byte `protobuf:"bytes,1,opt,name=addr,proto3" json:"addr,omitempty"`
	// The set of observations in this batch. Note that the default max message size in libp2p before fragmentation is 1MB.
	// If we limit this array to 4000 entries, that gives us a marshaled message size of 800K, which is safely below that limit.
	Observations []*Observation `protobuf:"bytes,2,rep,name=observations,proto3" json:"observations,omitempty"`
	// contains filtered or unexported fields
}

A SignedObservationBatch is a signed statement by a given guardian node that they observed a number of events.

func (*SignedObservationBatch) Descriptor deprecated 

func (*SignedObservationBatch) Descriptor() ([]byte, []int)

Deprecated: Use SignedObservationBatch.ProtoReflect.Descriptor instead.

func (*SignedObservationBatch) GetAddr 

func (x *SignedObservationBatch) GetAddr() []byte

func (*SignedObservationBatch) GetObservations 

func (x *SignedObservationBatch) GetObservations() []*Observation

func (*SignedObservationBatch) ProtoMessage 

func (*SignedObservationBatch) ProtoMessage()

func (*SignedObservationBatch) ProtoReflect 

func (x *SignedObservationBatch) ProtoReflect() protoreflect.Message

func (*SignedObservationBatch) Reset 

func (x *SignedObservationBatch) Reset()

func (*SignedObservationBatch) String 

func (x *SignedObservationBatch) String() string

type SignedObservationRequest 

type SignedObservationRequest struct {

	// Serialized observation request.
	ObservationRequest []byte `protobuf:"bytes,1,opt,name=observation_request,json=observationRequest,proto3" json:"observation_request,omitempty"`
	// Signature
	Signature    []byte `protobuf:"bytes,2,opt,name=signature,proto3" json:"signature,omitempty"`
	GuardianAddr []byte `protobuf:"bytes,3,opt,name=guardian_addr,json=guardianAddr,proto3" json:"guardian_addr,omitempty"`
	// contains filtered or unexported fields
}

Any guardian can send a SignedObservationRequest to the network to request all guardians to re-observe a given transaction. This is rate-limited to one request per second per guardian to prevent abuse.

In the current implementation, this is only implemented for Solana. For Solana, the tx_hash is the account address of the transaction's message account.

func (*SignedObservationRequest) Descriptor deprecated 

func (*SignedObservationRequest) Descriptor() ([]byte, []int)

Deprecated: Use SignedObservationRequest.ProtoReflect.Descriptor instead.

func (*SignedObservationRequest) GetGuardianAddr 

func (x *SignedObservationRequest) GetGuardianAddr() []byte

func (*SignedObservationRequest) GetObservationRequest 

func (x *SignedObservationRequest) GetObservationRequest() []byte

func (*SignedObservationRequest) GetSignature 

func (x *SignedObservationRequest) GetSignature() []byte

func (*SignedObservationRequest) ProtoMessage 

func (*SignedObservationRequest) ProtoMessage()

func (*SignedObservationRequest) ProtoReflect 

func (x *SignedObservationRequest) ProtoReflect() protoreflect.Message

func (*SignedObservationRequest) Reset 

func (x *SignedObservationRequest) Reset()

func (*SignedObservationRequest) String 

func (x *SignedObservationRequest) String() string

type SignedQueryRequest 

type SignedQueryRequest struct {

	// Serialized QueryRequest message.
	QueryRequest []byte `protobuf:"bytes,1,opt,name=query_request,json=queryRequest,proto3" json:"query_request,omitempty"`
	// ECDSA signature using the requestor's public key.
	Signature []byte `protobuf:"bytes,2,opt,name=signature,proto3" json:"signature,omitempty"`
	// contains filtered or unexported fields
}

func (*SignedQueryRequest) Descriptor deprecated 

func (*SignedQueryRequest) Descriptor() ([]byte, []int)

Deprecated: Use SignedQueryRequest.ProtoReflect.Descriptor instead.

func (*SignedQueryRequest) GetQueryRequest 

func (x *SignedQueryRequest) GetQueryRequest() []byte

func (*SignedQueryRequest) GetSignature 

func (x *SignedQueryRequest) GetSignature() []byte

func (*SignedQueryRequest) ProtoMessage 

func (*SignedQueryRequest) ProtoMessage()

func (*SignedQueryRequest) ProtoReflect 

func (x *SignedQueryRequest) ProtoReflect() protoreflect.Message

func (*SignedQueryRequest) Reset 

func (x *SignedQueryRequest) Reset()

func (*SignedQueryRequest) String 

func (x *SignedQueryRequest) String() string

type SignedQueryResponse 

type SignedQueryResponse struct {

	// Serialized QueryResponse message.
	QueryResponse []byte `protobuf:"bytes,1,opt,name=query_response,json=queryResponse,proto3" json:"query_response,omitempty"`
	// ECDSA signature using the node's guardian public key.
	Signature []byte `protobuf:"bytes,2,opt,name=signature,proto3" json:"signature,omitempty"`
	// contains filtered or unexported fields
}

func (*SignedQueryResponse) Descriptor deprecated 

func (*SignedQueryResponse) Descriptor() ([]byte, []int)

Deprecated: Use SignedQueryResponse.ProtoReflect.Descriptor instead.

func (*SignedQueryResponse) GetQueryResponse 

func (x *SignedQueryResponse) GetQueryResponse() []byte

func (*SignedQueryResponse) GetSignature 

func (x *SignedQueryResponse) GetSignature() []byte

func (*SignedQueryResponse) ProtoMessage 

func (*SignedQueryResponse) ProtoMessage()

func (*SignedQueryResponse) ProtoReflect 

func (x *SignedQueryResponse) ProtoReflect() protoreflect.Message

func (*SignedQueryResponse) Reset 

func (x *SignedQueryResponse) Reset()

func (*SignedQueryResponse) String 

func (x *SignedQueryResponse) String() string

type SignedVAAWithQuorum 

type SignedVAAWithQuorum struct {
	Vaa []byte `protobuf:"bytes,1,opt,name=vaa,proto3" json:"vaa,omitempty"`
	// contains filtered or unexported fields
}

A SignedVAAWithQuorum message is sent by nodes whenever one of the VAAs they observed reached a 2/3+ quorum to be considered valid. Signed VAAs are broadcasted to the gossip network to allow nodes to persist them even if they failed to observe the signature.

func (*SignedVAAWithQuorum) Descriptor deprecated 

func (*SignedVAAWithQuorum) Descriptor() ([]byte, []int)

Deprecated: Use SignedVAAWithQuorum.ProtoReflect.Descriptor instead.

func (*SignedVAAWithQuorum) GetVaa 

func (x *SignedVAAWithQuorum) GetVaa() []byte

func (*SignedVAAWithQuorum) ProtoMessage 

func (*SignedVAAWithQuorum) ProtoMessage()

func (*SignedVAAWithQuorum) ProtoReflect 

func (x *SignedVAAWithQuorum) ProtoReflect() protoreflect.Message

func (*SignedVAAWithQuorum) Reset 

func (x *SignedVAAWithQuorum) Reset()

func (*SignedVAAWithQuorum) String 

func (x *SignedVAAWithQuorum) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.