nodev1

package
v0.0.0-...-989067b Latest Latest
Warning

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

 Go to latest Published: Apr 15, 2024 License: Apache-2.0 Imports: 16 Imported by: 0

Documentation

Overview

Package nodev1 is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source 
var File_node_v1_node_proto protoreflect.FileDescriptor
View Source 
var NodePrivilegedService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "node.v1.NodePrivilegedService",
	HandlerType: (*NodePrivilegedServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "InjectGovernanceVAA",
			Handler:    _NodePrivilegedService_InjectGovernanceVAA_Handler,
		},
		{
			MethodName: "FindMissingMessages",
			Handler:    _NodePrivilegedService_FindMissingMessages_Handler,
		},
		{
			MethodName: "SendObservationRequest",
			Handler:    _NodePrivilegedService_SendObservationRequest_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "node/v1/node.proto",
}

NodePrivilegedService_ServiceDesc is the grpc.ServiceDesc for NodePrivilegedService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterNodePrivilegedServiceHandler 

func RegisterNodePrivilegedServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterNodePrivilegedServiceHandler registers the http handlers for service NodePrivilegedService to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterNodePrivilegedServiceHandlerClient 

func RegisterNodePrivilegedServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client NodePrivilegedServiceClient) error

RegisterNodePrivilegedServiceHandlerClient registers the http handlers for service NodePrivilegedService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "NodePrivilegedServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "NodePrivilegedServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "NodePrivilegedServiceClient" to call the correct interceptors.

func RegisterNodePrivilegedServiceHandlerFromEndpoint 

func RegisterNodePrivilegedServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterNodePrivilegedServiceHandlerFromEndpoint is same as RegisterNodePrivilegedServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterNodePrivilegedServiceHandlerServer 

func RegisterNodePrivilegedServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server NodePrivilegedServiceServer) error

RegisterNodePrivilegedServiceHandlerServer registers the http handlers for service NodePrivilegedService to "mux". UnaryRPC :call NodePrivilegedServiceServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterNodePrivilegedServiceHandlerFromEndpoint instead.

func RegisterNodePrivilegedServiceServer 

func RegisterNodePrivilegedServiceServer(s grpc.ServiceRegistrar, srv NodePrivilegedServiceServer)

Types

type BridgeRegisterChain 

type BridgeRegisterChain struct {

	// Module identifier of the token or NFT bridge (typically "TokenBridge" or "NFTBridge")
	Module string `protobuf:"bytes,1,opt,name=module,proto3" json:"module,omitempty"`
	// ID of the chain to be registered.
	ChainId uint32 `protobuf:"varint,2,opt,name=chain_id,json=chainId,proto3" json:"chain_id,omitempty"`
	// Hex-encoded emitter address to be registered (without leading 0x).
	EmitterAddress string `protobuf:"bytes,3,opt,name=emitter_address,json=emitterAddress,proto3" json:"emitter_address,omitempty"`
	// contains filtered or unexported fields
}

func (*BridgeRegisterChain) Descriptor deprecated 

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

Deprecated: Use BridgeRegisterChain.ProtoReflect.Descriptor instead.

func (*BridgeRegisterChain) GetChainId 

func (x *BridgeRegisterChain) GetChainId() uint32

func (*BridgeRegisterChain) GetEmitterAddress 

func (x *BridgeRegisterChain) GetEmitterAddress() string

func (*BridgeRegisterChain) GetModule 

func (x *BridgeRegisterChain) GetModule() string

func (*BridgeRegisterChain) ProtoMessage 

func (*BridgeRegisterChain) ProtoMessage()

func (*BridgeRegisterChain) ProtoReflect 

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

func (*BridgeRegisterChain) Reset 

func (x *BridgeRegisterChain) Reset()

func (*BridgeRegisterChain) String 

func (x *BridgeRegisterChain) String() string

type BridgeUpgradeContract 

type BridgeUpgradeContract struct {

	// Module identifier of the token or NFT bridge (typically "TokenBridge" or "NFTBridge").
	Module string `protobuf:"bytes,1,opt,name=module,proto3" json:"module,omitempty"`
	// hex string
	Payload string `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

func (*BridgeUpgradeContract) Descriptor deprecated 

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

Deprecated: Use BridgeUpgradeContract.ProtoReflect.Descriptor instead.

func (*BridgeUpgradeContract) GetModule 

func (x *BridgeUpgradeContract) GetModule() string

func (*BridgeUpgradeContract) GetPayload 

func (x *BridgeUpgradeContract) GetPayload() string

func (*BridgeUpgradeContract) ProtoMessage 

func (*BridgeUpgradeContract) ProtoMessage()

func (*BridgeUpgradeContract) ProtoReflect 

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

func (*BridgeUpgradeContract) Reset 

func (x *BridgeUpgradeContract) Reset()

func (*BridgeUpgradeContract) String 

func (x *BridgeUpgradeContract) String() string

type ContractUpgrade 

type ContractUpgrade struct {

	// hex string
	Payload string `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

ContractUpgrade represents a Wormhole contract update to be submitted to and signed by the node.

func (*ContractUpgrade) Descriptor deprecated 

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

Deprecated: Use ContractUpgrade.ProtoReflect.Descriptor instead.

func (*ContractUpgrade) GetPayload 

func (x *ContractUpgrade) GetPayload() string

func (*ContractUpgrade) ProtoMessage 

func (*ContractUpgrade) ProtoMessage()

func (*ContractUpgrade) ProtoReflect 

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

func (*ContractUpgrade) Reset 

func (x *ContractUpgrade) Reset()

func (*ContractUpgrade) String 

func (x *ContractUpgrade) String() string

type FindMissingMessagesRequest 

type FindMissingMessagesRequest struct {

	// Emitter chain ID to iterate.
	EmitterChain uint32 `protobuf:"varint,1,opt,name=emitter_chain,json=emitterChain,proto3" json:"emitter_chain,omitempty"`
	// Target chain ID
	TargetChain uint32 `protobuf:"varint,2,opt,name=target_chain,json=targetChain,proto3" json:"target_chain,omitempty"`
	// Hex-encoded (without leading 0x) emitter address to iterate.
	EmitterAddress string `protobuf:"bytes,3,opt,name=emitter_address,json=emitterAddress,proto3" json:"emitter_address,omitempty"`
	// Whether to attempt to backfill missing messages from a list of remote nodes.
	RpcBackfill bool `protobuf:"varint,4,opt,name=rpc_backfill,json=rpcBackfill,proto3" json:"rpc_backfill,omitempty"`
	// List of remote nodes to backfill from.
	BackfillNodes []string `protobuf:"bytes,5,rep,name=backfill_nodes,json=backfillNodes,proto3" json:"backfill_nodes,omitempty"`
	// contains filtered or unexported fields
}

func (*FindMissingMessagesRequest) Descriptor deprecated 

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

Deprecated: Use FindMissingMessagesRequest.ProtoReflect.Descriptor instead.

func (*FindMissingMessagesRequest) GetBackfillNodes 

func (x *FindMissingMessagesRequest) GetBackfillNodes() []string

func (*FindMissingMessagesRequest) GetEmitterAddress 

func (x *FindMissingMessagesRequest) GetEmitterAddress() string

func (*FindMissingMessagesRequest) GetEmitterChain 

func (x *FindMissingMessagesRequest) GetEmitterChain() uint32

func (*FindMissingMessagesRequest) GetRpcBackfill 

func (x *FindMissingMessagesRequest) GetRpcBackfill() bool

func (*FindMissingMessagesRequest) GetTargetChain 

func (x *FindMissingMessagesRequest) GetTargetChain() uint32

func (*FindMissingMessagesRequest) ProtoMessage 

func (*FindMissingMessagesRequest) ProtoMessage()

func (*FindMissingMessagesRequest) ProtoReflect 

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

func (*FindMissingMessagesRequest) Reset 

func (x *FindMissingMessagesRequest) Reset()

func (*FindMissingMessagesRequest) String 

func (x *FindMissingMessagesRequest) String() string

type FindMissingMessagesResponse 

type FindMissingMessagesResponse struct {

	// List of missing sequence numbers.
	MissingMessages []string `protobuf:"bytes,1,rep,name=missing_messages,json=missingMessages,proto3" json:"missing_messages,omitempty"`
	// Range processed
	FirstSequence uint64 `protobuf:"varint,2,opt,name=first_sequence,json=firstSequence,proto3" json:"first_sequence,omitempty"`
	LastSequence  uint64 `protobuf:"varint,3,opt,name=last_sequence,json=lastSequence,proto3" json:"last_sequence,omitempty"`
	// contains filtered or unexported fields
}

func (*FindMissingMessagesResponse) Descriptor deprecated 

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

Deprecated: Use FindMissingMessagesResponse.ProtoReflect.Descriptor instead.

func (*FindMissingMessagesResponse) GetFirstSequence 

func (x *FindMissingMessagesResponse) GetFirstSequence() uint64

func (*FindMissingMessagesResponse) GetLastSequence 

func (x *FindMissingMessagesResponse) GetLastSequence() uint64

func (*FindMissingMessagesResponse) GetMissingMessages 

func (x *FindMissingMessagesResponse) GetMissingMessages() []string

func (*FindMissingMessagesResponse) ProtoMessage 

func (*FindMissingMessagesResponse) ProtoMessage()

func (*FindMissingMessagesResponse) ProtoReflect 

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

func (*FindMissingMessagesResponse) Reset 

func (x *FindMissingMessagesResponse) Reset()

func (*FindMissingMessagesResponse) String 

func (x *FindMissingMessagesResponse) String() string

type GovernanceMessage 

type GovernanceMessage struct {

	// Sequence number. This is critical for replay protection - make sure the sequence number
	// is unique for every new manually injected governance VAA. Sequences are tracked
	// by emitter, and manually injected VAAs all use a single hardcoded emitter.
	//
	// We use random sequence numbers for the manual emitter.
	Sequence uint64 `protobuf:"varint,2,opt,name=sequence,proto3" json:"sequence,omitempty"`
	// Random nonce for disambiguation. Must be identical across all nodes.
	Nonce uint32 `protobuf:"varint,3,opt,name=nonce,proto3" json:"nonce,omitempty"`
	// Target chain ID
	TargetChainId uint32 `protobuf:"varint,4,opt,name=target_chain_id,json=targetChainId,proto3" json:"target_chain_id,omitempty"`
	// Types that are assignable to Payload:
	//
	//	*GovernanceMessage_UpdateMessageFee
	//	*GovernanceMessage_TransferFee
	//	*GovernanceMessage_GuardianSet
	//	*GovernanceMessage_ContractUpgrade
	//	*GovernanceMessage_BridgeRegisterChain
	//	*GovernanceMessage_BridgeContractUpgrade
	//	*GovernanceMessage_DestroyUnexecutedSequenceContracts
	//	*GovernanceMessage_UpdateMinimalConsistencyLevel
	//	*GovernanceMessage_UpdateRefundAddress
	Payload isGovernanceMessage_Payload `protobuf_oneof:"payload"`
	// contains filtered or unexported fields
}

func (*GovernanceMessage) Descriptor deprecated 

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

Deprecated: Use GovernanceMessage.ProtoReflect.Descriptor instead.

func (*GovernanceMessage) GetBridgeContractUpgrade 

func (x *GovernanceMessage) GetBridgeContractUpgrade() *BridgeUpgradeContract

func (*GovernanceMessage) GetBridgeRegisterChain 

func (x *GovernanceMessage) GetBridgeRegisterChain() *BridgeRegisterChain

func (*GovernanceMessage) GetContractUpgrade 

func (x *GovernanceMessage) GetContractUpgrade() *ContractUpgrade

func (*GovernanceMessage) GetDestroyUnexecutedSequenceContracts 

func (x *GovernanceMessage) GetDestroyUnexecutedSequenceContracts() *TokenBridgeDestroyUnexecutedSequenceContracts

func (*GovernanceMessage) GetGuardianSet 

func (x *GovernanceMessage) GetGuardianSet() *GuardianSetUpgrade

func (*GovernanceMessage) GetNonce 

func (x *GovernanceMessage) GetNonce() uint32

func (*GovernanceMessage) GetPayload 

func (m *GovernanceMessage) GetPayload() isGovernanceMessage_Payload

func (*GovernanceMessage) GetSequence 

func (x *GovernanceMessage) GetSequence() uint64

func (*GovernanceMessage) GetTargetChainId 

func (x *GovernanceMessage) GetTargetChainId() uint32

func (*GovernanceMessage) GetTransferFee 

func (x *GovernanceMessage) GetTransferFee() *TransferFee

func (*GovernanceMessage) GetUpdateMessageFee 

func (x *GovernanceMessage) GetUpdateMessageFee() *UpdateMessageFee

func (*GovernanceMessage) GetUpdateMinimalConsistencyLevel 

func (x *GovernanceMessage) GetUpdateMinimalConsistencyLevel() *TokenBridgeUpdateMinimalConsistencyLevel

func (*GovernanceMessage) GetUpdateRefundAddress 

func (x *GovernanceMessage) GetUpdateRefundAddress() *TokenBridgeUpdateRefundAddress

func (*GovernanceMessage) ProtoMessage 

func (*GovernanceMessage) ProtoMessage()

func (*GovernanceMessage) ProtoReflect 

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

func (*GovernanceMessage) Reset 

func (x *GovernanceMessage) Reset()

func (*GovernanceMessage) String 

func (x *GovernanceMessage) String() string

type GovernanceMessage_BridgeContractUpgrade 

type GovernanceMessage_BridgeContractUpgrade struct {
	BridgeContractUpgrade *BridgeUpgradeContract `protobuf:"bytes,13,opt,name=bridge_contract_upgrade,json=bridgeContractUpgrade,proto3,oneof"`
}

type GovernanceMessage_BridgeRegisterChain 

type GovernanceMessage_BridgeRegisterChain struct {
	BridgeRegisterChain *BridgeRegisterChain `protobuf:"bytes,12,opt,name=bridge_register_chain,json=bridgeRegisterChain,proto3,oneof"`
}

type GovernanceMessage_ContractUpgrade 

type GovernanceMessage_ContractUpgrade struct {
	ContractUpgrade *ContractUpgrade `protobuf:"bytes,11,opt,name=contract_upgrade,json=contractUpgrade,proto3,oneof"`
}

type GovernanceMessage_DestroyUnexecutedSequenceContracts 

type GovernanceMessage_DestroyUnexecutedSequenceContracts struct {
	// Alephium TokenBridge Extensions
	DestroyUnexecutedSequenceContracts *TokenBridgeDestroyUnexecutedSequenceContracts `protobuf:"bytes,20,opt,name=destroy_unexecuted_sequence_contracts,json=destroyUnexecutedSequenceContracts,proto3,oneof"`
}

type GovernanceMessage_GuardianSet 

type GovernanceMessage_GuardianSet struct {
	GuardianSet *GuardianSetUpgrade `protobuf:"bytes,10,opt,name=guardian_set,json=guardianSet,proto3,oneof"`
}

type GovernanceMessage_TransferFee 

type GovernanceMessage_TransferFee struct {
	TransferFee *TransferFee `protobuf:"bytes,9,opt,name=transfer_fee,json=transferFee,proto3,oneof"`
}

type GovernanceMessage_UpdateMessageFee 

type GovernanceMessage_UpdateMessageFee struct {
	UpdateMessageFee *UpdateMessageFee `protobuf:"bytes,8,opt,name=update_message_fee,json=updateMessageFee,proto3,oneof"`
}

type GovernanceMessage_UpdateMinimalConsistencyLevel 

type GovernanceMessage_UpdateMinimalConsistencyLevel struct {
	UpdateMinimalConsistencyLevel *TokenBridgeUpdateMinimalConsistencyLevel `protobuf:"bytes,21,opt,name=update_minimal_consistency_level,json=updateMinimalConsistencyLevel,proto3,oneof"`
}

type GovernanceMessage_UpdateRefundAddress 

type GovernanceMessage_UpdateRefundAddress struct {
	UpdateRefundAddress *TokenBridgeUpdateRefundAddress `protobuf:"bytes,22,opt,name=update_refund_address,json=updateRefundAddress,proto3,oneof"`
}

type GuardianKey 

type GuardianKey struct {

	// data is the binary representation of the secp256k1 private key.
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// Whether this key is deterministically generated and unsuitable for production mode.
	UnsafeDeterministicKey bool `` /* 130-byte string literal not displayed */
	// contains filtered or unexported fields
}

GuardianKey specifies the on-disk format for a node's guardian key.

func (*GuardianKey) Descriptor deprecated 

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

Deprecated: Use GuardianKey.ProtoReflect.Descriptor instead.

func (*GuardianKey) GetData 

func (x *GuardianKey) GetData() []byte

func (*GuardianKey) GetUnsafeDeterministicKey 

func (x *GuardianKey) GetUnsafeDeterministicKey() bool

func (*GuardianKey) ProtoMessage 

func (*GuardianKey) ProtoMessage()

func (*GuardianKey) ProtoReflect 

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

func (*GuardianKey) Reset 

func (x *GuardianKey) Reset()

func (*GuardianKey) String 

func (x *GuardianKey) String() string

type GuardianSetUpgrade 

type GuardianSetUpgrade struct {
	Guardians []*GuardianSetUpgrade_Guardian `protobuf:"bytes,3,rep,name=guardians,proto3" json:"guardians,omitempty"`
	// contains filtered or unexported fields
}

GuardianSet represents a new guardian set to be submitted to and signed by the node. During the genesis procedure, this data structure will be assembled using off-chain collaborative tooling like GitHub using a human-readable encoding, so readability is a concern.

func (*GuardianSetUpgrade) Descriptor deprecated 

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

Deprecated: Use GuardianSetUpgrade.ProtoReflect.Descriptor instead.

func (*GuardianSetUpgrade) GetGuardians 

func (x *GuardianSetUpgrade) GetGuardians() []*GuardianSetUpgrade_Guardian

func (*GuardianSetUpgrade) ProtoMessage 

func (*GuardianSetUpgrade) ProtoMessage()

func (*GuardianSetUpgrade) ProtoReflect 

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

func (*GuardianSetUpgrade) Reset 

func (x *GuardianSetUpgrade) Reset()

func (*GuardianSetUpgrade) String 

func (x *GuardianSetUpgrade) String() string

type GuardianSetUpgrade_Guardian 

type GuardianSetUpgrade_Guardian struct {

	// Guardian key pubkey. Stored as hex string with 0x prefix for human readability -
	// this is the canonical Ethereum representation.
	Pubkey string `protobuf:"bytes,1,opt,name=pubkey,proto3" json:"pubkey,omitempty"`
	// Optional descriptive name. Not stored on any chain, purely informational.
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

List of guardian set members.

func (*GuardianSetUpgrade_Guardian) Descriptor deprecated 

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

Deprecated: Use GuardianSetUpgrade_Guardian.ProtoReflect.Descriptor instead.

func (*GuardianSetUpgrade_Guardian) GetName 

func (x *GuardianSetUpgrade_Guardian) GetName() string

func (*GuardianSetUpgrade_Guardian) GetPubkey 

func (x *GuardianSetUpgrade_Guardian) GetPubkey() string

func (*GuardianSetUpgrade_Guardian) ProtoMessage 

func (*GuardianSetUpgrade_Guardian) ProtoMessage()

func (*GuardianSetUpgrade_Guardian) ProtoReflect 

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

func (*GuardianSetUpgrade_Guardian) Reset 

func (x *GuardianSetUpgrade_Guardian) Reset()

func (*GuardianSetUpgrade_Guardian) String 

func (x *GuardianSetUpgrade_Guardian) String() string

type InjectGovernanceVAARequest 

type InjectGovernanceVAARequest struct {

	// Index of the current guardian set.
	CurrentSetIndex uint32 `protobuf:"varint,1,opt,name=current_set_index,json=currentSetIndex,proto3" json:"current_set_index,omitempty"`
	// List of governance VAA messages to inject.
	Messages []*GovernanceMessage `protobuf:"bytes,2,rep,name=messages,proto3" json:"messages,omitempty"`
	// UNIX wall time in seconds
	Timestamp uint32 `protobuf:"varint,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

func (*InjectGovernanceVAARequest) Descriptor deprecated 

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

Deprecated: Use InjectGovernanceVAARequest.ProtoReflect.Descriptor instead.

func (*InjectGovernanceVAARequest) GetCurrentSetIndex 

func (x *InjectGovernanceVAARequest) GetCurrentSetIndex() uint32

func (*InjectGovernanceVAARequest) GetMessages 

func (x *InjectGovernanceVAARequest) GetMessages() []*GovernanceMessage

func (*InjectGovernanceVAARequest) GetTimestamp 

func (x *InjectGovernanceVAARequest) GetTimestamp() uint32

func (*InjectGovernanceVAARequest) ProtoMessage 

func (*InjectGovernanceVAARequest) ProtoMessage()

func (*InjectGovernanceVAARequest) ProtoReflect 

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

func (*InjectGovernanceVAARequest) Reset 

func (x *InjectGovernanceVAARequest) Reset()

func (*InjectGovernanceVAARequest) String 

func (x *InjectGovernanceVAARequest) String() string

type InjectGovernanceVAAResponse 

type InjectGovernanceVAAResponse struct {

	// Canonical digests of the submitted VAAs.
	Digests [][]byte `protobuf:"bytes,1,rep,name=digests,proto3" json:"digests,omitempty"`
	// contains filtered or unexported fields
}

func (*InjectGovernanceVAAResponse) Descriptor deprecated 

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

Deprecated: Use InjectGovernanceVAAResponse.ProtoReflect.Descriptor instead.

func (*InjectGovernanceVAAResponse) GetDigests 

func (x *InjectGovernanceVAAResponse) GetDigests() [][]byte

func (*InjectGovernanceVAAResponse) ProtoMessage 

func (*InjectGovernanceVAAResponse) ProtoMessage()

func (*InjectGovernanceVAAResponse) ProtoReflect 

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

func (*InjectGovernanceVAAResponse) Reset 

func (x *InjectGovernanceVAAResponse) Reset()

func (*InjectGovernanceVAAResponse) String 

func (x *InjectGovernanceVAAResponse) String() string

type NodePrivilegedServiceClient 

type NodePrivilegedServiceClient interface {
	// InjectGovernanceVAA injects a governance VAA into the guardian node.
	// The node will inject the VAA into the aggregator and sign/broadcast the VAA signature.
	//
	// A consensus majority of nodes on the network will have to inject the VAA within the
	// VAA timeout window for it to reach consensus.
	InjectGovernanceVAA(ctx context.Context, in *InjectGovernanceVAARequest, opts ...grpc.CallOption) (*InjectGovernanceVAAResponse, error)
	// FindMissingMessages will detect message sequence gaps in the local VAA store for a
	// specific emitter chain and address. Start and end slots are the lowest and highest
	// sequence numbers available in the local store, respectively.
	//
	// An error is returned if more than 1000 gaps are found.
	FindMissingMessages(ctx context.Context, in *FindMissingMessagesRequest, opts ...grpc.CallOption) (*FindMissingMessagesResponse, error)
	// SendObservationRequest broadcasts a signed observation request to the gossip network
	// using the node's guardian key. The network rate limits these requests to one per second.
	// Requests at higher rates will fail silently.
	SendObservationRequest(ctx context.Context, in *SendObservationRequestRequest, opts ...grpc.CallOption) (*SendObservationRequestResponse, error)
}

NodePrivilegedServiceClient is the client API for NodePrivilegedService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewNodePrivilegedServiceClient 

func NewNodePrivilegedServiceClient(cc grpc.ClientConnInterface) NodePrivilegedServiceClient

type NodePrivilegedServiceServer 

type NodePrivilegedServiceServer interface {
	// InjectGovernanceVAA injects a governance VAA into the guardian node.
	// The node will inject the VAA into the aggregator and sign/broadcast the VAA signature.
	//
	// A consensus majority of nodes on the network will have to inject the VAA within the
	// VAA timeout window for it to reach consensus.
	InjectGovernanceVAA(context.Context, *InjectGovernanceVAARequest) (*InjectGovernanceVAAResponse, error)
	// FindMissingMessages will detect message sequence gaps in the local VAA store for a
	// specific emitter chain and address. Start and end slots are the lowest and highest
	// sequence numbers available in the local store, respectively.
	//
	// An error is returned if more than 1000 gaps are found.
	FindMissingMessages(context.Context, *FindMissingMessagesRequest) (*FindMissingMessagesResponse, error)
	// SendObservationRequest broadcasts a signed observation request to the gossip network
	// using the node's guardian key. The network rate limits these requests to one per second.
	// Requests at higher rates will fail silently.
	SendObservationRequest(context.Context, *SendObservationRequestRequest) (*SendObservationRequestResponse, error)
	// contains filtered or unexported methods
}

NodePrivilegedServiceServer is the server API for NodePrivilegedService service. All implementations must embed UnimplementedNodePrivilegedServiceServer for forward compatibility

type SendObservationRequestRequest 

type SendObservationRequestRequest struct {
	ObservationRequest *v1.ObservationRequest `protobuf:"bytes,1,opt,name=observation_request,json=observationRequest,proto3" json:"observation_request,omitempty"`
	// contains filtered or unexported fields
}

func (*SendObservationRequestRequest) Descriptor deprecated 

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

Deprecated: Use SendObservationRequestRequest.ProtoReflect.Descriptor instead.

func (*SendObservationRequestRequest) GetObservationRequest 

func (x *SendObservationRequestRequest) GetObservationRequest() *v1.ObservationRequest

func (*SendObservationRequestRequest) ProtoMessage 

func (*SendObservationRequestRequest) ProtoMessage()

func (*SendObservationRequestRequest) ProtoReflect 

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

func (*SendObservationRequestRequest) Reset 

func (x *SendObservationRequestRequest) Reset()

func (*SendObservationRequestRequest) String 

func (x *SendObservationRequestRequest) String() string

type SendObservationRequestResponse 

type SendObservationRequestResponse struct {
	// contains filtered or unexported fields
}

func (*SendObservationRequestResponse) Descriptor deprecated 

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

Deprecated: Use SendObservationRequestResponse.ProtoReflect.Descriptor instead.

func (*SendObservationRequestResponse) ProtoMessage 

func (*SendObservationRequestResponse) ProtoMessage()

func (*SendObservationRequestResponse) ProtoReflect 

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

func (*SendObservationRequestResponse) Reset 

func (x *SendObservationRequestResponse) Reset()

func (*SendObservationRequestResponse) String 

func (x *SendObservationRequestResponse) String() string

type TokenBridgeDestroyUnexecutedSequenceContracts 

type TokenBridgeDestroyUnexecutedSequenceContracts struct {
	EmitterChain uint32   `protobuf:"varint,1,opt,name=emitter_chain,json=emitterChain,proto3" json:"emitter_chain,omitempty"`
	Sequences    []uint64 `protobuf:"varint,2,rep,packed,name=sequences,proto3" json:"sequences,omitempty"`
	// contains filtered or unexported fields
}

func (*TokenBridgeDestroyUnexecutedSequenceContracts) Descriptor deprecated 

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

Deprecated: Use TokenBridgeDestroyUnexecutedSequenceContracts.ProtoReflect.Descriptor instead.

func (*TokenBridgeDestroyUnexecutedSequenceContracts) GetEmitterChain 

func (x *TokenBridgeDestroyUnexecutedSequenceContracts) GetEmitterChain() uint32

func (*TokenBridgeDestroyUnexecutedSequenceContracts) GetSequences 

func (x *TokenBridgeDestroyUnexecutedSequenceContracts) GetSequences() []uint64

func (*TokenBridgeDestroyUnexecutedSequenceContracts) ProtoMessage 

func (*TokenBridgeDestroyUnexecutedSequenceContracts) ProtoMessage()

func (*TokenBridgeDestroyUnexecutedSequenceContracts) ProtoReflect 

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

func (*TokenBridgeDestroyUnexecutedSequenceContracts) Reset 

func (x *TokenBridgeDestroyUnexecutedSequenceContracts) Reset()

func (*TokenBridgeDestroyUnexecutedSequenceContracts) String 

func (x *TokenBridgeDestroyUnexecutedSequenceContracts) String() string

type TokenBridgeUpdateMinimalConsistencyLevel 

type TokenBridgeUpdateMinimalConsistencyLevel struct {
	NewConsistencyLevel uint32 `protobuf:"varint,1,opt,name=new_consistency_level,json=newConsistencyLevel,proto3" json:"new_consistency_level,omitempty"`
	// contains filtered or unexported fields
}

func (*TokenBridgeUpdateMinimalConsistencyLevel) Descriptor deprecated 

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

Deprecated: Use TokenBridgeUpdateMinimalConsistencyLevel.ProtoReflect.Descriptor instead.

func (*TokenBridgeUpdateMinimalConsistencyLevel) GetNewConsistencyLevel 

func (x *TokenBridgeUpdateMinimalConsistencyLevel) GetNewConsistencyLevel() uint32

func (*TokenBridgeUpdateMinimalConsistencyLevel) ProtoMessage 

func (*TokenBridgeUpdateMinimalConsistencyLevel) ProtoMessage()

func (*TokenBridgeUpdateMinimalConsistencyLevel) ProtoReflect 

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

func (*TokenBridgeUpdateMinimalConsistencyLevel) Reset 

func (x *TokenBridgeUpdateMinimalConsistencyLevel) Reset()

func (*TokenBridgeUpdateMinimalConsistencyLevel) String 

func (x *TokenBridgeUpdateMinimalConsistencyLevel) String() string

type TokenBridgeUpdateRefundAddress 

type TokenBridgeUpdateRefundAddress struct {

	// hex string
	NewRefundAddress string `protobuf:"bytes,1,opt,name=new_refund_address,json=newRefundAddress,proto3" json:"new_refund_address,omitempty"`
	// contains filtered or unexported fields
}

func (*TokenBridgeUpdateRefundAddress) Descriptor deprecated 

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

Deprecated: Use TokenBridgeUpdateRefundAddress.ProtoReflect.Descriptor instead.

func (*TokenBridgeUpdateRefundAddress) GetNewRefundAddress 

func (x *TokenBridgeUpdateRefundAddress) GetNewRefundAddress() string

func (*TokenBridgeUpdateRefundAddress) ProtoMessage 

func (*TokenBridgeUpdateRefundAddress) ProtoMessage()

func (*TokenBridgeUpdateRefundAddress) ProtoReflect 

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

func (*TokenBridgeUpdateRefundAddress) Reset 

func (x *TokenBridgeUpdateRefundAddress) Reset()

func (*TokenBridgeUpdateRefundAddress) String 

func (x *TokenBridgeUpdateRefundAddress) String() string

type TransferFee 

type TransferFee struct {

	// 32 bytes hex string
	Amount string `protobuf:"bytes,1,opt,name=amount,proto3" json:"amount,omitempty"`
	// 32 bytes hex string
	Recipient string `protobuf:"bytes,2,opt,name=recipient,proto3" json:"recipient,omitempty"`
	// contains filtered or unexported fields
}

func (*TransferFee) Descriptor deprecated 

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

Deprecated: Use TransferFee.ProtoReflect.Descriptor instead.

func (*TransferFee) GetAmount 

func (x *TransferFee) GetAmount() string

func (*TransferFee) GetRecipient 

func (x *TransferFee) GetRecipient() string

func (*TransferFee) ProtoMessage 

func (*TransferFee) ProtoMessage()

func (*TransferFee) ProtoReflect 

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

func (*TransferFee) Reset 

func (x *TransferFee) Reset()

func (*TransferFee) String 

func (x *TransferFee) String() string

type UnimplementedNodePrivilegedServiceServer 

type UnimplementedNodePrivilegedServiceServer struct {
}

UnimplementedNodePrivilegedServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedNodePrivilegedServiceServer) FindMissingMessages 

func (UnimplementedNodePrivilegedServiceServer) FindMissingMessages(context.Context, *FindMissingMessagesRequest) (*FindMissingMessagesResponse, error)

func (UnimplementedNodePrivilegedServiceServer) InjectGovernanceVAA 

func (UnimplementedNodePrivilegedServiceServer) InjectGovernanceVAA(context.Context, *InjectGovernanceVAARequest) (*InjectGovernanceVAAResponse, error)

func (UnimplementedNodePrivilegedServiceServer) SendObservationRequest 

func (UnimplementedNodePrivilegedServiceServer) SendObservationRequest(context.Context, *SendObservationRequestRequest) (*SendObservationRequestResponse, error)

type UnsafeNodePrivilegedServiceServer 

type UnsafeNodePrivilegedServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeNodePrivilegedServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to NodePrivilegedServiceServer will result in compilation errors.

type UpdateMessageFee 

type UpdateMessageFee struct {

	// 32 bytes hex string
	NewMessageFee string `protobuf:"bytes,1,opt,name=new_message_fee,json=newMessageFee,proto3" json:"new_message_fee,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateMessageFee) Descriptor deprecated 

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

Deprecated: Use UpdateMessageFee.ProtoReflect.Descriptor instead.

func (*UpdateMessageFee) GetNewMessageFee 

func (x *UpdateMessageFee) GetNewMessageFee() string

func (*UpdateMessageFee) ProtoMessage 

func (*UpdateMessageFee) ProtoMessage()

func (*UpdateMessageFee) ProtoReflect 

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

func (*UpdateMessageFee) Reset 

func (x *UpdateMessageFee) Reset()

func (*UpdateMessageFee) String 

func (x *UpdateMessageFee) 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.