types

package
v0.0.0-...-eab7081 Latest Latest
Warning

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

 Go to latest Published: Dec 13, 2023 License: Apache-2.0 Imports: 28 Imported by: 2

Documentation

Overview

Package types is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

View Source 
const (
	ETHEREUM_PUB_KEY_LEN = 65
	ETHEREUM_ADDR_LEN    = 20 // The ethereum address format is the last 20 bytes of the Keccak256 hashed public key
)

This is an ECDSA public key (secp256k1) in uncompressed format (65 bytes). The Cosmos hyperlane module is compatible with the same format.

View Source 
const (
	EventTypeAnnounce         = "ValidatorAnnouncement"
	AttributeKeySender        = "sender"
	AttributeValidatorAddress = "address"  // last 20 bytes of the keccak256 hash of the validator public key
	AttributeStorageLocation  = "location" // announced storage location for the validator signatures
)
View Source 
const (
	// ModuleName for the hyperlane-announce
	ModuleName = "hyperlane-announce"

	// StoreKey is the store key string for hyperlane-announce
	StoreKey = ModuleName

	// RouterKey is the message route for hyperlane-announce
	RouterKey = ModuleName
)

Variables

View Source 
var (
	ErrPackAnnouncement           = errorsmod.Register(ModuleName, 1, "failed packing announcement")
	ErrMarshalAnnouncement        = errorsmod.Register(ModuleName, 2, "failed marshalling announcement")
	ErrInvalidValidator           = errorsmod.Register(ModuleName, 3, "invalid validator address")
	ErrReplayAnnouncement         = errorsmod.Register(ModuleName, 4, "replay - validator already made this announcement")
	ErrBadDigest                  = errorsmod.Register(ModuleName, 5, "Signature does not match the declared validator")
	ErrMarshalAnnouncedValidators = errorsmod.Register(ModuleName, 6, "failed marshalling validators")
)
View Source 
var (
	ErrInvalidLengthGenesis        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowGenesis          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupGenesis = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	AnnouncedValidators       = []byte{0x00}
	AnnouncedStorageLocations = []byte{0x1}
)

KVStore keys

View Source 
var (
	ErrInvalidLengthQuery        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowQuery          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupQuery = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthTx        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTx          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupTx = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthTypes        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTypes          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupTypes = fmt.Errorf("proto: unexpected end of group")
)

Functions

func GetAnnouncementDigest 

func GetAnnouncementDigest(origin uint32, originMailbox []byte, storageLocation string) ([]byte, error)

func RegisterInterfaces 

func RegisterInterfaces(registry codectypes.InterfaceRegistry)

RegisterInterfaces registers the hyperlane announce implementations and interfaces.

func RegisterMsgServer 

func RegisterMsgServer(s grpc1.Server, srv MsgServer)

func RegisterQueryHandler 

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

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

func RegisterQueryHandlerClient 

func RegisterQueryHandlerClient(ctx context.Context, mux *runtime.ServeMux, client QueryClient) error

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

func RegisterQueryHandlerFromEndpoint 

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

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

func RegisterQueryHandlerServer 

func RegisterQueryHandlerServer(ctx context.Context, mux *runtime.ServeMux, server QueryServer) error

RegisterQueryHandlerServer registers the http handlers for service Query to "mux". UnaryRPC :call QueryServer 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 RegisterQueryHandlerFromEndpoint instead.

func RegisterQueryServer 

func RegisterQueryServer(s grpc1.Server, srv QueryServer)

func VerifyAnnouncementDigest 

func VerifyAnnouncementDigest(digest []byte, signature []byte, expectedSigner []byte) error

Types

type GenesisAnnouncement 

type GenesisAnnouncement struct {
	Announcements *StoredAnnouncements `protobuf:"bytes,1,opt,name=announcements,proto3" json:"announcements,omitempty"`
	// The validator (in eth address format) that announced
	Validator []byte `protobuf:"bytes,2,opt,name=validator,proto3" json:"validator,omitempty"`
}

Genesis helper type for Hyperlane's Announcement.

func (*GenesisAnnouncement) Descriptor 

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

func (*GenesisAnnouncement) Marshal 

func (m *GenesisAnnouncement) Marshal() (dAtA []byte, err error)

func (*GenesisAnnouncement) MarshalTo 

func (m *GenesisAnnouncement) MarshalTo(dAtA []byte) (int, error)

func (*GenesisAnnouncement) MarshalToSizedBuffer 

func (m *GenesisAnnouncement) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GenesisAnnouncement) ProtoMessage 

func (*GenesisAnnouncement) ProtoMessage()

func (*GenesisAnnouncement) Reset 

func (m *GenesisAnnouncement) Reset()

func (*GenesisAnnouncement) Size 

func (m *GenesisAnnouncement) Size() (n int)

func (*GenesisAnnouncement) String 

func (m *GenesisAnnouncement) String() string

func (*GenesisAnnouncement) Unmarshal 

func (m *GenesisAnnouncement) Unmarshal(dAtA []byte) error

func (*GenesisAnnouncement) XXX_DiscardUnknown 

func (m *GenesisAnnouncement) XXX_DiscardUnknown()

func (*GenesisAnnouncement) XXX_Marshal 

func (m *GenesisAnnouncement) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GenesisAnnouncement) XXX_Merge 

func (m *GenesisAnnouncement) XXX_Merge(src proto.Message)

func (*GenesisAnnouncement) XXX_Size 

func (m *GenesisAnnouncement) XXX_Size() int

func (*GenesisAnnouncement) XXX_Unmarshal 

func (m *GenesisAnnouncement) XXX_Unmarshal(b []byte) error

type GenesisState 

type GenesisState struct {
	Announcements []*GenesisAnnouncement `protobuf:"bytes,1,rep,name=announcements,proto3" json:"announcements,omitempty"`
}

Hyperlane Announce's keeper genesis state

func (*GenesisState) Descriptor 

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

func (*GenesisState) Marshal 

func (m *GenesisState) Marshal() (dAtA []byte, err error)

func (*GenesisState) MarshalTo 

func (m *GenesisState) MarshalTo(dAtA []byte) (int, error)

func (*GenesisState) MarshalToSizedBuffer 

func (m *GenesisState) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GenesisState) ProtoMessage 

func (*GenesisState) ProtoMessage()

func (*GenesisState) Reset 

func (m *GenesisState) Reset()

func (*GenesisState) Size 

func (m *GenesisState) Size() (n int)

func (*GenesisState) String 

func (m *GenesisState) String() string

func (*GenesisState) Unmarshal 

func (m *GenesisState) Unmarshal(dAtA []byte) error

func (*GenesisState) XXX_DiscardUnknown 

func (m *GenesisState) XXX_DiscardUnknown()

func (*GenesisState) XXX_Marshal 

func (m *GenesisState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GenesisState) XXX_Merge 

func (m *GenesisState) XXX_Merge(src proto.Message)

func (*GenesisState) XXX_Size 

func (m *GenesisState) XXX_Size() int

func (*GenesisState) XXX_Unmarshal 

func (m *GenesisState) XXX_Unmarshal(b []byte) error

type GetAnnouncedStorageLocationsRequest 

type GetAnnouncedStorageLocationsRequest struct {
	// list of validators where each validator is in hex-encoded eth address
	// format (20 bytes)
	Validator [][]byte `protobuf:"bytes,1,rep,name=validator,proto3" json:"validator,omitempty"`
}

GetAnnouncedStorageLocationsRequest is the request type for the GetAnnouncedStorageLocations RPC method.

func (*GetAnnouncedStorageLocationsRequest) Descriptor 

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

func (*GetAnnouncedStorageLocationsRequest) GetValidator 

func (m *GetAnnouncedStorageLocationsRequest) GetValidator() [][]byte

func (*GetAnnouncedStorageLocationsRequest) Marshal 

func (m *GetAnnouncedStorageLocationsRequest) Marshal() (dAtA []byte, err error)

func (*GetAnnouncedStorageLocationsRequest) MarshalTo 

func (m *GetAnnouncedStorageLocationsRequest) MarshalTo(dAtA []byte) (int, error)

func (*GetAnnouncedStorageLocationsRequest) MarshalToSizedBuffer 

func (m *GetAnnouncedStorageLocationsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetAnnouncedStorageLocationsRequest) ProtoMessage 

func (*GetAnnouncedStorageLocationsRequest) ProtoMessage()

func (*GetAnnouncedStorageLocationsRequest) Reset 

func (m *GetAnnouncedStorageLocationsRequest) Reset()

func (*GetAnnouncedStorageLocationsRequest) Size 

func (m *GetAnnouncedStorageLocationsRequest) Size() (n int)

func (*GetAnnouncedStorageLocationsRequest) String 

func (m *GetAnnouncedStorageLocationsRequest) String() string

func (*GetAnnouncedStorageLocationsRequest) Unmarshal 

func (m *GetAnnouncedStorageLocationsRequest) Unmarshal(dAtA []byte) error

func (*GetAnnouncedStorageLocationsRequest) XXX_DiscardUnknown 

func (m *GetAnnouncedStorageLocationsRequest) XXX_DiscardUnknown()

func (*GetAnnouncedStorageLocationsRequest) XXX_Marshal 

func (m *GetAnnouncedStorageLocationsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetAnnouncedStorageLocationsRequest) XXX_Merge 

func (m *GetAnnouncedStorageLocationsRequest) XXX_Merge(src proto.Message)

func (*GetAnnouncedStorageLocationsRequest) XXX_Size 

func (m *GetAnnouncedStorageLocationsRequest) XXX_Size() int

func (*GetAnnouncedStorageLocationsRequest) XXX_Unmarshal 

func (m *GetAnnouncedStorageLocationsRequest) XXX_Unmarshal(b []byte) error

type GetAnnouncedStorageLocationsResponse 

type GetAnnouncedStorageLocationsResponse struct {
	Metadata []*StorageMetadata `protobuf:"bytes,1,rep,name=metadata,proto3" json:"metadata,omitempty"`
}

GetAnnouncedStorageLocationsResponse is the response type for the GetAnnouncedStorageLocations RPC method.

func (*GetAnnouncedStorageLocationsResponse) Descriptor 

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

func (*GetAnnouncedStorageLocationsResponse) GetMetadata 

func (m *GetAnnouncedStorageLocationsResponse) GetMetadata() []*StorageMetadata

func (*GetAnnouncedStorageLocationsResponse) Marshal 

func (m *GetAnnouncedStorageLocationsResponse) Marshal() (dAtA []byte, err error)

func (*GetAnnouncedStorageLocationsResponse) MarshalTo 

func (m *GetAnnouncedStorageLocationsResponse) MarshalTo(dAtA []byte) (int, error)

func (*GetAnnouncedStorageLocationsResponse) MarshalToSizedBuffer 

func (m *GetAnnouncedStorageLocationsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetAnnouncedStorageLocationsResponse) ProtoMessage 

func (*GetAnnouncedStorageLocationsResponse) ProtoMessage()

func (*GetAnnouncedStorageLocationsResponse) Reset 

func (m *GetAnnouncedStorageLocationsResponse) Reset()

func (*GetAnnouncedStorageLocationsResponse) Size 

func (m *GetAnnouncedStorageLocationsResponse) Size() (n int)

func (*GetAnnouncedStorageLocationsResponse) String 

func (m *GetAnnouncedStorageLocationsResponse) String() string

func (*GetAnnouncedStorageLocationsResponse) Unmarshal 

func (m *GetAnnouncedStorageLocationsResponse) Unmarshal(dAtA []byte) error

func (*GetAnnouncedStorageLocationsResponse) XXX_DiscardUnknown 

func (m *GetAnnouncedStorageLocationsResponse) XXX_DiscardUnknown()

func (*GetAnnouncedStorageLocationsResponse) XXX_Marshal 

func (m *GetAnnouncedStorageLocationsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetAnnouncedStorageLocationsResponse) XXX_Merge 

func (m *GetAnnouncedStorageLocationsResponse) XXX_Merge(src proto.Message)

func (*GetAnnouncedStorageLocationsResponse) XXX_Size 

func (m *GetAnnouncedStorageLocationsResponse) XXX_Size() int

func (*GetAnnouncedStorageLocationsResponse) XXX_Unmarshal 

func (m *GetAnnouncedStorageLocationsResponse) XXX_Unmarshal(b []byte) error

type GetAnnouncedValidatorsRequest 

type GetAnnouncedValidatorsRequest struct{}

GetAnnouncedValidatorsRequest is the request type for the GetAnnouncedValidators RPC method.

func (*GetAnnouncedValidatorsRequest) Descriptor 

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

func (*GetAnnouncedValidatorsRequest) Marshal 

func (m *GetAnnouncedValidatorsRequest) Marshal() (dAtA []byte, err error)

func (*GetAnnouncedValidatorsRequest) MarshalTo 

func (m *GetAnnouncedValidatorsRequest) MarshalTo(dAtA []byte) (int, error)

func (*GetAnnouncedValidatorsRequest) MarshalToSizedBuffer 

func (m *GetAnnouncedValidatorsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetAnnouncedValidatorsRequest) ProtoMessage 

func (*GetAnnouncedValidatorsRequest) ProtoMessage()

func (*GetAnnouncedValidatorsRequest) Reset 

func (m *GetAnnouncedValidatorsRequest) Reset()

func (*GetAnnouncedValidatorsRequest) Size 

func (m *GetAnnouncedValidatorsRequest) Size() (n int)

func (*GetAnnouncedValidatorsRequest) String 

func (m *GetAnnouncedValidatorsRequest) String() string

func (*GetAnnouncedValidatorsRequest) Unmarshal 

func (m *GetAnnouncedValidatorsRequest) Unmarshal(dAtA []byte) error

func (*GetAnnouncedValidatorsRequest) XXX_DiscardUnknown 

func (m *GetAnnouncedValidatorsRequest) XXX_DiscardUnknown()

func (*GetAnnouncedValidatorsRequest) XXX_Marshal 

func (m *GetAnnouncedValidatorsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetAnnouncedValidatorsRequest) XXX_Merge 

func (m *GetAnnouncedValidatorsRequest) XXX_Merge(src proto.Message)

func (*GetAnnouncedValidatorsRequest) XXX_Size 

func (m *GetAnnouncedValidatorsRequest) XXX_Size() int

func (*GetAnnouncedValidatorsRequest) XXX_Unmarshal 

func (m *GetAnnouncedValidatorsRequest) XXX_Unmarshal(b []byte) error

type GetAnnouncedValidatorsResponse 

type GetAnnouncedValidatorsResponse struct {
	// list of validators where each validator is in hex-encoded eth address
	// format (20 bytes)
	Validator []string `protobuf:"bytes,1,rep,name=validator,proto3" json:"validator,omitempty"`
}

GetAnnouncedValidatorsResponse is the response type for the GetAnnouncedValidators RPC method.

func (*GetAnnouncedValidatorsResponse) Descriptor 

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

func (*GetAnnouncedValidatorsResponse) GetValidator 

func (m *GetAnnouncedValidatorsResponse) GetValidator() []string

func (*GetAnnouncedValidatorsResponse) Marshal 

func (m *GetAnnouncedValidatorsResponse) Marshal() (dAtA []byte, err error)

func (*GetAnnouncedValidatorsResponse) MarshalTo 

func (m *GetAnnouncedValidatorsResponse) MarshalTo(dAtA []byte) (int, error)

func (*GetAnnouncedValidatorsResponse) MarshalToSizedBuffer 

func (m *GetAnnouncedValidatorsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetAnnouncedValidatorsResponse) ProtoMessage 

func (*GetAnnouncedValidatorsResponse) ProtoMessage()

func (*GetAnnouncedValidatorsResponse) Reset 

func (m *GetAnnouncedValidatorsResponse) Reset()

func (*GetAnnouncedValidatorsResponse) Size 

func (m *GetAnnouncedValidatorsResponse) Size() (n int)

func (*GetAnnouncedValidatorsResponse) String 

func (m *GetAnnouncedValidatorsResponse) String() string

func (*GetAnnouncedValidatorsResponse) Unmarshal 

func (m *GetAnnouncedValidatorsResponse) Unmarshal(dAtA []byte) error

func (*GetAnnouncedValidatorsResponse) XXX_DiscardUnknown 

func (m *GetAnnouncedValidatorsResponse) XXX_DiscardUnknown()

func (*GetAnnouncedValidatorsResponse) XXX_Marshal 

func (m *GetAnnouncedValidatorsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetAnnouncedValidatorsResponse) XXX_Merge 

func (m *GetAnnouncedValidatorsResponse) XXX_Merge(src proto.Message)

func (*GetAnnouncedValidatorsResponse) XXX_Size 

func (m *GetAnnouncedValidatorsResponse) XXX_Size() int

func (*GetAnnouncedValidatorsResponse) XXX_Unmarshal 

func (m *GetAnnouncedValidatorsResponse) XXX_Unmarshal(b []byte) error

type MailboxKeeper 

type MailboxKeeper interface {
	GetMailboxAddress() []byte
	GetDomain(context.Context) uint32
}

type MsgAnnouncement 

type MsgAnnouncement struct {
	Sender string `protobuf:"bytes,1,opt,name=sender,proto3" json:"sender,omitempty"`
	// The validator (in eth address format) that is announcing its storage
	// location
	Validator []byte `protobuf:"bytes,2,opt,name=validator,proto3" json:"validator,omitempty"`
	// location where signatures will be stored
	StorageLocation string `protobuf:"bytes,3,opt,name=storage_location,json=storageLocation,proto3" json:"storage_location,omitempty"`
	// signed validator announcement
	Signature []byte `protobuf:"bytes,4,opt,name=signature,proto3" json:"signature,omitempty"`
}

MsgAnnouncement Announces a validator signature storage location

func (*MsgAnnouncement) Descriptor 

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

func (MsgAnnouncement) GetSigners 

func (m MsgAnnouncement) GetSigners() []sdk.AccAddress

GetSigners implements sdk.Msg

func (*MsgAnnouncement) Marshal 

func (m *MsgAnnouncement) Marshal() (dAtA []byte, err error)

func (*MsgAnnouncement) MarshalTo 

func (m *MsgAnnouncement) MarshalTo(dAtA []byte) (int, error)

func (*MsgAnnouncement) MarshalToSizedBuffer 

func (m *MsgAnnouncement) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MsgAnnouncement) ProtoMessage 

func (*MsgAnnouncement) ProtoMessage()

func (*MsgAnnouncement) Reset 

func (m *MsgAnnouncement) Reset()

func (*MsgAnnouncement) Size 

func (m *MsgAnnouncement) Size() (n int)

func (*MsgAnnouncement) String 

func (m *MsgAnnouncement) String() string

func (*MsgAnnouncement) Unmarshal 

func (m *MsgAnnouncement) Unmarshal(dAtA []byte) error

func (MsgAnnouncement) ValidateBasic 

func (m MsgAnnouncement) ValidateBasic() error

ValidateBasic implements sdk.Msg

func (*MsgAnnouncement) XXX_DiscardUnknown 

func (m *MsgAnnouncement) XXX_DiscardUnknown()

func (*MsgAnnouncement) XXX_Marshal 

func (m *MsgAnnouncement) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MsgAnnouncement) XXX_Merge 

func (m *MsgAnnouncement) XXX_Merge(src proto.Message)

func (*MsgAnnouncement) XXX_Size 

func (m *MsgAnnouncement) XXX_Size() int

func (*MsgAnnouncement) XXX_Unmarshal 

func (m *MsgAnnouncement) XXX_Unmarshal(b []byte) error

type MsgAnnouncementResponse 

type MsgAnnouncementResponse struct{}

MsgAnnouncementResponse defines the MsgAnnouncementResponse response type.

func (*MsgAnnouncementResponse) Descriptor 

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

func (*MsgAnnouncementResponse) Marshal 

func (m *MsgAnnouncementResponse) Marshal() (dAtA []byte, err error)

func (*MsgAnnouncementResponse) MarshalTo 

func (m *MsgAnnouncementResponse) MarshalTo(dAtA []byte) (int, error)

func (*MsgAnnouncementResponse) MarshalToSizedBuffer 

func (m *MsgAnnouncementResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MsgAnnouncementResponse) ProtoMessage 

func (*MsgAnnouncementResponse) ProtoMessage()

func (*MsgAnnouncementResponse) Reset 

func (m *MsgAnnouncementResponse) Reset()

func (*MsgAnnouncementResponse) Size 

func (m *MsgAnnouncementResponse) Size() (n int)

func (*MsgAnnouncementResponse) String 

func (m *MsgAnnouncementResponse) String() string

func (*MsgAnnouncementResponse) Unmarshal 

func (m *MsgAnnouncementResponse) Unmarshal(dAtA []byte) error

func (*MsgAnnouncementResponse) XXX_DiscardUnknown 

func (m *MsgAnnouncementResponse) XXX_DiscardUnknown()

func (*MsgAnnouncementResponse) XXX_Marshal 

func (m *MsgAnnouncementResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MsgAnnouncementResponse) XXX_Merge 

func (m *MsgAnnouncementResponse) XXX_Merge(src proto.Message)

func (*MsgAnnouncementResponse) XXX_Size 

func (m *MsgAnnouncementResponse) XXX_Size() int

func (*MsgAnnouncementResponse) XXX_Unmarshal 

func (m *MsgAnnouncementResponse) XXX_Unmarshal(b []byte) error

type MsgClient 

type MsgClient interface {
	// Announces a validator signature storage location
	Announcement(ctx context.Context, in *MsgAnnouncement, opts ...grpc.CallOption) (*MsgAnnouncementResponse, error)
}

MsgClient is the client API for Msg service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewMsgClient 

func NewMsgClient(cc grpc1.ClientConn) MsgClient

type MsgServer 

type MsgServer interface {
	// Announces a validator signature storage location
	Announcement(context.Context, *MsgAnnouncement) (*MsgAnnouncementResponse, error)
}

MsgServer is the server API for Msg service.

type QueryClient 

type QueryClient interface {
	// Gets the announced storage locations (where signatures are stored) for the
	// requested validators
	GetAnnouncedStorageLocations(ctx context.Context, in *GetAnnouncedStorageLocationsRequest, opts ...grpc.CallOption) (*GetAnnouncedStorageLocationsResponse, error)
	// Gets a list of validators that have made announcements
	GetAnnouncedValidators(ctx context.Context, in *GetAnnouncedValidatorsRequest, opts ...grpc.CallOption) (*GetAnnouncedValidatorsResponse, error)
}

QueryClient is the client API for Query service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewQueryClient 

func NewQueryClient(cc grpc1.ClientConn) QueryClient

type QueryServer 

type QueryServer interface {
	// Gets the announced storage locations (where signatures are stored) for the
	// requested validators
	GetAnnouncedStorageLocations(context.Context, *GetAnnouncedStorageLocationsRequest) (*GetAnnouncedStorageLocationsResponse, error)
	// Gets a list of validators that have made announcements
	GetAnnouncedValidators(context.Context, *GetAnnouncedValidatorsRequest) (*GetAnnouncedValidatorsResponse, error)
}

QueryServer is the server API for Query service.

type StorageMetadata 

type StorageMetadata struct {
	Metadata []string `protobuf:"bytes,1,rep,name=metadata,proto3" json:"metadata,omitempty"`
}

Helper type for Hyperlane's getAnnouncedStorageLocations.

func (*StorageMetadata) Descriptor 

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

func (*StorageMetadata) Marshal 

func (m *StorageMetadata) Marshal() (dAtA []byte, err error)

func (*StorageMetadata) MarshalTo 

func (m *StorageMetadata) MarshalTo(dAtA []byte) (int, error)

func (*StorageMetadata) MarshalToSizedBuffer 

func (m *StorageMetadata) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*StorageMetadata) ProtoMessage 

func (*StorageMetadata) ProtoMessage()

func (*StorageMetadata) Reset 

func (m *StorageMetadata) Reset()

func (*StorageMetadata) Size 

func (m *StorageMetadata) Size() (n int)

func (*StorageMetadata) String 

func (m *StorageMetadata) String() string

func (*StorageMetadata) Unmarshal 

func (m *StorageMetadata) Unmarshal(dAtA []byte) error

func (*StorageMetadata) XXX_DiscardUnknown 

func (m *StorageMetadata) XXX_DiscardUnknown()

func (*StorageMetadata) XXX_Marshal 

func (m *StorageMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StorageMetadata) XXX_Merge 

func (m *StorageMetadata) XXX_Merge(src proto.Message)

func (*StorageMetadata) XXX_Size 

func (m *StorageMetadata) XXX_Size() int

func (*StorageMetadata) XXX_Unmarshal 

func (m *StorageMetadata) XXX_Unmarshal(b []byte) error

type StoredAnnouncement 

type StoredAnnouncement struct {
	// location where signatures will be stored
	StorageLocation string `protobuf:"bytes,1,opt,name=storage_location,json=storageLocation,proto3" json:"storage_location,omitempty"`
}

Helper type for Hyperlane's Announcement.

func (*StoredAnnouncement) Descriptor 

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

func (*StoredAnnouncement) Marshal 

func (m *StoredAnnouncement) Marshal() (dAtA []byte, err error)

func (*StoredAnnouncement) MarshalTo 

func (m *StoredAnnouncement) MarshalTo(dAtA []byte) (int, error)

func (*StoredAnnouncement) MarshalToSizedBuffer 

func (m *StoredAnnouncement) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*StoredAnnouncement) ProtoMessage 

func (*StoredAnnouncement) ProtoMessage()

func (*StoredAnnouncement) Reset 

func (m *StoredAnnouncement) Reset()

func (*StoredAnnouncement) Size 

func (m *StoredAnnouncement) Size() (n int)

func (*StoredAnnouncement) String 

func (m *StoredAnnouncement) String() string

func (*StoredAnnouncement) Unmarshal 

func (m *StoredAnnouncement) Unmarshal(dAtA []byte) error

func (*StoredAnnouncement) XXX_DiscardUnknown 

func (m *StoredAnnouncement) XXX_DiscardUnknown()

func (*StoredAnnouncement) XXX_Marshal 

func (m *StoredAnnouncement) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StoredAnnouncement) XXX_Merge 

func (m *StoredAnnouncement) XXX_Merge(src proto.Message)

func (*StoredAnnouncement) XXX_Size 

func (m *StoredAnnouncement) XXX_Size() int

func (*StoredAnnouncement) XXX_Unmarshal 

func (m *StoredAnnouncement) XXX_Unmarshal(b []byte) error

type StoredAnnouncements 

type StoredAnnouncements struct {
	Announcement []*StoredAnnouncement `protobuf:"bytes,1,rep,name=announcement,proto3" json:"announcement,omitempty"`
}

Helper type for Hyperlane's Announcement.

func (*StoredAnnouncements) Descriptor 

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

func (*StoredAnnouncements) Marshal 

func (m *StoredAnnouncements) Marshal() (dAtA []byte, err error)

func (*StoredAnnouncements) MarshalTo 

func (m *StoredAnnouncements) MarshalTo(dAtA []byte) (int, error)

func (*StoredAnnouncements) MarshalToSizedBuffer 

func (m *StoredAnnouncements) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*StoredAnnouncements) ProtoMessage 

func (*StoredAnnouncements) ProtoMessage()

func (*StoredAnnouncements) Reset 

func (m *StoredAnnouncements) Reset()

func (*StoredAnnouncements) Size 

func (m *StoredAnnouncements) Size() (n int)

func (*StoredAnnouncements) String 

func (m *StoredAnnouncements) String() string

func (*StoredAnnouncements) Unmarshal 

func (m *StoredAnnouncements) Unmarshal(dAtA []byte) error

func (*StoredAnnouncements) XXX_DiscardUnknown 

func (m *StoredAnnouncements) XXX_DiscardUnknown()

func (*StoredAnnouncements) XXX_Marshal 

func (m *StoredAnnouncements) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StoredAnnouncements) XXX_Merge 

func (m *StoredAnnouncements) XXX_Merge(src proto.Message)

func (*StoredAnnouncements) XXX_Size 

func (m *StoredAnnouncements) XXX_Size() int

func (*StoredAnnouncements) XXX_Unmarshal 

func (m *StoredAnnouncements) XXX_Unmarshal(b []byte) error

type UnimplementedMsgServer 

type UnimplementedMsgServer struct{}

UnimplementedMsgServer can be embedded to have forward compatible implementations.

func (*UnimplementedMsgServer) Announcement 

func (*UnimplementedMsgServer) Announcement(ctx context.Context, req *MsgAnnouncement) (*MsgAnnouncementResponse, error)

type UnimplementedQueryServer 

type UnimplementedQueryServer struct{}

UnimplementedQueryServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryServer) GetAnnouncedStorageLocations 

func (*UnimplementedQueryServer) GetAnnouncedStorageLocations(ctx context.Context, req *GetAnnouncedStorageLocationsRequest) (*GetAnnouncedStorageLocationsResponse, error)

func (*UnimplementedQueryServer) GetAnnouncedValidators 

func (*UnimplementedQueryServer) GetAnnouncedValidators(ctx context.Context, req *GetAnnouncedValidatorsRequest) (*GetAnnouncedValidatorsResponse, error)

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.