types

package
v0.11.0 Latest Latest
Warning

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

 Go to latest Published: Nov 25, 2024 License: GPL-3.0 Imports: 20 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	StatusUnknown  uint32 = 0
	StatusPending  uint32 = 1
	StatusApproved uint32 = 2
)
View Source 
const (
	// ModuleName defines the module name.
	ModuleName = "attest"
)

Variables

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 MsgService_serviceDesc = _MsgService_serviceDesc
View Source 
var Query_serviceDesc = _Query_serviceDesc

Functions

func AttLogs added in v0.11.0 

func AttLogs(headers []*AttestHeader) []any

AttLogs returns the headers as opinionated human-readable logging attributes.

func AttestHeaderFromProto 

func AttestHeaderFromProto(header *AttestHeader) xchain.AttestHeader

AttestHeaderFromProto converts a protobuf AttestHeader to a xchain.AttestHeader.

func AttestationFromProto 

func AttestationFromProto(att *Attestation) (xchain.Attestation, error)

AttestationFromProto converts a protobuf Attestation to a xchain.Attestation.

func AttestationsFromProto 

func AttestationsFromProto(atts []*Attestation) ([]xchain.Attestation, error)

AttestationsFromProto converts a slice of protobuf Attestations to a slice of xchain.Attestations.

func BlockHeaderFromProto 

func BlockHeaderFromProto(header *BlockHeader) (xchain.BlockHeader, error)

BlockHeaderFromProto converts a protobuf BlockHeader to a xchain.BlockHeader.

func RegisterInterfaces 

func RegisterInterfaces(registry cdctypes.InterfaceRegistry)

func RegisterMsgServiceServer 

func RegisterMsgServiceServer(s grpc1.Server, srv MsgServiceServer)

func RegisterQueryServer 

func RegisterQueryServer(s grpc1.Server, srv QueryServer)

func SigFromProto 

func SigFromProto(sig *SigTuple) (xchain.SigTuple, error)

SigFromProto converts a protobuf SigTuple to a xchain.SigTuple.

func VoteLogs added in v0.11.0 

func VoteLogs(votes []*Vote) []any

VoteLogs returns the logs as opinionated human-readable logging attributes.

Types

type AddVotesResponse 

type AddVotesResponse struct {
}

func (*AddVotesResponse) Descriptor 

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

func (*AddVotesResponse) Marshal 

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

func (*AddVotesResponse) MarshalTo 

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

func (*AddVotesResponse) MarshalToSizedBuffer 

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

func (*AddVotesResponse) ProtoMessage 

func (*AddVotesResponse) ProtoMessage()

func (*AddVotesResponse) Reset 

func (m *AddVotesResponse) Reset()

func (*AddVotesResponse) Size 

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

func (*AddVotesResponse) String 

func (m *AddVotesResponse) String() string

func (*AddVotesResponse) Unmarshal 

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

func (*AddVotesResponse) XXX_DiscardUnknown 

func (m *AddVotesResponse) XXX_DiscardUnknown()

func (*AddVotesResponse) XXX_Marshal 

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

func (*AddVotesResponse) XXX_Merge 

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

func (*AddVotesResponse) XXX_Size 

func (m *AddVotesResponse) XXX_Size() int

func (*AddVotesResponse) XXX_Unmarshal 

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

type AggVote 

type AggVote struct {
	AttestHeader *AttestHeader `protobuf:"bytes,1,opt,name=attest_header,json=attestHeader,proto3" json:"attest_header,omitempty"`
	BlockHeader  *BlockHeader  `protobuf:"bytes,2,opt,name=block_header,json=blockHeader,proto3" json:"block_header,omitempty"`
	MsgRoot      []byte        `protobuf:"bytes,3,opt,name=msg_root,json=msgRoot,proto3" json:"msg_root,omitempty"`
	Signatures   []*SigTuple   `protobuf:"bytes,4,rep,name=signatures,proto3" json:"signatures,omitempty"`
}

AggVote aggregates multiple votes of a cross-chain Block.

func (*AggVote) AttestationRoot 

func (a *AggVote) AttestationRoot() (common.Hash, error)

func (*AggVote) Descriptor 

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

func (*AggVote) GetAttestHeader 

func (m *AggVote) GetAttestHeader() *AttestHeader

func (*AggVote) GetBlockHeader 

func (m *AggVote) GetBlockHeader() *BlockHeader

func (*AggVote) GetMsgRoot 

func (m *AggVote) GetMsgRoot() []byte

func (*AggVote) GetSignatures 

func (m *AggVote) GetSignatures() []*SigTuple

func (*AggVote) Marshal 

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

func (*AggVote) MarshalTo 

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

func (*AggVote) MarshalToSizedBuffer 

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

func (*AggVote) ProtoMessage 

func (*AggVote) ProtoMessage()

func (*AggVote) Reset 

func (m *AggVote) Reset()

func (*AggVote) Size 

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

func (*AggVote) String 

func (m *AggVote) String() string

func (*AggVote) Unmarshal 

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

func (*AggVote) Verify 

func (a *AggVote) Verify() error

func (*AggVote) XXX_DiscardUnknown 

func (m *AggVote) XXX_DiscardUnknown()

func (*AggVote) XXX_Marshal 

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

func (*AggVote) XXX_Merge 

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

func (*AggVote) XXX_Size 

func (m *AggVote) XXX_Size() int

func (*AggVote) XXX_Unmarshal 

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

type AttestHeader 

type AttestHeader struct {
	ConsensusChainId uint64 `protobuf:"varint,1,opt,name=consensus_chain_id,json=consensusChainId,proto3" json:"consensus_chain_id,omitempty"`
	SourceChainId    uint64 `protobuf:"varint,2,opt,name=source_chain_id,json=sourceChainId,proto3" json:"source_chain_id,omitempty"`
	ConfLevel        uint32 `protobuf:"varint,3,opt,name=conf_level,json=confLevel,proto3" json:"conf_level,omitempty"`
	AttestOffset     uint64 `protobuf:"varint,4,opt,name=attest_offset,json=attestOffset,proto3" json:"attest_offset,omitempty"`
}

AttestHeader uniquely identifies an attestation that requires quorum votes. This is used to determine duplicate votes.

func (*AttestHeader) Descriptor 

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

func (*AttestHeader) GetAttestOffset 

func (m *AttestHeader) GetAttestOffset() uint64

func (*AttestHeader) GetConfLevel 

func (m *AttestHeader) GetConfLevel() uint32

func (*AttestHeader) GetConsensusChainId 

func (m *AttestHeader) GetConsensusChainId() uint64

func (*AttestHeader) GetSourceChainId 

func (m *AttestHeader) GetSourceChainId() uint64

func (*AttestHeader) Marshal 

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

func (*AttestHeader) MarshalTo 

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

func (*AttestHeader) MarshalToSizedBuffer 

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

func (*AttestHeader) ProtoMessage 

func (*AttestHeader) ProtoMessage()

func (*AttestHeader) Reset 

func (m *AttestHeader) Reset()

func (*AttestHeader) Size 

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

func (*AttestHeader) String 

func (m *AttestHeader) String() string

func (*AttestHeader) ToXChain 

func (h *AttestHeader) ToXChain() xchain.AttestHeader

func (*AttestHeader) Unmarshal 

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

func (*AttestHeader) Verify 

func (h *AttestHeader) Verify() error

func (*AttestHeader) XChainVersion 

func (h *AttestHeader) XChainVersion() xchain.ChainVersion

func (*AttestHeader) XXX_DiscardUnknown 

func (m *AttestHeader) XXX_DiscardUnknown()

func (*AttestHeader) XXX_Marshal 

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

func (*AttestHeader) XXX_Merge 

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

func (*AttestHeader) XXX_Size 

func (m *AttestHeader) XXX_Size() int

func (*AttestHeader) XXX_Unmarshal 

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

type AttestKeeper 

type AttestKeeper interface {
	ListAttestationsFrom(ctx context.Context, chainID uint64, confLevel uint32, offset uint64, max uint64) ([]*Attestation, error)
}

type Attestation 

type Attestation struct {
	AttestHeader   *AttestHeader `protobuf:"bytes,1,opt,name=attest_header,json=attestHeader,proto3" json:"attest_header,omitempty"`
	BlockHeader    *BlockHeader  `protobuf:"bytes,2,opt,name=block_header,json=blockHeader,proto3" json:"block_header,omitempty"`
	MsgRoot        []byte        `protobuf:"bytes,3,opt,name=msg_root,json=msgRoot,proto3" json:"msg_root,omitempty"`
	Signatures     []*SigTuple   `protobuf:"bytes,4,rep,name=signatures,proto3" json:"signatures,omitempty"`
	ValidatorSetId uint64        `protobuf:"varint,5,opt,name=validator_set_id,json=validatorSetId,proto3" json:"validator_set_id,omitempty"`
}

Attestation contains quorum votes for a cross-chain block of a specific validator set.

func (*Attestation) AttestationRoot 

func (a *Attestation) AttestationRoot() (common.Hash, error)

func (*Attestation) Descriptor 

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

func (*Attestation) GetAttestHeader 

func (m *Attestation) GetAttestHeader() *AttestHeader

func (*Attestation) GetBlockHeader 

func (m *Attestation) GetBlockHeader() *BlockHeader

func (*Attestation) GetMsgRoot 

func (m *Attestation) GetMsgRoot() []byte

func (*Attestation) GetSignatures 

func (m *Attestation) GetSignatures() []*SigTuple

func (*Attestation) GetValidatorSetId 

func (m *Attestation) GetValidatorSetId() uint64

func (*Attestation) Marshal 

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

func (*Attestation) MarshalTo 

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

func (*Attestation) MarshalToSizedBuffer 

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

func (*Attestation) ProtoMessage 

func (*Attestation) ProtoMessage()

func (*Attestation) Reset 

func (m *Attestation) Reset()

func (*Attestation) Size 

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

func (*Attestation) String 

func (m *Attestation) String() string

func (*Attestation) ToXChain 

func (a *Attestation) ToXChain() (xchain.Attestation, error)

func (*Attestation) Unmarshal 

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

func (*Attestation) Verify 

func (a *Attestation) Verify() error

func (*Attestation) XXX_DiscardUnknown 

func (m *Attestation) XXX_DiscardUnknown()

func (*Attestation) XXX_Marshal 

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

func (*Attestation) XXX_Merge 

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

func (*Attestation) XXX_Size 

func (m *Attestation) XXX_Size() int

func (*Attestation) XXX_Unmarshal 

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

type AttestationsFromRequest 

type AttestationsFromRequest struct {
	ChainId    uint64 `protobuf:"varint,1,opt,name=chain_id,json=chainId,proto3" json:"chain_id,omitempty"`
	ConfLevel  uint32 `protobuf:"varint,2,opt,name=conf_level,json=confLevel,proto3" json:"conf_level,omitempty"`
	FromOffset uint64 `protobuf:"varint,3,opt,name=from_offset,json=fromOffset,proto3" json:"from_offset,omitempty"`
}

ApprovedFromRequest queries halo for approved attestations for the given chain_id and from the given height (inclusive). The response will contain at most max attestations sequentially following from_height.

func (*AttestationsFromRequest) Descriptor 

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

func (*AttestationsFromRequest) GetChainId 

func (m *AttestationsFromRequest) GetChainId() uint64

func (*AttestationsFromRequest) GetConfLevel 

func (m *AttestationsFromRequest) GetConfLevel() uint32

func (*AttestationsFromRequest) GetFromOffset 

func (m *AttestationsFromRequest) GetFromOffset() uint64

func (*AttestationsFromRequest) Marshal 

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

func (*AttestationsFromRequest) MarshalTo 

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

func (*AttestationsFromRequest) MarshalToSizedBuffer 

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

func (*AttestationsFromRequest) ProtoMessage 

func (*AttestationsFromRequest) ProtoMessage()

func (*AttestationsFromRequest) Reset 

func (m *AttestationsFromRequest) Reset()

func (*AttestationsFromRequest) Size 

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

func (*AttestationsFromRequest) String 

func (m *AttestationsFromRequest) String() string

func (*AttestationsFromRequest) Unmarshal 

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

func (*AttestationsFromRequest) XXX_DiscardUnknown 

func (m *AttestationsFromRequest) XXX_DiscardUnknown()

func (*AttestationsFromRequest) XXX_Marshal 

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

func (*AttestationsFromRequest) XXX_Merge 

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

func (*AttestationsFromRequest) XXX_Size 

func (m *AttestationsFromRequest) XXX_Size() int

func (*AttestationsFromRequest) XXX_Unmarshal 

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

type AttestationsFromResponse 

type AttestationsFromResponse struct {
	Attestations []*Attestation `protobuf:"bytes,1,rep,name=attestations,proto3" json:"attestations,omitempty"`
}

func (*AttestationsFromResponse) Descriptor 

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

func (*AttestationsFromResponse) GetAttestations 

func (m *AttestationsFromResponse) GetAttestations() []*Attestation

func (*AttestationsFromResponse) Marshal 

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

func (*AttestationsFromResponse) MarshalTo 

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

func (*AttestationsFromResponse) MarshalToSizedBuffer 

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

func (*AttestationsFromResponse) ProtoMessage 

func (*AttestationsFromResponse) ProtoMessage()

func (*AttestationsFromResponse) Reset 

func (m *AttestationsFromResponse) Reset()

func (*AttestationsFromResponse) Size 

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

func (*AttestationsFromResponse) String 

func (m *AttestationsFromResponse) String() string

func (*AttestationsFromResponse) Unmarshal 

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

func (*AttestationsFromResponse) XXX_DiscardUnknown 

func (m *AttestationsFromResponse) XXX_DiscardUnknown()

func (*AttestationsFromResponse) XXX_Marshal 

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

func (*AttestationsFromResponse) XXX_Merge 

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

func (*AttestationsFromResponse) XXX_Size 

func (m *AttestationsFromResponse) XXX_Size() int

func (*AttestationsFromResponse) XXX_Unmarshal 

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

type BlockHeader 

type BlockHeader struct {
	ChainId     uint64 `protobuf:"varint,1,opt,name=chain_id,json=chainId,proto3" json:"chain_id,omitempty"`
	BlockHeight uint64 `protobuf:"varint,2,opt,name=block_height,json=blockHeight,proto3" json:"block_height,omitempty"`
	BlockHash   []byte `protobuf:"bytes,3,opt,name=block_hash,json=blockHash,proto3" json:"block_hash,omitempty"`
}

BlockHeader uniquely identifies a cross chain block.

func (*BlockHeader) Descriptor 

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

func (*BlockHeader) GetBlockHash 

func (m *BlockHeader) GetBlockHash() []byte

func (*BlockHeader) GetBlockHeight 

func (m *BlockHeader) GetBlockHeight() uint64

func (*BlockHeader) GetChainId 

func (m *BlockHeader) GetChainId() uint64

func (*BlockHeader) Marshal 

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

func (*BlockHeader) MarshalTo 

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

func (*BlockHeader) MarshalToSizedBuffer 

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

func (*BlockHeader) ProtoMessage 

func (*BlockHeader) ProtoMessage()

func (*BlockHeader) Reset 

func (m *BlockHeader) Reset()

func (*BlockHeader) Size 

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

func (*BlockHeader) String 

func (m *BlockHeader) String() string

func (*BlockHeader) ToXChain 

func (h *BlockHeader) ToXChain() (xchain.BlockHeader, error)

func (*BlockHeader) Unmarshal 

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

func (*BlockHeader) Verify 

func (h *BlockHeader) Verify() error

func (*BlockHeader) XXX_DiscardUnknown 

func (m *BlockHeader) XXX_DiscardUnknown()

func (*BlockHeader) XXX_Marshal 

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

func (*BlockHeader) XXX_Merge 

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

func (*BlockHeader) XXX_Size 

func (m *BlockHeader) XXX_Size() int

func (*BlockHeader) XXX_Unmarshal 

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

type ChainVerNameFunc 

type ChainVerNameFunc func(xchain.ChainVersion) string

ChainVerNameFunc is a function that returns the name of a chain version.

type EarliestAttestationRequest 

type EarliestAttestationRequest struct {
	ChainId   uint64 `protobuf:"varint,1,opt,name=chain_id,json=chainId,proto3" json:"chain_id,omitempty"`
	ConfLevel uint32 `protobuf:"varint,2,opt,name=conf_level,json=confLevel,proto3" json:"conf_level,omitempty"`
}

func (*EarliestAttestationRequest) Descriptor 

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

func (*EarliestAttestationRequest) GetChainId 

func (m *EarliestAttestationRequest) GetChainId() uint64

func (*EarliestAttestationRequest) GetConfLevel 

func (m *EarliestAttestationRequest) GetConfLevel() uint32

func (*EarliestAttestationRequest) Marshal 

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

func (*EarliestAttestationRequest) MarshalTo 

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

func (*EarliestAttestationRequest) MarshalToSizedBuffer 

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

func (*EarliestAttestationRequest) ProtoMessage 

func (*EarliestAttestationRequest) ProtoMessage()

func (*EarliestAttestationRequest) Reset 

func (m *EarliestAttestationRequest) Reset()

func (*EarliestAttestationRequest) Size 

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

func (*EarliestAttestationRequest) String 

func (m *EarliestAttestationRequest) String() string

func (*EarliestAttestationRequest) Unmarshal 

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

func (*EarliestAttestationRequest) XXX_DiscardUnknown 

func (m *EarliestAttestationRequest) XXX_DiscardUnknown()

func (*EarliestAttestationRequest) XXX_Marshal 

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

func (*EarliestAttestationRequest) XXX_Merge 

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

func (*EarliestAttestationRequest) XXX_Size 

func (m *EarliestAttestationRequest) XXX_Size() int

func (*EarliestAttestationRequest) XXX_Unmarshal 

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

type EarliestAttestationResponse 

type EarliestAttestationResponse struct {
	Attestation *Attestation `protobuf:"bytes,1,opt,name=attestation,proto3" json:"attestation,omitempty"`
}

func (*EarliestAttestationResponse) Descriptor 

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

func (*EarliestAttestationResponse) GetAttestation 

func (m *EarliestAttestationResponse) GetAttestation() *Attestation

func (*EarliestAttestationResponse) Marshal 

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

func (*EarliestAttestationResponse) MarshalTo 

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

func (*EarliestAttestationResponse) MarshalToSizedBuffer 

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

func (*EarliestAttestationResponse) ProtoMessage 

func (*EarliestAttestationResponse) ProtoMessage()

func (*EarliestAttestationResponse) Reset 

func (m *EarliestAttestationResponse) Reset()

func (*EarliestAttestationResponse) Size 

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

func (*EarliestAttestationResponse) String 

func (m *EarliestAttestationResponse) String() string

func (*EarliestAttestationResponse) Unmarshal 

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

func (*EarliestAttestationResponse) XXX_DiscardUnknown 

func (m *EarliestAttestationResponse) XXX_DiscardUnknown()

func (*EarliestAttestationResponse) XXX_Marshal 

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

func (*EarliestAttestationResponse) XXX_Merge 

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

func (*EarliestAttestationResponse) XXX_Size 

func (m *EarliestAttestationResponse) XXX_Size() int

func (*EarliestAttestationResponse) XXX_Unmarshal 

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

type LatestAttestationRequest 

type LatestAttestationRequest struct {
	ChainId   uint64 `protobuf:"varint,1,opt,name=chain_id,json=chainId,proto3" json:"chain_id,omitempty"`
	ConfLevel uint32 `protobuf:"varint,2,opt,name=conf_level,json=confLevel,proto3" json:"conf_level,omitempty"`
}

func (*LatestAttestationRequest) Descriptor 

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

func (*LatestAttestationRequest) GetChainId 

func (m *LatestAttestationRequest) GetChainId() uint64

func (*LatestAttestationRequest) GetConfLevel 

func (m *LatestAttestationRequest) GetConfLevel() uint32

func (*LatestAttestationRequest) Marshal 

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

func (*LatestAttestationRequest) MarshalTo 

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

func (*LatestAttestationRequest) MarshalToSizedBuffer 

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

func (*LatestAttestationRequest) ProtoMessage 

func (*LatestAttestationRequest) ProtoMessage()

func (*LatestAttestationRequest) Reset 

func (m *LatestAttestationRequest) Reset()

func (*LatestAttestationRequest) Size 

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

func (*LatestAttestationRequest) String 

func (m *LatestAttestationRequest) String() string

func (*LatestAttestationRequest) Unmarshal 

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

func (*LatestAttestationRequest) XXX_DiscardUnknown 

func (m *LatestAttestationRequest) XXX_DiscardUnknown()

func (*LatestAttestationRequest) XXX_Marshal 

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

func (*LatestAttestationRequest) XXX_Merge 

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

func (*LatestAttestationRequest) XXX_Size 

func (m *LatestAttestationRequest) XXX_Size() int

func (*LatestAttestationRequest) XXX_Unmarshal 

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

type LatestAttestationResponse 

type LatestAttestationResponse struct {
	Attestation *Attestation `protobuf:"bytes,1,opt,name=attestation,proto3" json:"attestation,omitempty"`
}

func (*LatestAttestationResponse) Descriptor 

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

func (*LatestAttestationResponse) GetAttestation 

func (m *LatestAttestationResponse) GetAttestation() *Attestation

func (*LatestAttestationResponse) Marshal 

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

func (*LatestAttestationResponse) MarshalTo 

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

func (*LatestAttestationResponse) MarshalToSizedBuffer 

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

func (*LatestAttestationResponse) ProtoMessage 

func (*LatestAttestationResponse) ProtoMessage()

func (*LatestAttestationResponse) Reset 

func (m *LatestAttestationResponse) Reset()

func (*LatestAttestationResponse) Size 

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

func (*LatestAttestationResponse) String 

func (m *LatestAttestationResponse) String() string

func (*LatestAttestationResponse) Unmarshal 

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

func (*LatestAttestationResponse) XXX_DiscardUnknown 

func (m *LatestAttestationResponse) XXX_DiscardUnknown()

func (*LatestAttestationResponse) XXX_Marshal 

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

func (*LatestAttestationResponse) XXX_Merge 

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

func (*LatestAttestationResponse) XXX_Size 

func (m *LatestAttestationResponse) XXX_Size() int

func (*LatestAttestationResponse) XXX_Unmarshal 

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

type ListAllAttestationsRequest 

type ListAllAttestationsRequest struct {
	ChainId    uint64 `protobuf:"varint,1,opt,name=chain_id,json=chainId,proto3" json:"chain_id,omitempty"`
	ConfLevel  uint32 `protobuf:"varint,2,opt,name=conf_level,json=confLevel,proto3" json:"conf_level,omitempty"`
	Status     uint32 `protobuf:"varint,3,opt,name=status,proto3" json:"status,omitempty"`
	FromOffset uint64 `protobuf:"varint,4,opt,name=from_offset,json=fromOffset,proto3" json:"from_offset,omitempty"`
}

func (*ListAllAttestationsRequest) Descriptor 

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

func (*ListAllAttestationsRequest) GetChainId 

func (m *ListAllAttestationsRequest) GetChainId() uint64

func (*ListAllAttestationsRequest) GetConfLevel 

func (m *ListAllAttestationsRequest) GetConfLevel() uint32

func (*ListAllAttestationsRequest) GetFromOffset 

func (m *ListAllAttestationsRequest) GetFromOffset() uint64

func (*ListAllAttestationsRequest) GetStatus 

func (m *ListAllAttestationsRequest) GetStatus() uint32

func (*ListAllAttestationsRequest) Marshal 

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

func (*ListAllAttestationsRequest) MarshalTo 

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

func (*ListAllAttestationsRequest) MarshalToSizedBuffer 

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

func (*ListAllAttestationsRequest) ProtoMessage 

func (*ListAllAttestationsRequest) ProtoMessage()

func (*ListAllAttestationsRequest) Reset 

func (m *ListAllAttestationsRequest) Reset()

func (*ListAllAttestationsRequest) Size 

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

func (*ListAllAttestationsRequest) String 

func (m *ListAllAttestationsRequest) String() string

func (*ListAllAttestationsRequest) Unmarshal 

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

func (*ListAllAttestationsRequest) XXX_DiscardUnknown 

func (m *ListAllAttestationsRequest) XXX_DiscardUnknown()

func (*ListAllAttestationsRequest) XXX_Marshal 

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

func (*ListAllAttestationsRequest) XXX_Merge 

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

func (*ListAllAttestationsRequest) XXX_Size 

func (m *ListAllAttestationsRequest) XXX_Size() int

func (*ListAllAttestationsRequest) XXX_Unmarshal 

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

type ListAllAttestationsResponse 

type ListAllAttestationsResponse struct {
	Attestations []*Attestation `protobuf:"bytes,1,rep,name=attestations,proto3" json:"attestations,omitempty"`
}

func (*ListAllAttestationsResponse) Descriptor 

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

func (*ListAllAttestationsResponse) GetAttestations 

func (m *ListAllAttestationsResponse) GetAttestations() []*Attestation

func (*ListAllAttestationsResponse) Marshal 

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

func (*ListAllAttestationsResponse) MarshalTo 

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

func (*ListAllAttestationsResponse) MarshalToSizedBuffer 

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

func (*ListAllAttestationsResponse) ProtoMessage 

func (*ListAllAttestationsResponse) ProtoMessage()

func (*ListAllAttestationsResponse) Reset 

func (m *ListAllAttestationsResponse) Reset()

func (*ListAllAttestationsResponse) Size 

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

func (*ListAllAttestationsResponse) String 

func (m *ListAllAttestationsResponse) String() string

func (*ListAllAttestationsResponse) Unmarshal 

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

func (*ListAllAttestationsResponse) XXX_DiscardUnknown 

func (m *ListAllAttestationsResponse) XXX_DiscardUnknown()

func (*ListAllAttestationsResponse) XXX_Marshal 

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

func (*ListAllAttestationsResponse) XXX_Merge 

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

func (*ListAllAttestationsResponse) XXX_Size 

func (m *ListAllAttestationsResponse) XXX_Size() int

func (*ListAllAttestationsResponse) XXX_Unmarshal 

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

type MsgAddVotes 

type MsgAddVotes struct {
	Authority string     `protobuf:"bytes,1,opt,name=authority,proto3" json:"authority,omitempty"`
	Votes     []*AggVote `protobuf:"bytes,2,rep,name=votes,proto3" json:"votes,omitempty"`
}

MsgAddVotes contains multiple aggregated votes for different cross-chain Blocks.

func (*MsgAddVotes) Descriptor 

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

func (*MsgAddVotes) GetAuthority 

func (m *MsgAddVotes) GetAuthority() string

func (*MsgAddVotes) GetVotes 

func (m *MsgAddVotes) GetVotes() []*AggVote

func (*MsgAddVotes) Marshal 

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

func (*MsgAddVotes) MarshalTo 

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

func (*MsgAddVotes) MarshalToSizedBuffer 

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

func (*MsgAddVotes) ProtoMessage 

func (*MsgAddVotes) ProtoMessage()

func (*MsgAddVotes) Reset 

func (m *MsgAddVotes) Reset()

func (*MsgAddVotes) Size 

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

func (*MsgAddVotes) String 

func (m *MsgAddVotes) String() string

func (*MsgAddVotes) Unmarshal 

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

func (*MsgAddVotes) XXX_DiscardUnknown 

func (m *MsgAddVotes) XXX_DiscardUnknown()

func (*MsgAddVotes) XXX_Marshal 

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

func (*MsgAddVotes) XXX_Merge 

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

func (*MsgAddVotes) XXX_Size 

func (m *MsgAddVotes) XXX_Size() int

func (*MsgAddVotes) XXX_Unmarshal 

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

type MsgServiceClient 

type MsgServiceClient interface {
	// AddVotes processes aggregate votes included in a proposed or finalised block.
	AddVotes(ctx context.Context, in *MsgAddVotes, opts ...grpc.CallOption) (*AddVotesResponse, error)
}

MsgServiceClient is the client API for MsgService service.

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

func NewMsgServiceClient 

func NewMsgServiceClient(cc grpc1.ClientConn) MsgServiceClient

type MsgServiceServer 

type MsgServiceServer interface {
	// AddVotes processes aggregate votes included in a proposed or finalised block.
	AddVotes(context.Context, *MsgAddVotes) (*AddVotesResponse, error)
}

MsgServiceServer is the server API for MsgService service.

type QueryClient 

type QueryClient interface {
	// AttestationsFrom queries halo for approved attestations for the given chain_id
	// and from the given height (inclusive). The response will contain at most max attestations sequentially
	// following from_height.
	AttestationsFrom(ctx context.Context, in *AttestationsFromRequest, opts ...grpc.CallOption) (*AttestationsFromResponse, error)
	// LatestAttestation queries halo for the latest approved attestations for the given chain_id.
	LatestAttestation(ctx context.Context, in *LatestAttestationRequest, opts ...grpc.CallOption) (*LatestAttestationResponse, error)
	// EarliestAttestation queries halo for the earliest approved attestation in consensus chain state for the given chain_id.
	EarliestAttestation(ctx context.Context, in *EarliestAttestationRequest, opts ...grpc.CallOption) (*EarliestAttestationResponse, error)
	// ListAllAttestations queries halo for all approved attestations in consensus chain state for the given chain_id.
	ListAllAttestations(ctx context.Context, in *ListAllAttestationsRequest, opts ...grpc.CallOption) (*ListAllAttestationsResponse, error)
	// WindowCompare compares the given chain height to the vote window.
	// It returns whether the request is behind (-1), or in (0), or after (1) the vote window.
	// The vote window is a configured number of blocks around the latest approved attestation.
	WindowCompare(ctx context.Context, in *WindowCompareRequest, opts ...grpc.CallOption) (*WindowCompareResponse, 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 {
	// AttestationsFrom queries halo for approved attestations for the given chain_id
	// and from the given height (inclusive). The response will contain at most max attestations sequentially
	// following from_height.
	AttestationsFrom(context.Context, *AttestationsFromRequest) (*AttestationsFromResponse, error)
	// LatestAttestation queries halo for the latest approved attestations for the given chain_id.
	LatestAttestation(context.Context, *LatestAttestationRequest) (*LatestAttestationResponse, error)
	// EarliestAttestation queries halo for the earliest approved attestation in consensus chain state for the given chain_id.
	EarliestAttestation(context.Context, *EarliestAttestationRequest) (*EarliestAttestationResponse, error)
	// ListAllAttestations queries halo for all approved attestations in consensus chain state for the given chain_id.
	ListAllAttestations(context.Context, *ListAllAttestationsRequest) (*ListAllAttestationsResponse, error)
	// WindowCompare compares the given chain height to the vote window.
	// It returns whether the request is behind (-1), or in (0), or after (1) the vote window.
	// The vote window is a configured number of blocks around the latest approved attestation.
	WindowCompare(context.Context, *WindowCompareRequest) (*WindowCompareResponse, error)
}

QueryServer is the server API for Query service.

type SigTuple 

type SigTuple struct {
	ValidatorAddress []byte `protobuf:"bytes,1,opt,name=validator_address,json=validatorAddress,proto3" json:"validator_address,omitempty"`
	Signature        []byte `protobuf:"bytes,2,opt,name=signature,proto3" json:"signature,omitempty"`
}

SigTuple is a validator public key and signature (over the attestation root).

func (*SigTuple) Descriptor 

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

func (*SigTuple) GetSignature 

func (m *SigTuple) GetSignature() []byte

func (*SigTuple) GetValidatorAddress 

func (m *SigTuple) GetValidatorAddress() []byte

func (*SigTuple) Marshal 

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

func (*SigTuple) MarshalTo 

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

func (*SigTuple) MarshalToSizedBuffer 

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

func (*SigTuple) ProtoMessage 

func (*SigTuple) ProtoMessage()

func (*SigTuple) Reset 

func (m *SigTuple) Reset()

func (*SigTuple) Size 

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

func (*SigTuple) String 

func (m *SigTuple) String() string

func (*SigTuple) ToXChain 

func (s *SigTuple) ToXChain() (xchain.SigTuple, error)

func (*SigTuple) Unmarshal 

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

func (*SigTuple) ValidatorEthAddress added in v0.10.0 

func (s *SigTuple) ValidatorEthAddress() (common.Address, error)

func (*SigTuple) Verify 

func (s *SigTuple) Verify() error

func (*SigTuple) XXX_DiscardUnknown 

func (m *SigTuple) XXX_DiscardUnknown()

func (*SigTuple) XXX_Marshal 

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

func (*SigTuple) XXX_Merge 

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

func (*SigTuple) XXX_Size 

func (m *SigTuple) XXX_Size() int

func (*SigTuple) XXX_Unmarshal 

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

type UnimplementedMsgServiceServer 

type UnimplementedMsgServiceServer struct {
}

UnimplementedMsgServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedMsgServiceServer) AddVotes 

func (*UnimplementedMsgServiceServer) AddVotes(ctx context.Context, req *MsgAddVotes) (*AddVotesResponse, error)

type UnimplementedQueryServer 

type UnimplementedQueryServer struct {
}

UnimplementedQueryServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryServer) AttestationsFrom 

func (*UnimplementedQueryServer) AttestationsFrom(ctx context.Context, req *AttestationsFromRequest) (*AttestationsFromResponse, error)

func (*UnimplementedQueryServer) EarliestAttestation 

func (*UnimplementedQueryServer) EarliestAttestation(ctx context.Context, req *EarliestAttestationRequest) (*EarliestAttestationResponse, error)

func (*UnimplementedQueryServer) LatestAttestation 

func (*UnimplementedQueryServer) LatestAttestation(ctx context.Context, req *LatestAttestationRequest) (*LatestAttestationResponse, error)

func (*UnimplementedQueryServer) ListAllAttestations 

func (*UnimplementedQueryServer) ListAllAttestations(ctx context.Context, req *ListAllAttestationsRequest) (*ListAllAttestationsResponse, error)

func (*UnimplementedQueryServer) WindowCompare 

func (*UnimplementedQueryServer) WindowCompare(ctx context.Context, req *WindowCompareRequest) (*WindowCompareResponse, error)

type Vote 

type Vote struct {
	AttestHeader *AttestHeader `protobuf:"bytes,1,opt,name=attest_header,json=attestHeader,proto3" json:"attest_header,omitempty"`
	BlockHeader  *BlockHeader  `protobuf:"bytes,2,opt,name=block_header,json=blockHeader,proto3" json:"block_header,omitempty"`
	MsgRoot      []byte        `protobuf:"bytes,3,opt,name=msg_root,json=msgRoot,proto3" json:"msg_root,omitempty"`
	Signature    *SigTuple     `protobuf:"bytes,4,opt,name=signature,proto3" json:"signature,omitempty"`
}

Vote by a validator of a cross-chain Block.

func (*Vote) AttestationRoot 

func (v *Vote) AttestationRoot() (common.Hash, error)

func (*Vote) Descriptor 

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

func (*Vote) GetAttestHeader 

func (m *Vote) GetAttestHeader() *AttestHeader

func (*Vote) GetBlockHeader 

func (m *Vote) GetBlockHeader() *BlockHeader

func (*Vote) GetMsgRoot 

func (m *Vote) GetMsgRoot() []byte

func (*Vote) GetSignature 

func (m *Vote) GetSignature() *SigTuple

func (*Vote) Marshal 

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

func (*Vote) MarshalTo 

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

func (*Vote) MarshalToSizedBuffer 

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

func (*Vote) ProtoMessage 

func (*Vote) ProtoMessage()

func (*Vote) Reset 

func (m *Vote) Reset()

func (*Vote) Size 

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

func (*Vote) String 

func (m *Vote) String() string

func (*Vote) ToXChain 

func (v *Vote) ToXChain() (xchain.Vote, error)

func (*Vote) Unmarshal 

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

func (*Vote) Verify 

func (v *Vote) Verify() error

func (*Vote) XXX_DiscardUnknown 

func (m *Vote) XXX_DiscardUnknown()

func (*Vote) XXX_Marshal 

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

func (*Vote) XXX_Merge 

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

func (*Vote) XXX_Size 

func (m *Vote) XXX_Size() int

func (*Vote) XXX_Unmarshal 

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

type Voter 

type Voter interface {
	// GetAvailable returns all "available" votes in the vote window.
	// This basically queries all "available" votes and filters by current vote window.
	GetAvailable() []*Vote

	// SetProposed updates the status of the provided votes to "proposed",
	// i.e., they were included by a proposer in a new proposed block.
	// All other existing "proposed" votes are reset to "available", i.e. they were
	// proposed previously by another proposer, but that block was never finalized/committed.
	SetProposed(ctx context.Context, headers []*AttestHeader) error

	// SetCommitted updates the status of the provided votes to "committed",
	// i.e., they were included in a finalized consensus block and is now part of the consensus chain.
	// All other existing "proposed" votes are reset to "available", i.e. we probably
	// missed the proposal step and only learnt of the finalized block post-fact.
	// All but the latest "confirmed" attestation for each source chain can be safely deleted from disk.
	SetCommitted(ctx context.Context, headers []*AttestHeader) error

	// LocalAddress returns the local validator's ethereum address.
	LocalAddress() common.Address

	// TrimBehind deletes all available votes that are behind the vote window minimums (map[chainID]minimum) since
	// they will never be committed. It returns the number that was deleted.
	TrimBehind(minsByChain map[xchain.ChainVersion]uint64) int

	// UpdateValidatorSet sets the latest active validator set when updated.
	// This is used to calculate whether the voter is in-or-out of the validator set.
	UpdateValidatorSet(set *vtypes.ValidatorSetResponse) error
}

Voter abstracts the validator duty of v∂oting for all XBlocks for all source chains.

It streams all finalized XBlocks from all source chains. It creates a Vote for each (a signature). It stores these to disk, setting their status as "available".

type VoterDeps 

type VoterDeps interface {
	// LatestAttestation returns the latest approved attestation for the given chain version.
	LatestAttestation(ctx context.Context, chainVer xchain.ChainVersion) (xchain.Attestation, bool, error)
}

VoterDeps abstracts the Voter's internal cosmosSDK dependencies; basically the attest keeper. They have a circular dependency.

type Votes 

type Votes struct {
	Votes []*Vote `protobuf:"bytes,1,rep,name=votes,proto3" json:"votes,omitempty"`
}

Votes contains multiple votes for different cross-chain Blocks. Usually by the same validator.

func (*Votes) Descriptor 

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

func (*Votes) GetVotes 

func (m *Votes) GetVotes() []*Vote

func (*Votes) Marshal 

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

func (*Votes) MarshalTo 

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

func (*Votes) MarshalToSizedBuffer 

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

func (*Votes) ProtoMessage 

func (*Votes) ProtoMessage()

func (*Votes) Reset 

func (m *Votes) Reset()

func (*Votes) Size 

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

func (*Votes) String 

func (m *Votes) String() string

func (*Votes) Unmarshal 

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

func (*Votes) XXX_DiscardUnknown 

func (m *Votes) XXX_DiscardUnknown()

func (*Votes) XXX_Marshal 

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

func (*Votes) XXX_Merge 

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

func (*Votes) XXX_Size 

func (m *Votes) XXX_Size() int

func (*Votes) XXX_Unmarshal 

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

type WindowCompareRequest 

type WindowCompareRequest struct {
	ChainId      uint64 `protobuf:"varint,1,opt,name=chain_id,json=chainId,proto3" json:"chain_id,omitempty"`
	ConfLevel    uint32 `protobuf:"varint,2,opt,name=conf_level,json=confLevel,proto3" json:"conf_level,omitempty"`
	AttestOffset uint64 `protobuf:"varint,3,opt,name=attest_offset,json=attestOffset,proto3" json:"attest_offset,omitempty"`
}

func (*WindowCompareRequest) Descriptor 

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

func (*WindowCompareRequest) GetAttestOffset 

func (m *WindowCompareRequest) GetAttestOffset() uint64

func (*WindowCompareRequest) GetChainId 

func (m *WindowCompareRequest) GetChainId() uint64

func (*WindowCompareRequest) GetConfLevel 

func (m *WindowCompareRequest) GetConfLevel() uint32

func (*WindowCompareRequest) Marshal 

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

func (*WindowCompareRequest) MarshalTo 

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

func (*WindowCompareRequest) MarshalToSizedBuffer 

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

func (*WindowCompareRequest) ProtoMessage 

func (*WindowCompareRequest) ProtoMessage()

func (*WindowCompareRequest) Reset 

func (m *WindowCompareRequest) Reset()

func (*WindowCompareRequest) Size 

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

func (*WindowCompareRequest) String 

func (m *WindowCompareRequest) String() string

func (*WindowCompareRequest) Unmarshal 

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

func (*WindowCompareRequest) XChainVersion 

func (h *WindowCompareRequest) XChainVersion() xchain.ChainVersion

func (*WindowCompareRequest) XXX_DiscardUnknown 

func (m *WindowCompareRequest) XXX_DiscardUnknown()

func (*WindowCompareRequest) XXX_Marshal 

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

func (*WindowCompareRequest) XXX_Merge 

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

func (*WindowCompareRequest) XXX_Size 

func (m *WindowCompareRequest) XXX_Size() int

func (*WindowCompareRequest) XXX_Unmarshal 

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

type WindowCompareResponse 

type WindowCompareResponse struct {
	Cmp int32 `protobuf:"varint,1,opt,name=cmp,proto3" json:"cmp,omitempty"`
}

func (*WindowCompareResponse) Descriptor 

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

func (*WindowCompareResponse) GetCmp 

func (m *WindowCompareResponse) GetCmp() int32

func (*WindowCompareResponse) Marshal 

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

func (*WindowCompareResponse) MarshalTo 

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

func (*WindowCompareResponse) MarshalToSizedBuffer 

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

func (*WindowCompareResponse) ProtoMessage 

func (*WindowCompareResponse) ProtoMessage()

func (*WindowCompareResponse) Reset 

func (m *WindowCompareResponse) Reset()

func (*WindowCompareResponse) Size 

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

func (*WindowCompareResponse) String 

func (m *WindowCompareResponse) String() string

func (*WindowCompareResponse) Unmarshal 

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

func (*WindowCompareResponse) XXX_DiscardUnknown 

func (m *WindowCompareResponse) XXX_DiscardUnknown()

func (*WindowCompareResponse) XXX_Marshal 

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

func (*WindowCompareResponse) XXX_Merge 

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

func (*WindowCompareResponse) XXX_Size 

func (m *WindowCompareResponse) XXX_Size() int

func (*WindowCompareResponse) XXX_Unmarshal 

func (m *WindowCompareResponse) XXX_Unmarshal(b []byte) 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.