publicrpcv1

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: 17 Imported by: 2

Documentation

Overview

Package publicrpcv1 is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source 
var (
	ChainID_name = map[int32]string{
		0:     "CHAIN_ID_UNSPECIFIED",
		1:     "CHAIN_ID_SOLANA",
		2:     "CHAIN_ID_ETHEREUM",
		3:     "CHAIN_ID_TERRA",
		4:     "CHAIN_ID_BSC",
		5:     "CHAIN_ID_POLYGON",
		6:     "CHAIN_ID_AVALANCHE",
		7:     "CHAIN_ID_OASIS",
		8:     "CHAIN_ID_ALGORAND",
		9:     "CHAIN_ID_AURORA",
		10:    "CHAIN_ID_FANTOM",
		11:    "CHAIN_ID_KARURA",
		12:    "CHAIN_ID_ACALA",
		13:    "CHAIN_ID_KLAYTN",
		14:    "CHAIN_ID_CELO",
		15:    "CHAIN_ID_NEAR",
		16:    "CHAIN_ID_MOONBEAM",
		17:    "CHAIN_ID_NEON",
		255:   "CHAIN_ID_ALEPHIUM",
		10001: "CHAIN_ID_ETHEREUM_ROPSTEN",
	}
	ChainID_value = map[string]int32{
		"CHAIN_ID_UNSPECIFIED":      0,
		"CHAIN_ID_SOLANA":           1,
		"CHAIN_ID_ETHEREUM":         2,
		"CHAIN_ID_TERRA":            3,
		"CHAIN_ID_BSC":              4,
		"CHAIN_ID_POLYGON":          5,
		"CHAIN_ID_AVALANCHE":        6,
		"CHAIN_ID_OASIS":            7,
		"CHAIN_ID_ALGORAND":         8,
		"CHAIN_ID_AURORA":           9,
		"CHAIN_ID_FANTOM":           10,
		"CHAIN_ID_KARURA":           11,
		"CHAIN_ID_ACALA":            12,
		"CHAIN_ID_KLAYTN":           13,
		"CHAIN_ID_CELO":             14,
		"CHAIN_ID_NEAR":             15,
		"CHAIN_ID_MOONBEAM":         16,
		"CHAIN_ID_NEON":             17,
		"CHAIN_ID_ALEPHIUM":         255,
		"CHAIN_ID_ETHEREUM_ROPSTEN": 10001,
	}
)

Enum value maps for ChainID.

View Source 
var File_publicrpc_v1_publicrpc_proto protoreflect.FileDescriptor
View Source 
var PublicRPCService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "publicrpc.v1.PublicRPCService",
	HandlerType: (*PublicRPCServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetLastHeartbeats",
			Handler:    _PublicRPCService_GetLastHeartbeats_Handler,
		},
		{
			MethodName: "GetSignedVAA",
			Handler:    _PublicRPCService_GetSignedVAA_Handler,
		},
		{
			MethodName: "GetNonGovernanceVAABatch",
			Handler:    _PublicRPCService_GetNonGovernanceVAABatch_Handler,
		},
		{
			MethodName: "GetGovernanceVAABatch",
			Handler:    _PublicRPCService_GetGovernanceVAABatch_Handler,
		},
		{
			MethodName: "GetCurrentGuardianSet",
			Handler:    _PublicRPCService_GetCurrentGuardianSet_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "publicrpc/v1/publicrpc.proto",
}

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

Functions

func RegisterPublicRPCServiceHandler 

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

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

func RegisterPublicRPCServiceHandlerClient 

func RegisterPublicRPCServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client PublicRPCServiceClient) error

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

func RegisterPublicRPCServiceHandlerFromEndpoint 

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

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

func RegisterPublicRPCServiceHandlerServer 

func RegisterPublicRPCServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server PublicRPCServiceServer) error

RegisterPublicRPCServiceHandlerServer registers the http handlers for service PublicRPCService to "mux". UnaryRPC :call PublicRPCServiceServer 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 RegisterPublicRPCServiceHandlerFromEndpoint instead.

func RegisterPublicRPCServiceServer 

func RegisterPublicRPCServiceServer(s grpc.ServiceRegistrar, srv PublicRPCServiceServer)

Types

type ChainID 

type ChainID int32
const (
	ChainID_CHAIN_ID_UNSPECIFIED ChainID = 0
	ChainID_CHAIN_ID_SOLANA      ChainID = 1
	ChainID_CHAIN_ID_ETHEREUM    ChainID = 2
	ChainID_CHAIN_ID_TERRA       ChainID = 3
	ChainID_CHAIN_ID_BSC         ChainID = 4
	ChainID_CHAIN_ID_POLYGON     ChainID = 5
	ChainID_CHAIN_ID_AVALANCHE   ChainID = 6
	ChainID_CHAIN_ID_OASIS       ChainID = 7
	ChainID_CHAIN_ID_ALGORAND    ChainID = 8
	ChainID_CHAIN_ID_AURORA      ChainID = 9
	ChainID_CHAIN_ID_FANTOM      ChainID = 10
	ChainID_CHAIN_ID_KARURA      ChainID = 11
	ChainID_CHAIN_ID_ACALA       ChainID = 12
	ChainID_CHAIN_ID_KLAYTN      ChainID = 13
	ChainID_CHAIN_ID_CELO        ChainID = 14
	ChainID_CHAIN_ID_NEAR        ChainID = 15
	ChainID_CHAIN_ID_MOONBEAM    ChainID = 16
	ChainID_CHAIN_ID_NEON        ChainID = 17
	ChainID_CHAIN_ID_ALEPHIUM    ChainID = 255
	// Special case - Eth has two testnets. CHAIN_ID_ETHEREUM is Goerli,
	// but we also want to connect to Ropsten, so we add a separate chain.
	ChainID_CHAIN_ID_ETHEREUM_ROPSTEN ChainID = 10001
)

func (ChainID) Descriptor 

func (ChainID) Descriptor() protoreflect.EnumDescriptor

func (ChainID) Enum 

func (x ChainID) Enum() *ChainID

func (ChainID) EnumDescriptor deprecated 

func (ChainID) EnumDescriptor() ([]byte, []int)

Deprecated: Use ChainID.Descriptor instead.

func (ChainID) Number 

func (x ChainID) Number() protoreflect.EnumNumber

func (ChainID) String 

func (x ChainID) String() string

func (ChainID) Type 

func (ChainID) Type() protoreflect.EnumType

type GetCurrentGuardianSetRequest 

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

func (*GetCurrentGuardianSetRequest) Descriptor deprecated 

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

Deprecated: Use GetCurrentGuardianSetRequest.ProtoReflect.Descriptor instead.

func (*GetCurrentGuardianSetRequest) ProtoMessage 

func (*GetCurrentGuardianSetRequest) ProtoMessage()

func (*GetCurrentGuardianSetRequest) ProtoReflect 

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

func (*GetCurrentGuardianSetRequest) Reset 

func (x *GetCurrentGuardianSetRequest) Reset()

func (*GetCurrentGuardianSetRequest) String 

func (x *GetCurrentGuardianSetRequest) String() string

type GetCurrentGuardianSetResponse 

type GetCurrentGuardianSetResponse struct {
	GuardianSet *GuardianSet `protobuf:"bytes,1,opt,name=guardian_set,json=guardianSet,proto3" json:"guardian_set,omitempty"`
	// contains filtered or unexported fields
}

func (*GetCurrentGuardianSetResponse) Descriptor deprecated 

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

Deprecated: Use GetCurrentGuardianSetResponse.ProtoReflect.Descriptor instead.

func (*GetCurrentGuardianSetResponse) GetGuardianSet 

func (x *GetCurrentGuardianSetResponse) GetGuardianSet() *GuardianSet

func (*GetCurrentGuardianSetResponse) ProtoMessage 

func (*GetCurrentGuardianSetResponse) ProtoMessage()

func (*GetCurrentGuardianSetResponse) ProtoReflect 

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

func (*GetCurrentGuardianSetResponse) Reset 

func (x *GetCurrentGuardianSetResponse) Reset()

func (*GetCurrentGuardianSetResponse) String 

func (x *GetCurrentGuardianSetResponse) String() string

type GetGovernanceVAABatchRequest 

type GetGovernanceVAABatchRequest struct {

	// Sequences
	Sequences []uint64 `protobuf:"varint,1,rep,packed,name=sequences,proto3" json:"sequences,omitempty"`
	// contains filtered or unexported fields
}

func (*GetGovernanceVAABatchRequest) Descriptor deprecated 

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

Deprecated: Use GetGovernanceVAABatchRequest.ProtoReflect.Descriptor instead.

func (*GetGovernanceVAABatchRequest) GetSequences 

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

func (*GetGovernanceVAABatchRequest) ProtoMessage 

func (*GetGovernanceVAABatchRequest) ProtoMessage()

func (*GetGovernanceVAABatchRequest) ProtoReflect 

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

func (*GetGovernanceVAABatchRequest) Reset 

func (x *GetGovernanceVAABatchRequest) Reset()

func (*GetGovernanceVAABatchRequest) String 

func (x *GetGovernanceVAABatchRequest) String() string

type GetGovernanceVAABatchResponse 

type GetGovernanceVAABatchResponse struct {
	Entries []*GetGovernanceVAABatchResponse_Entry `protobuf:"bytes,1,rep,name=entries,proto3" json:"entries,omitempty"`
	// contains filtered or unexported fields
}

func (*GetGovernanceVAABatchResponse) Descriptor deprecated 

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

Deprecated: Use GetGovernanceVAABatchResponse.ProtoReflect.Descriptor instead.

func (*GetGovernanceVAABatchResponse) GetEntries 

func (x *GetGovernanceVAABatchResponse) GetEntries() []*GetGovernanceVAABatchResponse_Entry

func (*GetGovernanceVAABatchResponse) ProtoMessage 

func (*GetGovernanceVAABatchResponse) ProtoMessage()

func (*GetGovernanceVAABatchResponse) ProtoReflect 

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

func (*GetGovernanceVAABatchResponse) Reset 

func (x *GetGovernanceVAABatchResponse) Reset()

func (*GetGovernanceVAABatchResponse) String 

func (x *GetGovernanceVAABatchResponse) String() string

type GetGovernanceVAABatchResponse_Entry 

type GetGovernanceVAABatchResponse_Entry struct {
	TargetChain ChainID `protobuf:"varint,1,opt,name=target_chain,json=targetChain,proto3,enum=publicrpc.v1.ChainID" json:"target_chain,omitempty"`
	Sequence    uint64  `protobuf:"varint,2,opt,name=sequence,proto3" json:"sequence,omitempty"`
	VaaBytes    []byte  `protobuf:"bytes,3,opt,name=vaa_bytes,json=vaaBytes,proto3" json:"vaa_bytes,omitempty"`
	// contains filtered or unexported fields
}

func (*GetGovernanceVAABatchResponse_Entry) Descriptor deprecated 

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

Deprecated: Use GetGovernanceVAABatchResponse_Entry.ProtoReflect.Descriptor instead.

func (*GetGovernanceVAABatchResponse_Entry) GetSequence 

func (x *GetGovernanceVAABatchResponse_Entry) GetSequence() uint64

func (*GetGovernanceVAABatchResponse_Entry) GetTargetChain 

func (x *GetGovernanceVAABatchResponse_Entry) GetTargetChain() ChainID

func (*GetGovernanceVAABatchResponse_Entry) GetVaaBytes 

func (x *GetGovernanceVAABatchResponse_Entry) GetVaaBytes() []byte

func (*GetGovernanceVAABatchResponse_Entry) ProtoMessage 

func (*GetGovernanceVAABatchResponse_Entry) ProtoMessage()

func (*GetGovernanceVAABatchResponse_Entry) ProtoReflect 

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

func (*GetGovernanceVAABatchResponse_Entry) Reset 

func (x *GetGovernanceVAABatchResponse_Entry) Reset()

func (*GetGovernanceVAABatchResponse_Entry) String 

func (x *GetGovernanceVAABatchResponse_Entry) String() string

type GetLastHeartbeatsRequest 

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

func (*GetLastHeartbeatsRequest) Descriptor deprecated 

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

Deprecated: Use GetLastHeartbeatsRequest.ProtoReflect.Descriptor instead.

func (*GetLastHeartbeatsRequest) ProtoMessage 

func (*GetLastHeartbeatsRequest) ProtoMessage()

func (*GetLastHeartbeatsRequest) ProtoReflect 

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

func (*GetLastHeartbeatsRequest) Reset 

func (x *GetLastHeartbeatsRequest) Reset()

func (*GetLastHeartbeatsRequest) String 

func (x *GetLastHeartbeatsRequest) String() string

type GetLastHeartbeatsResponse 

type GetLastHeartbeatsResponse struct {
	Entries []*GetLastHeartbeatsResponse_Entry `protobuf:"bytes,1,rep,name=entries,proto3" json:"entries,omitempty"`
	// contains filtered or unexported fields
}

func (*GetLastHeartbeatsResponse) Descriptor deprecated 

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

Deprecated: Use GetLastHeartbeatsResponse.ProtoReflect.Descriptor instead.

func (*GetLastHeartbeatsResponse) GetEntries 

func (x *GetLastHeartbeatsResponse) GetEntries() []*GetLastHeartbeatsResponse_Entry

func (*GetLastHeartbeatsResponse) ProtoMessage 

func (*GetLastHeartbeatsResponse) ProtoMessage()

func (*GetLastHeartbeatsResponse) ProtoReflect 

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

func (*GetLastHeartbeatsResponse) Reset 

func (x *GetLastHeartbeatsResponse) Reset()

func (*GetLastHeartbeatsResponse) String 

func (x *GetLastHeartbeatsResponse) String() string

type GetLastHeartbeatsResponse_Entry 

type GetLastHeartbeatsResponse_Entry struct {

	// Verified, hex-encoded (with leading 0x) guardian address. This is the guardian address
	// which signed this heartbeat. The GuardianAddr field inside the heartbeat
	// is NOT verified - remote nodes can put arbitrary data in it.
	VerifiedGuardianAddr string `protobuf:"bytes,1,opt,name=verified_guardian_addr,json=verifiedGuardianAddr,proto3" json:"verified_guardian_addr,omitempty"`
	// Base58-encoded libp2p node address that sent this heartbeat, used to
	// distinguish between multiple nodes running for the same guardian.
	P2PNodeAddr string `protobuf:"bytes,2,opt,name=p2p_node_addr,json=p2pNodeAddr,proto3" json:"p2p_node_addr,omitempty"`
	// Raw heartbeat received from the network. Data is only as trusted
	// as the guardian node that sent it - none of the fields are verified.
	RawHeartbeat *v1.Heartbeat `protobuf:"bytes,3,opt,name=raw_heartbeat,json=rawHeartbeat,proto3" json:"raw_heartbeat,omitempty"`
	// contains filtered or unexported fields
}

func (*GetLastHeartbeatsResponse_Entry) Descriptor deprecated 

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

Deprecated: Use GetLastHeartbeatsResponse_Entry.ProtoReflect.Descriptor instead.

func (*GetLastHeartbeatsResponse_Entry) GetP2PNodeAddr 

func (x *GetLastHeartbeatsResponse_Entry) GetP2PNodeAddr() string

func (*GetLastHeartbeatsResponse_Entry) GetRawHeartbeat 

func (x *GetLastHeartbeatsResponse_Entry) GetRawHeartbeat() *v1.Heartbeat

func (*GetLastHeartbeatsResponse_Entry) GetVerifiedGuardianAddr 

func (x *GetLastHeartbeatsResponse_Entry) GetVerifiedGuardianAddr() string

func (*GetLastHeartbeatsResponse_Entry) ProtoMessage 

func (*GetLastHeartbeatsResponse_Entry) ProtoMessage()

func (*GetLastHeartbeatsResponse_Entry) ProtoReflect 

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

func (*GetLastHeartbeatsResponse_Entry) Reset 

func (x *GetLastHeartbeatsResponse_Entry) Reset()

func (*GetLastHeartbeatsResponse_Entry) String 

func (x *GetLastHeartbeatsResponse_Entry) String() string

type GetNonGovernanceVAABatchRequest 

type GetNonGovernanceVAABatchRequest struct {

	// Emitter chain ID.
	EmitterChain ChainID `protobuf:"varint,1,opt,name=emitter_chain,json=emitterChain,proto3,enum=publicrpc.v1.ChainID" json:"emitter_chain,omitempty"`
	// Hex-encoded (without leading 0x) emitter address.
	EmitterAddress string `protobuf:"bytes,2,opt,name=emitter_address,json=emitterAddress,proto3" json:"emitter_address,omitempty"`
	// Target chain ID.
	TargetChain ChainID `protobuf:"varint,3,opt,name=target_chain,json=targetChain,proto3,enum=publicrpc.v1.ChainID" json:"target_chain,omitempty"`
	// Sequences
	Sequences []uint64 `protobuf:"varint,4,rep,packed,name=sequences,proto3" json:"sequences,omitempty"`
	// contains filtered or unexported fields
}

func (*GetNonGovernanceVAABatchRequest) Descriptor deprecated 

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

Deprecated: Use GetNonGovernanceVAABatchRequest.ProtoReflect.Descriptor instead.

func (*GetNonGovernanceVAABatchRequest) GetEmitterAddress 

func (x *GetNonGovernanceVAABatchRequest) GetEmitterAddress() string

func (*GetNonGovernanceVAABatchRequest) GetEmitterChain 

func (x *GetNonGovernanceVAABatchRequest) GetEmitterChain() ChainID

func (*GetNonGovernanceVAABatchRequest) GetSequences 

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

func (*GetNonGovernanceVAABatchRequest) GetTargetChain 

func (x *GetNonGovernanceVAABatchRequest) GetTargetChain() ChainID

func (*GetNonGovernanceVAABatchRequest) ProtoMessage 

func (*GetNonGovernanceVAABatchRequest) ProtoMessage()

func (*GetNonGovernanceVAABatchRequest) ProtoReflect 

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

func (*GetNonGovernanceVAABatchRequest) Reset 

func (x *GetNonGovernanceVAABatchRequest) Reset()

func (*GetNonGovernanceVAABatchRequest) String 

func (x *GetNonGovernanceVAABatchRequest) String() string

type GetNonGovernanceVAABatchResponse 

type GetNonGovernanceVAABatchResponse struct {
	Entries []*GetNonGovernanceVAABatchResponse_Entry `protobuf:"bytes,1,rep,name=entries,proto3" json:"entries,omitempty"`
	// contains filtered or unexported fields
}

func (*GetNonGovernanceVAABatchResponse) Descriptor deprecated 

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

Deprecated: Use GetNonGovernanceVAABatchResponse.ProtoReflect.Descriptor instead.

func (*GetNonGovernanceVAABatchResponse) GetEntries 

func (x *GetNonGovernanceVAABatchResponse) GetEntries() []*GetNonGovernanceVAABatchResponse_Entry

func (*GetNonGovernanceVAABatchResponse) ProtoMessage 

func (*GetNonGovernanceVAABatchResponse) ProtoMessage()

func (*GetNonGovernanceVAABatchResponse) ProtoReflect 

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

func (*GetNonGovernanceVAABatchResponse) Reset 

func (x *GetNonGovernanceVAABatchResponse) Reset()

func (*GetNonGovernanceVAABatchResponse) String 

func (x *GetNonGovernanceVAABatchResponse) String() string

type GetNonGovernanceVAABatchResponse_Entry 

type GetNonGovernanceVAABatchResponse_Entry struct {
	Sequence uint64 `protobuf:"varint,1,opt,name=sequence,proto3" json:"sequence,omitempty"`
	VaaBytes []byte `protobuf:"bytes,2,opt,name=vaa_bytes,json=vaaBytes,proto3" json:"vaa_bytes,omitempty"`
	// contains filtered or unexported fields
}

func (*GetNonGovernanceVAABatchResponse_Entry) Descriptor deprecated 

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

Deprecated: Use GetNonGovernanceVAABatchResponse_Entry.ProtoReflect.Descriptor instead.

func (*GetNonGovernanceVAABatchResponse_Entry) GetSequence 

func (x *GetNonGovernanceVAABatchResponse_Entry) GetSequence() uint64

func (*GetNonGovernanceVAABatchResponse_Entry) GetVaaBytes 

func (x *GetNonGovernanceVAABatchResponse_Entry) GetVaaBytes() []byte

func (*GetNonGovernanceVAABatchResponse_Entry) ProtoMessage 

func (*GetNonGovernanceVAABatchResponse_Entry) ProtoMessage()

func (*GetNonGovernanceVAABatchResponse_Entry) ProtoReflect 

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

func (*GetNonGovernanceVAABatchResponse_Entry) Reset 

func (x *GetNonGovernanceVAABatchResponse_Entry) Reset()

func (*GetNonGovernanceVAABatchResponse_Entry) String 

func (x *GetNonGovernanceVAABatchResponse_Entry) String() string

type GetSignedVAARequest 

type GetSignedVAARequest struct {
	MessageId *MessageID `protobuf:"bytes,1,opt,name=message_id,json=messageId,proto3" json:"message_id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetSignedVAARequest) Descriptor deprecated 

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

Deprecated: Use GetSignedVAARequest.ProtoReflect.Descriptor instead.

func (*GetSignedVAARequest) GetMessageId 

func (x *GetSignedVAARequest) GetMessageId() *MessageID

func (*GetSignedVAARequest) ProtoMessage 

func (*GetSignedVAARequest) ProtoMessage()

func (*GetSignedVAARequest) ProtoReflect 

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

func (*GetSignedVAARequest) Reset 

func (x *GetSignedVAARequest) Reset()

func (*GetSignedVAARequest) String 

func (x *GetSignedVAARequest) String() string

type GetSignedVAAResponse 

type GetSignedVAAResponse struct {
	VaaBytes []byte `protobuf:"bytes,1,opt,name=vaa_bytes,json=vaaBytes,proto3" json:"vaa_bytes,omitempty"`
	// contains filtered or unexported fields
}

func (*GetSignedVAAResponse) Descriptor deprecated 

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

Deprecated: Use GetSignedVAAResponse.ProtoReflect.Descriptor instead.

func (*GetSignedVAAResponse) GetVaaBytes 

func (x *GetSignedVAAResponse) GetVaaBytes() []byte

func (*GetSignedVAAResponse) ProtoMessage 

func (*GetSignedVAAResponse) ProtoMessage()

func (*GetSignedVAAResponse) ProtoReflect 

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

func (*GetSignedVAAResponse) Reset 

func (x *GetSignedVAAResponse) Reset()

func (*GetSignedVAAResponse) String 

func (x *GetSignedVAAResponse) String() string

type GuardianSet 

type GuardianSet struct {

	// Guardian set index
	Index uint32 `protobuf:"varint,1,opt,name=index,proto3" json:"index,omitempty"`
	// List of guardian addresses as human-readable hex-encoded (leading 0x) addresses.
	Addresses []string `protobuf:"bytes,2,rep,name=addresses,proto3" json:"addresses,omitempty"`
	// contains filtered or unexported fields
}

func (*GuardianSet) Descriptor deprecated 

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

Deprecated: Use GuardianSet.ProtoReflect.Descriptor instead.

func (*GuardianSet) GetAddresses 

func (x *GuardianSet) GetAddresses() []string

func (*GuardianSet) GetIndex 

func (x *GuardianSet) GetIndex() uint32

func (*GuardianSet) ProtoMessage 

func (*GuardianSet) ProtoMessage()

func (*GuardianSet) ProtoReflect 

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

func (*GuardianSet) Reset 

func (x *GuardianSet) Reset()

func (*GuardianSet) String 

func (x *GuardianSet) String() string

type MessageID 

type MessageID struct {

	// Emitter chain ID.
	EmitterChain ChainID `protobuf:"varint,1,opt,name=emitter_chain,json=emitterChain,proto3,enum=publicrpc.v1.ChainID" json:"emitter_chain,omitempty"`
	// Hex-encoded (without leading 0x) emitter address.
	EmitterAddress string `protobuf:"bytes,2,opt,name=emitter_address,json=emitterAddress,proto3" json:"emitter_address,omitempty"`
	// Target chain ID.
	TargetChain ChainID `protobuf:"varint,3,opt,name=target_chain,json=targetChain,proto3,enum=publicrpc.v1.ChainID" json:"target_chain,omitempty"`
	// Sequence number for (emitter_chain, emitter_address).
	Sequence uint64 `protobuf:"varint,4,opt,name=sequence,proto3" json:"sequence,omitempty"`
	// contains filtered or unexported fields
}

MessageID is a VAA's globally unique identifier (see data availability design document).

func (*MessageID) Descriptor deprecated 

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

Deprecated: Use MessageID.ProtoReflect.Descriptor instead.

func (*MessageID) GetEmitterAddress 

func (x *MessageID) GetEmitterAddress() string

func (*MessageID) GetEmitterChain 

func (x *MessageID) GetEmitterChain() ChainID

func (*MessageID) GetSequence 

func (x *MessageID) GetSequence() uint64

func (*MessageID) GetTargetChain 

func (x *MessageID) GetTargetChain() ChainID

func (*MessageID) ProtoMessage 

func (*MessageID) ProtoMessage()

func (*MessageID) ProtoReflect 

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

func (*MessageID) Reset 

func (x *MessageID) Reset()

func (*MessageID) String 

func (x *MessageID) String() string

type PublicRPCServiceClient 

type PublicRPCServiceClient interface {
	// GetLastHeartbeats returns the last heartbeat received for each guardian node in the
	// node's active guardian set. Heartbeats received by nodes not in the guardian set are ignored.
	// The heartbeat value is null if no heartbeat has yet been received.
	GetLastHeartbeats(ctx context.Context, in *GetLastHeartbeatsRequest, opts ...grpc.CallOption) (*GetLastHeartbeatsResponse, error)
	GetSignedVAA(ctx context.Context, in *GetSignedVAARequest, opts ...grpc.CallOption) (*GetSignedVAAResponse, error)
	GetNonGovernanceVAABatch(ctx context.Context, in *GetNonGovernanceVAABatchRequest, opts ...grpc.CallOption) (*GetNonGovernanceVAABatchResponse, error)
	GetGovernanceVAABatch(ctx context.Context, in *GetGovernanceVAABatchRequest, opts ...grpc.CallOption) (*GetGovernanceVAABatchResponse, error)
	GetCurrentGuardianSet(ctx context.Context, in *GetCurrentGuardianSetRequest, opts ...grpc.CallOption) (*GetCurrentGuardianSetResponse, error)
}

PublicRPCServiceClient is the client API for PublicRPCService 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 NewPublicRPCServiceClient 

func NewPublicRPCServiceClient(cc grpc.ClientConnInterface) PublicRPCServiceClient

type PublicRPCServiceServer 

type PublicRPCServiceServer interface {
	// GetLastHeartbeats returns the last heartbeat received for each guardian node in the
	// node's active guardian set. Heartbeats received by nodes not in the guardian set are ignored.
	// The heartbeat value is null if no heartbeat has yet been received.
	GetLastHeartbeats(context.Context, *GetLastHeartbeatsRequest) (*GetLastHeartbeatsResponse, error)
	GetSignedVAA(context.Context, *GetSignedVAARequest) (*GetSignedVAAResponse, error)
	GetNonGovernanceVAABatch(context.Context, *GetNonGovernanceVAABatchRequest) (*GetNonGovernanceVAABatchResponse, error)
	GetGovernanceVAABatch(context.Context, *GetGovernanceVAABatchRequest) (*GetGovernanceVAABatchResponse, error)
	GetCurrentGuardianSet(context.Context, *GetCurrentGuardianSetRequest) (*GetCurrentGuardianSetResponse, error)
	// contains filtered or unexported methods
}

PublicRPCServiceServer is the server API for PublicRPCService service. All implementations must embed UnimplementedPublicRPCServiceServer for forward compatibility

type UnimplementedPublicRPCServiceServer 

type UnimplementedPublicRPCServiceServer struct {
}

UnimplementedPublicRPCServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedPublicRPCServiceServer) GetCurrentGuardianSet 

func (UnimplementedPublicRPCServiceServer) GetCurrentGuardianSet(context.Context, *GetCurrentGuardianSetRequest) (*GetCurrentGuardianSetResponse, error)

func (UnimplementedPublicRPCServiceServer) GetGovernanceVAABatch 

func (UnimplementedPublicRPCServiceServer) GetGovernanceVAABatch(context.Context, *GetGovernanceVAABatchRequest) (*GetGovernanceVAABatchResponse, error)

func (UnimplementedPublicRPCServiceServer) GetLastHeartbeats 

func (UnimplementedPublicRPCServiceServer) GetLastHeartbeats(context.Context, *GetLastHeartbeatsRequest) (*GetLastHeartbeatsResponse, error)

func (UnimplementedPublicRPCServiceServer) GetNonGovernanceVAABatch 

func (UnimplementedPublicRPCServiceServer) GetNonGovernanceVAABatch(context.Context, *GetNonGovernanceVAABatchRequest) (*GetNonGovernanceVAABatchResponse, error)

func (UnimplementedPublicRPCServiceServer) GetSignedVAA 

func (UnimplementedPublicRPCServiceServer) GetSignedVAA(context.Context, *GetSignedVAARequest) (*GetSignedVAAResponse, error)

type UnsafePublicRPCServiceServer 

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

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

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.