types

package
v0.10.0 Latest Latest
Warning

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

 Go to latest Published: Jul 20, 2026 License: GPL-3.0 Imports: 45 Imported by: 3

Documentation

Overview

Package types is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

View Source 
const (
	// ModuleName is the name of the staking module
	ModuleName = "stake"

	// StoreKey is the string store representation
	StoreKey = ModuleName

	// RouterKey is the msg router key for the stake module
	RouterKey = ModuleName

	// DefaultLogIndexUnit represents the default unit for txHash+logIndex
	DefaultLogIndexUnit = 100000
)
View Source 
const (
	MaxTotalVotingPower      = int64(math.MaxInt64) / 8
	PriorityWindowSizeFactor = 2
)

Variables

View Source 
var (
	// ErrInvalidMsg is returned if the message is invalid
	ErrInvalidMsg = errorsmod.Register(ModuleName, 2, "invalid message")

	// ErrNoValidator is returned if the respective validator doesn't exist
	ErrNoValidator = errorsmod.Register(ModuleName, 4, "no respective validator found")

	// ErrNoSignerChange returned when the new signer address is same as old one
	ErrNoSignerChange = errorsmod.Register(ModuleName, 5, "new signer is same as old one")

	// ErrValUnBonded is returned when the respective validator is already unBonded
	ErrValUnBonded = errorsmod.Register(ModuleName, 6, "validator already unBonded")
)
View Source 
var (
	EventTypeValidatorJoin = "validator-join"
	EventTypeSignerUpdate  = "signer-update"
	EventTypeStakeUpdate   = "stake-update"
	EventTypeValidatorExit = "validator-exit"

	AttributeKeySigner         = "signer"
	AttributeKeyValidatorID    = "validator-id"
	AttributeKeyValidatorNonce = "validator-nonce"

	AttributeValueCategory = ModuleName
)

stake module event types

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 (
	ValidatorsKey                   = []byte{0x21} // prefix for each key to a validator
	ValidatorSetKey                 = []byte{0x22} // prefix for each key for the validator map
	CurrentValidatorSetKey          = []byte{0x23} // key to store the current validator set
	StakeSequenceKey                = []byte{0x24} // prefix for each key for the staking sequence map
	SignerKey                       = []byte{0x25} // prefix for signer address for signer map
	LastBlockTxsKey                 = []byte{0x26} // key to store last block's txs
	PreviousBlockValidatorSetKey    = []byte{0x27} // key to store the previous block's validator set
	PenultimateBlockValidatorSetKey = []byte{0x28} // key to store the validator set from 2 blocks ago
)
View Source 
var (
	ErrInvalidLengthLastBlockTxs        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowLastBlockTxs          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupLastBlockTxs = fmt.Errorf("proto: unexpected end of group")
)
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 (
	ErrInvalidLengthValidator        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowValidator          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupValidator = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var EmptyPubKey = PubKey{}

EmptyPubKey represents an empty pub key

View Source 
var Secp256k1Type = secp256k1.GenPrivKey().PubKey().Type()

Functions

func RegisterInterfaces 

func RegisterInterfaces(registry types.InterfaceRegistry)

RegisterInterfaces registers the x/stake interfaces types with the interface registry

func RegisterLegacyAminoCodec 

func RegisterLegacyAminoCodec(cdc *codec.LegacyAmino)

RegisterLegacyAminoCodec registers the necessary x/stake interfaces and concrete types on the provided LegacyAmino codec. These types are used for Amino JSON serialization.

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 RegisterSideMsgServer 

func RegisterSideMsgServer(sideCfg sidetxs.SideTxConfigurator, srv sidetxs.SideMsgServer)

func SetGenesisStateToAppState 

func SetGenesisStateToAppState(cdc codec.JSONCodec, appState map[string]json.RawMessage, validators []*Validator, currentValSet ValidatorSet) (map[string]json.RawMessage, error)

SetGenesisStateToAppState sets x/stake GenesisState into the raw application genesis state.

Types

type BankKeeper 

type BankKeeper interface {
	GetBalance(ctx context.Context, addr sdk.AccAddress, denom string) sdk.Coin
	SendCoins(ctx context.Context, fromAddr, toAddr sdk.AccAddress, amt sdk.Coins) error
}

type CheckpointKeeper 

type CheckpointKeeper interface {
	GetAckCount(ctx context.Context) (uint64, error)
}

CheckpointKeeper defines the checkpoint keeper contract used by x/stake module

type GenesisState 

type GenesisState struct {
	// All validators at genesis.
	Validators []*Validator `protobuf:"bytes,1,rep,name=validators,proto3" json:"validators,omitempty"`
	// Current active validator set.
	CurrentValidatorSet ValidatorSet `protobuf:"bytes,2,opt,name=current_validator_set,json=currentValidatorSet,proto3" json:"current_validator_set"`
	// Staking transaction sequences for replay protection.
	StakingSequences []string `protobuf:"bytes,3,rep,name=staking_sequences,json=stakingSequences,proto3" json:"staking_sequences,omitempty"`
	// Validator set from the previous block.
	PreviousBlockValidatorSet ValidatorSet `` /* 130-byte string literal not displayed */
	// Stake transactions from the last block.
	LastBlockTxs LastBlockTxs `protobuf:"bytes,5,opt,name=last_block_txs,json=lastBlockTxs,proto3" json:"last_block_txs"`
	// Validator set from two blocks ago.
	PenultimateBlockValidatorSet ValidatorSet `` /* 139-byte string literal not displayed */
}

GenesisState defines the stake module's genesis state.

func DefaultGenesisState 

func DefaultGenesisState() *GenesisState

DefaultGenesisState gets the raw genesis message for testing

func GetGenesisStateFromAppState 

func GetGenesisStateFromAppState(cdc codec.JSONCodec, appState map[string]json.RawMessage) *GenesisState

GetGenesisStateFromAppState returns x/stake GenesisState given raw application genesis state.

func NewGenesisState 

func NewGenesisState(validators []*Validator,
	currentValSet ValidatorSet,
	stakingSequences []string,
) *GenesisState

NewGenesisState creates a new GenesisState instance

func (*GenesisState) Descriptor 

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

func (*GenesisState) GetCurrentValidatorSet 

func (m *GenesisState) GetCurrentValidatorSet() ValidatorSet

func (*GenesisState) GetLastBlockTxs added in v0.1.18 

func (m *GenesisState) GetLastBlockTxs() LastBlockTxs

func (*GenesisState) GetPenultimateBlockValidatorSet added in v0.3.0 

func (m *GenesisState) GetPenultimateBlockValidatorSet() ValidatorSet

func (*GenesisState) GetPreviousBlockValidatorSet added in v0.1.18 

func (m *GenesisState) GetPreviousBlockValidatorSet() ValidatorSet

func (*GenesisState) GetStakingSequences 

func (m *GenesisState) GetStakingSequences() []string

func (*GenesisState) GetValidators 

func (m *GenesisState) GetValidators() []*Validator

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) Validate added in v0.1.18 

func (data GenesisState) Validate() error

Validate validates the provided stake genesis state to ensure that listed validators and staking sequences are valid

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 LastBlockTxs 

type LastBlockTxs struct {
	// Raw transaction bytes from stake operations in the previous block.
	Txs [][]byte `protobuf:"bytes,1,rep,name=txs,proto3" json:"txs,omitempty"`
}

LastBlockTxs stores the stake-related transactions from the last block. This is used to track recent validator updates and ensure proper sequencing.

func (*LastBlockTxs) Descriptor 

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

func (*LastBlockTxs) GetTxs 

func (m *LastBlockTxs) GetTxs() [][]byte

func (*LastBlockTxs) Marshal 

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

func (*LastBlockTxs) MarshalTo 

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

func (*LastBlockTxs) MarshalToSizedBuffer 

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

func (*LastBlockTxs) ProtoMessage 

func (*LastBlockTxs) ProtoMessage()

func (*LastBlockTxs) Reset 

func (m *LastBlockTxs) Reset()

func (*LastBlockTxs) Size 

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

func (*LastBlockTxs) String 

func (m *LastBlockTxs) String() string

func (*LastBlockTxs) Unmarshal 

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

func (*LastBlockTxs) XXX_DiscardUnknown 

func (m *LastBlockTxs) XXX_DiscardUnknown()

func (*LastBlockTxs) XXX_Marshal 

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

func (*LastBlockTxs) XXX_Merge 

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

func (*LastBlockTxs) XXX_Size 

func (m *LastBlockTxs) XXX_Size() int

func (*LastBlockTxs) XXX_Unmarshal 

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

type MinimalVal 

type MinimalVal struct {
	ID          uint64         `json:"ID"`
	VotingPower uint64         `json:"power"`
	Signer      common.Address `json:"signer"`
}

MinimalVal is the minimal validator representation Used to send validator information to the bor validator contract

type MsgClient 

type MsgClient interface {
	// ValidatorJoin processes a new validator joining the network.
	ValidatorJoin(ctx context.Context, in *MsgValidatorJoin, opts ...grpc.CallOption) (*MsgValidatorJoinResponse, error)
	// StakeUpdate processes an update to a validator's stake amount.
	StakeUpdate(ctx context.Context, in *MsgStakeUpdate, opts ...grpc.CallOption) (*MsgStakeUpdateResponse, error)
	// SignerUpdate processes an update to a validator's signer public key.
	SignerUpdate(ctx context.Context, in *MsgSignerUpdate, opts ...grpc.CallOption) (*MsgSignerUpdateResponse, error)
	// ValidatorExit processes a validator exiting the network.
	ValidatorExit(ctx context.Context, in *MsgValidatorExit, opts ...grpc.CallOption) (*MsgValidatorExitResponse, 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 {
	// ValidatorJoin processes a new validator joining the network.
	ValidatorJoin(context.Context, *MsgValidatorJoin) (*MsgValidatorJoinResponse, error)
	// StakeUpdate processes an update to a validator's stake amount.
	StakeUpdate(context.Context, *MsgStakeUpdate) (*MsgStakeUpdateResponse, error)
	// SignerUpdate processes an update to a validator's signer public key.
	SignerUpdate(context.Context, *MsgSignerUpdate) (*MsgSignerUpdateResponse, error)
	// ValidatorExit processes a validator exiting the network.
	ValidatorExit(context.Context, *MsgValidatorExit) (*MsgValidatorExitResponse, error)
}

MsgServer is the server API for Msg service.

type MsgSignerUpdate 

type MsgSignerUpdate struct {
	From            string `protobuf:"bytes,1,opt,name=from,proto3" json:"from,omitempty"`
	ValId           uint64 `protobuf:"varint,2,opt,name=val_id,json=valId,proto3" json:"val_id,omitempty"`
	NewSignerPubKey []byte `protobuf:"bytes,3,opt,name=new_signer_pub_key,json=newSignerPubKey,proto3" json:"new_signer_pub_key,omitempty"`
	TxHash          []byte `protobuf:"bytes,4,opt,name=tx_hash,json=txHash,proto3" json:"tx_hash,omitempty"`
	LogIndex        uint64 `protobuf:"varint,5,opt,name=log_index,json=logIndex,proto3" json:"log_index,omitempty"`
	BlockNumber     uint64 `protobuf:"varint,6,opt,name=block_number,json=blockNumber,proto3" json:"block_number,omitempty"`
	Nonce           uint64 `protobuf:"varint,7,opt,name=nonce,proto3" json:"nonce,omitempty"`
}

MsgSignerUpdate defines the message for updating a validator's signer public key.

func NewMsgSignerUpdate 

func NewMsgSignerUpdate(from string, id uint64,
	pubKey []byte, txHash []byte, logIndex uint64,
	blockNumber uint64, nonce uint64,
) (*MsgSignerUpdate, error)

NewMsgSignerUpdate creates a new MsgSignerUpdate instance.

func (*MsgSignerUpdate) Descriptor 

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

func (*MsgSignerUpdate) GetBlockNumber 

func (m *MsgSignerUpdate) GetBlockNumber() uint64

func (*MsgSignerUpdate) GetFrom 

func (m *MsgSignerUpdate) GetFrom() string

func (*MsgSignerUpdate) GetLogIndex 

func (m *MsgSignerUpdate) GetLogIndex() uint64

func (*MsgSignerUpdate) GetNewSignerPubKey 

func (m *MsgSignerUpdate) GetNewSignerPubKey() []byte

func (*MsgSignerUpdate) GetNonce 

func (m *MsgSignerUpdate) GetNonce() uint64

func (*MsgSignerUpdate) GetTxHash 

func (m *MsgSignerUpdate) GetTxHash() []byte

func (*MsgSignerUpdate) GetValId 

func (m *MsgSignerUpdate) GetValId() uint64

func (*MsgSignerUpdate) Marshal 

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

func (*MsgSignerUpdate) MarshalTo 

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

func (*MsgSignerUpdate) MarshalToSizedBuffer 

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

func (*MsgSignerUpdate) ProtoMessage 

func (*MsgSignerUpdate) ProtoMessage()

func (*MsgSignerUpdate) Reset 

func (m *MsgSignerUpdate) Reset()

func (*MsgSignerUpdate) Size 

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

func (*MsgSignerUpdate) String 

func (m *MsgSignerUpdate) String() string

func (*MsgSignerUpdate) Unmarshal 

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

func (MsgSignerUpdate) ValidateBasic added in v0.1.18 

func (msg MsgSignerUpdate) ValidateBasic() error

ValidateBasic validates the signer update msg before it is executed

func (*MsgSignerUpdate) XXX_DiscardUnknown 

func (m *MsgSignerUpdate) XXX_DiscardUnknown()

func (*MsgSignerUpdate) XXX_Marshal 

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

func (*MsgSignerUpdate) XXX_Merge 

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

func (*MsgSignerUpdate) XXX_Size 

func (m *MsgSignerUpdate) XXX_Size() int

func (*MsgSignerUpdate) XXX_Unmarshal 

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

type MsgSignerUpdateResponse 

type MsgSignerUpdateResponse struct {
}

MsgSignerUpdateResponse defines the response for MsgSignerUpdate.

func (*MsgSignerUpdateResponse) Descriptor 

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

func (*MsgSignerUpdateResponse) Marshal 

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

func (*MsgSignerUpdateResponse) MarshalTo 

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

func (*MsgSignerUpdateResponse) MarshalToSizedBuffer 

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

func (*MsgSignerUpdateResponse) ProtoMessage 

func (*MsgSignerUpdateResponse) ProtoMessage()

func (*MsgSignerUpdateResponse) Reset 

func (m *MsgSignerUpdateResponse) Reset()

func (*MsgSignerUpdateResponse) Size 

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

func (*MsgSignerUpdateResponse) String 

func (m *MsgSignerUpdateResponse) String() string

func (*MsgSignerUpdateResponse) Unmarshal 

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

func (*MsgSignerUpdateResponse) XXX_DiscardUnknown 

func (m *MsgSignerUpdateResponse) XXX_DiscardUnknown()

func (*MsgSignerUpdateResponse) XXX_Marshal 

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

func (*MsgSignerUpdateResponse) XXX_Merge 

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

func (*MsgSignerUpdateResponse) XXX_Size 

func (m *MsgSignerUpdateResponse) XXX_Size() int

func (*MsgSignerUpdateResponse) XXX_Unmarshal 

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

type MsgStakeUpdate 

type MsgStakeUpdate struct {
	From        string                `protobuf:"bytes,1,opt,name=from,proto3" json:"from,omitempty"`
	ValId       uint64                `protobuf:"varint,2,opt,name=val_id,json=valId,proto3" json:"val_id,omitempty"`
	NewAmount   cosmossdk_io_math.Int `protobuf:"bytes,3,opt,name=new_amount,json=newAmount,proto3,customtype=cosmossdk.io/math.Int" json:"new_amount"`
	TxHash      []byte                `protobuf:"bytes,4,opt,name=tx_hash,json=txHash,proto3" json:"tx_hash,omitempty"`
	LogIndex    uint64                `protobuf:"varint,5,opt,name=log_index,json=logIndex,proto3" json:"log_index,omitempty"`
	BlockNumber uint64                `protobuf:"varint,6,opt,name=block_number,json=blockNumber,proto3" json:"block_number,omitempty"`
	Nonce       uint64                `protobuf:"varint,7,opt,name=nonce,proto3" json:"nonce,omitempty"`
}

MsgStakeUpdate defines the message for updating a validator's stake amount.

func NewMsgStakeUpdate 

func NewMsgStakeUpdate(from string, id uint64,
	newAmount sdkmath.Int, txHash []byte, logIndex uint64,
	blockNumber uint64, nonce uint64,
) (*MsgStakeUpdate, error)

NewMsgStakeUpdate creates a new MsgStakeUpdate instance

func (*MsgStakeUpdate) Descriptor 

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

func (*MsgStakeUpdate) GetBlockNumber 

func (m *MsgStakeUpdate) GetBlockNumber() uint64

func (*MsgStakeUpdate) GetFrom 

func (m *MsgStakeUpdate) GetFrom() string

func (*MsgStakeUpdate) GetLogIndex 

func (m *MsgStakeUpdate) GetLogIndex() uint64

func (*MsgStakeUpdate) GetNonce 

func (m *MsgStakeUpdate) GetNonce() uint64

func (*MsgStakeUpdate) GetTxHash 

func (m *MsgStakeUpdate) GetTxHash() []byte

func (*MsgStakeUpdate) GetValId 

func (m *MsgStakeUpdate) GetValId() uint64

func (*MsgStakeUpdate) Marshal 

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

func (*MsgStakeUpdate) MarshalTo 

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

func (*MsgStakeUpdate) MarshalToSizedBuffer 

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

func (*MsgStakeUpdate) ProtoMessage 

func (*MsgStakeUpdate) ProtoMessage()

func (*MsgStakeUpdate) Reset 

func (m *MsgStakeUpdate) Reset()

func (*MsgStakeUpdate) Size 

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

func (*MsgStakeUpdate) String 

func (m *MsgStakeUpdate) String() string

func (*MsgStakeUpdate) Unmarshal 

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

func (MsgStakeUpdate) ValidateBasic added in v0.1.18 

func (msg MsgStakeUpdate) ValidateBasic() error

ValidateBasic validates the stake update msg before it is executed

func (*MsgStakeUpdate) XXX_DiscardUnknown 

func (m *MsgStakeUpdate) XXX_DiscardUnknown()

func (*MsgStakeUpdate) XXX_Marshal 

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

func (*MsgStakeUpdate) XXX_Merge 

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

func (*MsgStakeUpdate) XXX_Size 

func (m *MsgStakeUpdate) XXX_Size() int

func (*MsgStakeUpdate) XXX_Unmarshal 

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

type MsgStakeUpdateResponse 

type MsgStakeUpdateResponse struct {
}

MsgStakeUpdateResponse defines the response for MsgStakeUpdate.

func (*MsgStakeUpdateResponse) Descriptor 

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

func (*MsgStakeUpdateResponse) Marshal 

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

func (*MsgStakeUpdateResponse) MarshalTo 

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

func (*MsgStakeUpdateResponse) MarshalToSizedBuffer 

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

func (*MsgStakeUpdateResponse) ProtoMessage 

func (*MsgStakeUpdateResponse) ProtoMessage()

func (*MsgStakeUpdateResponse) Reset 

func (m *MsgStakeUpdateResponse) Reset()

func (*MsgStakeUpdateResponse) Size 

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

func (*MsgStakeUpdateResponse) String 

func (m *MsgStakeUpdateResponse) String() string

func (*MsgStakeUpdateResponse) Unmarshal 

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

func (*MsgStakeUpdateResponse) XXX_DiscardUnknown 

func (m *MsgStakeUpdateResponse) XXX_DiscardUnknown()

func (*MsgStakeUpdateResponse) XXX_Marshal 

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

func (*MsgStakeUpdateResponse) XXX_Merge 

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

func (*MsgStakeUpdateResponse) XXX_Size 

func (m *MsgStakeUpdateResponse) XXX_Size() int

func (*MsgStakeUpdateResponse) XXX_Unmarshal 

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

type MsgValidatorExit 

type MsgValidatorExit struct {
	From              string `protobuf:"bytes,1,opt,name=from,proto3" json:"from,omitempty"`
	ValId             uint64 `protobuf:"varint,2,opt,name=val_id,json=valId,proto3" json:"val_id,omitempty"`
	DeactivationEpoch uint64 `protobuf:"varint,3,opt,name=deactivation_epoch,json=deactivationEpoch,proto3" json:"deactivation_epoch,omitempty"`
	TxHash            []byte `protobuf:"bytes,4,opt,name=tx_hash,json=txHash,proto3" json:"tx_hash,omitempty"`
	LogIndex          uint64 `protobuf:"varint,5,opt,name=log_index,json=logIndex,proto3" json:"log_index,omitempty"`
	BlockNumber       uint64 `protobuf:"varint,6,opt,name=block_number,json=blockNumber,proto3" json:"block_number,omitempty"`
	Nonce             uint64 `protobuf:"varint,7,opt,name=nonce,proto3" json:"nonce,omitempty"`
}

MsgValidatorExit defines the message for a validator exiting the network.

func NewMsgValidatorExit 

func NewMsgValidatorExit(
	from string, id uint64, deactivationEpoch uint64,
	txHash []byte, logIndex uint64,
	blockNumber uint64, nonce uint64,
) (*MsgValidatorExit, error)

NewMsgValidatorExit creates a new MsgValidatorExit instance.

func (*MsgValidatorExit) Descriptor 

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

func (*MsgValidatorExit) GetBlockNumber 

func (m *MsgValidatorExit) GetBlockNumber() uint64

func (*MsgValidatorExit) GetDeactivationEpoch 

func (m *MsgValidatorExit) GetDeactivationEpoch() uint64

func (*MsgValidatorExit) GetFrom 

func (m *MsgValidatorExit) GetFrom() string

func (*MsgValidatorExit) GetLogIndex 

func (m *MsgValidatorExit) GetLogIndex() uint64

func (*MsgValidatorExit) GetNonce 

func (m *MsgValidatorExit) GetNonce() uint64

func (*MsgValidatorExit) GetTxHash 

func (m *MsgValidatorExit) GetTxHash() []byte

func (*MsgValidatorExit) GetValId 

func (m *MsgValidatorExit) GetValId() uint64

func (*MsgValidatorExit) Marshal 

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

func (*MsgValidatorExit) MarshalTo 

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

func (*MsgValidatorExit) MarshalToSizedBuffer 

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

func (*MsgValidatorExit) ProtoMessage 

func (*MsgValidatorExit) ProtoMessage()

func (*MsgValidatorExit) Reset 

func (m *MsgValidatorExit) Reset()

func (*MsgValidatorExit) Size 

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

func (*MsgValidatorExit) String 

func (m *MsgValidatorExit) String() string

func (*MsgValidatorExit) Unmarshal 

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

func (MsgValidatorExit) ValidateBasic added in v0.1.18 

func (msg MsgValidatorExit) ValidateBasic() error

ValidateBasic validates the validator exit msg before it is executed

func (*MsgValidatorExit) XXX_DiscardUnknown 

func (m *MsgValidatorExit) XXX_DiscardUnknown()

func (*MsgValidatorExit) XXX_Marshal 

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

func (*MsgValidatorExit) XXX_Merge 

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

func (*MsgValidatorExit) XXX_Size 

func (m *MsgValidatorExit) XXX_Size() int

func (*MsgValidatorExit) XXX_Unmarshal 

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

type MsgValidatorExitResponse 

type MsgValidatorExitResponse struct {
}

MsgValidatorExitResponse defines the response for MsgValidatorExit.

func (*MsgValidatorExitResponse) Descriptor 

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

func (*MsgValidatorExitResponse) Marshal 

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

func (*MsgValidatorExitResponse) MarshalTo 

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

func (*MsgValidatorExitResponse) MarshalToSizedBuffer 

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

func (*MsgValidatorExitResponse) ProtoMessage 

func (*MsgValidatorExitResponse) ProtoMessage()

func (*MsgValidatorExitResponse) Reset 

func (m *MsgValidatorExitResponse) Reset()

func (*MsgValidatorExitResponse) Size 

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

func (*MsgValidatorExitResponse) String 

func (m *MsgValidatorExitResponse) String() string

func (*MsgValidatorExitResponse) Unmarshal 

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

func (*MsgValidatorExitResponse) XXX_DiscardUnknown 

func (m *MsgValidatorExitResponse) XXX_DiscardUnknown()

func (*MsgValidatorExitResponse) XXX_Marshal 

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

func (*MsgValidatorExitResponse) XXX_Merge 

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

func (*MsgValidatorExitResponse) XXX_Size 

func (m *MsgValidatorExitResponse) XXX_Size() int

func (*MsgValidatorExitResponse) XXX_Unmarshal 

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

type MsgValidatorJoin 

type MsgValidatorJoin struct {
	From            string                `protobuf:"bytes,1,opt,name=from,proto3" json:"from,omitempty"`
	ValId           uint64                `protobuf:"varint,2,opt,name=val_id,json=valId,proto3" json:"val_id,omitempty"`
	ActivationEpoch uint64                `protobuf:"varint,3,opt,name=activation_epoch,json=activationEpoch,proto3" json:"activation_epoch,omitempty"`
	Amount          cosmossdk_io_math.Int `protobuf:"bytes,4,opt,name=amount,proto3,customtype=cosmossdk.io/math.Int" json:"amount"`
	SignerPubKey    []byte                `protobuf:"bytes,5,opt,name=signer_pub_key,json=signerPubKey,proto3" json:"signer_pub_key,omitempty"`
	TxHash          []byte                `protobuf:"bytes,6,opt,name=tx_hash,json=txHash,proto3" json:"tx_hash,omitempty"`
	LogIndex        uint64                `protobuf:"varint,7,opt,name=log_index,json=logIndex,proto3" json:"log_index,omitempty"`
	BlockNumber     uint64                `protobuf:"varint,8,opt,name=block_number,json=blockNumber,proto3" json:"block_number,omitempty"`
	Nonce           uint64                `protobuf:"varint,9,opt,name=nonce,proto3" json:"nonce,omitempty"`
}

MsgValidatorJoin defines the message for a new validator joining the network. This is triggered by stake events from the root chain.

func NewMsgValidatorJoin 

func NewMsgValidatorJoin(
	from string, id uint64, activationEpoch uint64,
	amount sdkmath.Int, pubKey cryptotypes.PubKey, txHash []byte, logIndex uint64,
	blockNumber uint64, nonce uint64,
) (*MsgValidatorJoin, error)

NewMsgValidatorJoin creates a new MsgCreateValidator instance.

func (*MsgValidatorJoin) Descriptor 

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

func (*MsgValidatorJoin) GetActivationEpoch 

func (m *MsgValidatorJoin) GetActivationEpoch() uint64

func (*MsgValidatorJoin) GetBlockNumber 

func (m *MsgValidatorJoin) GetBlockNumber() uint64

func (*MsgValidatorJoin) GetFrom 

func (m *MsgValidatorJoin) GetFrom() string

func (*MsgValidatorJoin) GetLogIndex 

func (m *MsgValidatorJoin) GetLogIndex() uint64

func (*MsgValidatorJoin) GetNonce 

func (m *MsgValidatorJoin) GetNonce() uint64

func (*MsgValidatorJoin) GetSignerPubKey 

func (m *MsgValidatorJoin) GetSignerPubKey() []byte

func (*MsgValidatorJoin) GetTxHash 

func (m *MsgValidatorJoin) GetTxHash() []byte

func (*MsgValidatorJoin) GetValId 

func (m *MsgValidatorJoin) GetValId() uint64

func (*MsgValidatorJoin) Marshal 

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

func (*MsgValidatorJoin) MarshalTo 

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

func (*MsgValidatorJoin) MarshalToSizedBuffer 

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

func (*MsgValidatorJoin) ProtoMessage 

func (*MsgValidatorJoin) ProtoMessage()

func (*MsgValidatorJoin) Reset 

func (m *MsgValidatorJoin) Reset()

func (*MsgValidatorJoin) Size 

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

func (*MsgValidatorJoin) String 

func (m *MsgValidatorJoin) String() string

func (*MsgValidatorJoin) Unmarshal 

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

func (MsgValidatorJoin) ValidateBasic added in v0.1.18 

func (msg MsgValidatorJoin) ValidateBasic() error

ValidateBasic validates the validator join msg before it is executed

func (*MsgValidatorJoin) XXX_DiscardUnknown 

func (m *MsgValidatorJoin) XXX_DiscardUnknown()

func (*MsgValidatorJoin) XXX_Marshal 

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

func (*MsgValidatorJoin) XXX_Merge 

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

func (*MsgValidatorJoin) XXX_Size 

func (m *MsgValidatorJoin) XXX_Size() int

func (*MsgValidatorJoin) XXX_Unmarshal 

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

type MsgValidatorJoinResponse 

type MsgValidatorJoinResponse struct {
}

MsgValidatorJoinResponse defines the response for MsgValidatorJoin.

func (*MsgValidatorJoinResponse) Descriptor 

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

func (*MsgValidatorJoinResponse) Marshal 

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

func (*MsgValidatorJoinResponse) MarshalTo 

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

func (*MsgValidatorJoinResponse) MarshalToSizedBuffer 

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

func (*MsgValidatorJoinResponse) ProtoMessage 

func (*MsgValidatorJoinResponse) ProtoMessage()

func (*MsgValidatorJoinResponse) Reset 

func (m *MsgValidatorJoinResponse) Reset()

func (*MsgValidatorJoinResponse) Size 

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

func (*MsgValidatorJoinResponse) String 

func (m *MsgValidatorJoinResponse) String() string

func (*MsgValidatorJoinResponse) Unmarshal 

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

func (*MsgValidatorJoinResponse) XXX_DiscardUnknown 

func (m *MsgValidatorJoinResponse) XXX_DiscardUnknown()

func (*MsgValidatorJoinResponse) XXX_Marshal 

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

func (*MsgValidatorJoinResponse) XXX_Merge 

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

func (*MsgValidatorJoinResponse) XXX_Size 

func (m *MsgValidatorJoinResponse) XXX_Size() int

func (*MsgValidatorJoinResponse) XXX_Unmarshal 

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

type PubKey 

type PubKey [65]byte

type QueryClient 

type QueryClient interface {
	// GetCurrentValidatorSet queries the current active validator set.
	GetCurrentValidatorSet(ctx context.Context, in *QueryCurrentValidatorSetRequest, opts ...grpc.CallOption) (*QueryCurrentValidatorSetResponse, error)
	// GetSignerByAddress queries validator information by signer address.
	GetSignerByAddress(ctx context.Context, in *QuerySignerRequest, opts ...grpc.CallOption) (*QuerySignerResponse, error)
	// GetValidatorById queries validator information by validator ID.
	GetValidatorById(ctx context.Context, in *QueryValidatorRequest, opts ...grpc.CallOption) (*QueryValidatorResponse, error)
	// GetValidatorStatusByAddress queries whether a validator is active or old.
	GetValidatorStatusByAddress(ctx context.Context, in *QueryValidatorStatusRequest, opts ...grpc.CallOption) (*QueryValidatorStatusResponse, error)
	// GetTotalPower queries the sum of all validators' voting power.
	GetTotalPower(ctx context.Context, in *QueryTotalPowerRequest, opts ...grpc.CallOption) (*QueryTotalPowerResponse, error)
	// IsStakeTxOld checks if a stake transaction has already been processed.
	IsStakeTxOld(ctx context.Context, in *QueryStakeIsOldTxRequest, opts ...grpc.CallOption) (*QueryStakeIsOldTxResponse, error)
	// GetCurrentProposer queries the validator currently designated as proposer.
	GetCurrentProposer(ctx context.Context, in *QueryCurrentProposerRequest, opts ...grpc.CallOption) (*QueryCurrentProposerResponse, error)
	// GetProposersByTimes returns the next N proposers in the rotation sequence.
	GetProposersByTimes(ctx context.Context, in *QueryProposersRequest, opts ...grpc.CallOption) (*QueryProposersResponse, 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 QueryCurrentProposerRequest added in v0.1.18 

type QueryCurrentProposerRequest struct {
}

QueryCurrentProposerRequest is the request type for the GetCurrentProposer query.

func (*QueryCurrentProposerRequest) Descriptor added in v0.1.18 

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

func (*QueryCurrentProposerRequest) Marshal added in v0.1.18 

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

func (*QueryCurrentProposerRequest) MarshalTo added in v0.1.18 

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

func (*QueryCurrentProposerRequest) MarshalToSizedBuffer added in v0.1.18 

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

func (*QueryCurrentProposerRequest) ProtoMessage added in v0.1.18 

func (*QueryCurrentProposerRequest) ProtoMessage()

func (*QueryCurrentProposerRequest) Reset added in v0.1.18 

func (m *QueryCurrentProposerRequest) Reset()

func (*QueryCurrentProposerRequest) Size added in v0.1.18 

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

func (*QueryCurrentProposerRequest) String added in v0.1.18 

func (m *QueryCurrentProposerRequest) String() string

func (*QueryCurrentProposerRequest) Unmarshal added in v0.1.18 

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

func (*QueryCurrentProposerRequest) XXX_DiscardUnknown added in v0.1.18 

func (m *QueryCurrentProposerRequest) XXX_DiscardUnknown()

func (*QueryCurrentProposerRequest) XXX_Marshal added in v0.1.18 

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

func (*QueryCurrentProposerRequest) XXX_Merge added in v0.1.18 

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

func (*QueryCurrentProposerRequest) XXX_Size added in v0.1.18 

func (m *QueryCurrentProposerRequest) XXX_Size() int

func (*QueryCurrentProposerRequest) XXX_Unmarshal added in v0.1.18 

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

type QueryCurrentProposerResponse added in v0.1.18 

type QueryCurrentProposerResponse struct {
	// The validator currently designated as proposer.
	Validator Validator `protobuf:"bytes,1,opt,name=validator,proto3" json:"validator"`
}

QueryCurrentProposerResponse is the response type for the GetCurrentProposer query.

func (*QueryCurrentProposerResponse) Descriptor added in v0.1.18 

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

func (*QueryCurrentProposerResponse) GetValidator added in v0.1.18 

func (m *QueryCurrentProposerResponse) GetValidator() Validator

func (*QueryCurrentProposerResponse) Marshal added in v0.1.18 

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

func (*QueryCurrentProposerResponse) MarshalTo added in v0.1.18 

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

func (*QueryCurrentProposerResponse) MarshalToSizedBuffer added in v0.1.18 

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

func (*QueryCurrentProposerResponse) ProtoMessage added in v0.1.18 

func (*QueryCurrentProposerResponse) ProtoMessage()

func (*QueryCurrentProposerResponse) Reset added in v0.1.18 

func (m *QueryCurrentProposerResponse) Reset()

func (*QueryCurrentProposerResponse) Size added in v0.1.18 

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

func (*QueryCurrentProposerResponse) String added in v0.1.18 

func (m *QueryCurrentProposerResponse) String() string

func (*QueryCurrentProposerResponse) Unmarshal added in v0.1.18 

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

func (*QueryCurrentProposerResponse) XXX_DiscardUnknown added in v0.1.18 

func (m *QueryCurrentProposerResponse) XXX_DiscardUnknown()

func (*QueryCurrentProposerResponse) XXX_Marshal added in v0.1.18 

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

func (*QueryCurrentProposerResponse) XXX_Merge added in v0.1.18 

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

func (*QueryCurrentProposerResponse) XXX_Size added in v0.1.18 

func (m *QueryCurrentProposerResponse) XXX_Size() int

func (*QueryCurrentProposerResponse) XXX_Unmarshal added in v0.1.18 

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

type QueryCurrentValidatorSetRequest 

type QueryCurrentValidatorSetRequest struct {
}

QueryCurrentValidatorSetRequest is the request type for the GetCurrentValidatorSet query.

func (*QueryCurrentValidatorSetRequest) Descriptor 

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

func (*QueryCurrentValidatorSetRequest) Marshal 

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

func (*QueryCurrentValidatorSetRequest) MarshalTo 

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

func (*QueryCurrentValidatorSetRequest) MarshalToSizedBuffer 

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

func (*QueryCurrentValidatorSetRequest) ProtoMessage 

func (*QueryCurrentValidatorSetRequest) ProtoMessage()

func (*QueryCurrentValidatorSetRequest) Reset 

func (m *QueryCurrentValidatorSetRequest) Reset()

func (*QueryCurrentValidatorSetRequest) Size 

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

func (*QueryCurrentValidatorSetRequest) String 

func (m *QueryCurrentValidatorSetRequest) String() string

func (*QueryCurrentValidatorSetRequest) Unmarshal 

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

func (*QueryCurrentValidatorSetRequest) XXX_DiscardUnknown 

func (m *QueryCurrentValidatorSetRequest) XXX_DiscardUnknown()

func (*QueryCurrentValidatorSetRequest) XXX_Marshal 

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

func (*QueryCurrentValidatorSetRequest) XXX_Merge 

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

func (*QueryCurrentValidatorSetRequest) XXX_Size 

func (m *QueryCurrentValidatorSetRequest) XXX_Size() int

func (*QueryCurrentValidatorSetRequest) XXX_Unmarshal 

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

type QueryCurrentValidatorSetResponse 

type QueryCurrentValidatorSetResponse struct {
	// The current active validator set.
	ValidatorSet ValidatorSet `protobuf:"bytes,1,opt,name=validator_set,json=validatorSet,proto3" json:"validator_set"`
}

QueryCurrentValidatorSetResponse is the response type for the GetCurrentValidatorSet query.

func (*QueryCurrentValidatorSetResponse) Descriptor 

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

func (*QueryCurrentValidatorSetResponse) GetValidatorSet 

func (m *QueryCurrentValidatorSetResponse) GetValidatorSet() ValidatorSet

func (*QueryCurrentValidatorSetResponse) Marshal 

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

func (*QueryCurrentValidatorSetResponse) MarshalTo 

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

func (*QueryCurrentValidatorSetResponse) MarshalToSizedBuffer 

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

func (*QueryCurrentValidatorSetResponse) ProtoMessage 

func (*QueryCurrentValidatorSetResponse) ProtoMessage()

func (*QueryCurrentValidatorSetResponse) Reset 

func (m *QueryCurrentValidatorSetResponse) Reset()

func (*QueryCurrentValidatorSetResponse) Size 

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

func (*QueryCurrentValidatorSetResponse) String 

func (m *QueryCurrentValidatorSetResponse) String() string

func (*QueryCurrentValidatorSetResponse) Unmarshal 

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

func (*QueryCurrentValidatorSetResponse) XXX_DiscardUnknown 

func (m *QueryCurrentValidatorSetResponse) XXX_DiscardUnknown()

func (*QueryCurrentValidatorSetResponse) XXX_Marshal 

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

func (*QueryCurrentValidatorSetResponse) XXX_Merge 

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

func (*QueryCurrentValidatorSetResponse) XXX_Size 

func (m *QueryCurrentValidatorSetResponse) XXX_Size() int

func (*QueryCurrentValidatorSetResponse) XXX_Unmarshal 

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

type QueryProposersRequest 

type QueryProposersRequest struct {
	// Number of future proposers to return in the rotation sequence.
	Times uint64 `protobuf:"varint,1,opt,name=times,proto3" json:"times,omitempty"`
}

QueryProposersRequest is the request type for the GetProposersByTimes query.

func (*QueryProposersRequest) Descriptor 

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

func (*QueryProposersRequest) GetTimes 

func (m *QueryProposersRequest) GetTimes() uint64

func (*QueryProposersRequest) Marshal 

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

func (*QueryProposersRequest) MarshalTo 

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

func (*QueryProposersRequest) MarshalToSizedBuffer 

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

func (*QueryProposersRequest) ProtoMessage 

func (*QueryProposersRequest) ProtoMessage()

func (*QueryProposersRequest) Reset 

func (m *QueryProposersRequest) Reset()

func (*QueryProposersRequest) Size 

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

func (*QueryProposersRequest) String 

func (m *QueryProposersRequest) String() string

func (*QueryProposersRequest) Unmarshal 

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

func (*QueryProposersRequest) XXX_DiscardUnknown 

func (m *QueryProposersRequest) XXX_DiscardUnknown()

func (*QueryProposersRequest) XXX_Marshal 

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

func (*QueryProposersRequest) XXX_Merge 

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

func (*QueryProposersRequest) XXX_Size 

func (m *QueryProposersRequest) XXX_Size() int

func (*QueryProposersRequest) XXX_Unmarshal 

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

type QueryProposersResponse 

type QueryProposersResponse struct {
	// List of validators in proposer rotation order.
	Proposers []Validator `protobuf:"bytes,1,rep,name=proposers,proto3" json:"proposers"`
}

QueryProposersResponse is the response type for the GetProposersByTimes query.

func (*QueryProposersResponse) Descriptor 

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

func (*QueryProposersResponse) GetProposers 

func (m *QueryProposersResponse) GetProposers() []Validator

func (*QueryProposersResponse) Marshal 

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

func (*QueryProposersResponse) MarshalTo 

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

func (*QueryProposersResponse) MarshalToSizedBuffer 

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

func (*QueryProposersResponse) ProtoMessage 

func (*QueryProposersResponse) ProtoMessage()

func (*QueryProposersResponse) Reset 

func (m *QueryProposersResponse) Reset()

func (*QueryProposersResponse) Size 

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

func (*QueryProposersResponse) String 

func (m *QueryProposersResponse) String() string

func (*QueryProposersResponse) Unmarshal 

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

func (*QueryProposersResponse) XXX_DiscardUnknown 

func (m *QueryProposersResponse) XXX_DiscardUnknown()

func (*QueryProposersResponse) XXX_Marshal 

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

func (*QueryProposersResponse) XXX_Merge 

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

func (*QueryProposersResponse) XXX_Size 

func (m *QueryProposersResponse) XXX_Size() int

func (*QueryProposersResponse) XXX_Unmarshal 

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

type QueryServer 

type QueryServer interface {
	// GetCurrentValidatorSet queries the current active validator set.
	GetCurrentValidatorSet(context.Context, *QueryCurrentValidatorSetRequest) (*QueryCurrentValidatorSetResponse, error)
	// GetSignerByAddress queries validator information by signer address.
	GetSignerByAddress(context.Context, *QuerySignerRequest) (*QuerySignerResponse, error)
	// GetValidatorById queries validator information by validator ID.
	GetValidatorById(context.Context, *QueryValidatorRequest) (*QueryValidatorResponse, error)
	// GetValidatorStatusByAddress queries whether a validator is active or old.
	GetValidatorStatusByAddress(context.Context, *QueryValidatorStatusRequest) (*QueryValidatorStatusResponse, error)
	// GetTotalPower queries the sum of all validators' voting power.
	GetTotalPower(context.Context, *QueryTotalPowerRequest) (*QueryTotalPowerResponse, error)
	// IsStakeTxOld checks if a stake transaction has already been processed.
	IsStakeTxOld(context.Context, *QueryStakeIsOldTxRequest) (*QueryStakeIsOldTxResponse, error)
	// GetCurrentProposer queries the validator currently designated as proposer.
	GetCurrentProposer(context.Context, *QueryCurrentProposerRequest) (*QueryCurrentProposerResponse, error)
	// GetProposersByTimes returns the next N proposers in the rotation sequence.
	GetProposersByTimes(context.Context, *QueryProposersRequest) (*QueryProposersResponse, error)
}

QueryServer is the server API for Query service.

type QuerySignerRequest 

type QuerySignerRequest struct {
	// Signer address to query for.
	ValAddress string `protobuf:"bytes,1,opt,name=val_address,json=valAddress,proto3" json:"val_address,omitempty"`
}

QuerySignerRequest is the request type for the GetSignerByAddress query.

func (*QuerySignerRequest) Descriptor 

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

func (*QuerySignerRequest) GetValAddress 

func (m *QuerySignerRequest) GetValAddress() string

func (*QuerySignerRequest) Marshal 

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

func (*QuerySignerRequest) MarshalTo 

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

func (*QuerySignerRequest) MarshalToSizedBuffer 

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

func (*QuerySignerRequest) ProtoMessage 

func (*QuerySignerRequest) ProtoMessage()

func (*QuerySignerRequest) Reset 

func (m *QuerySignerRequest) Reset()

func (*QuerySignerRequest) Size 

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

func (*QuerySignerRequest) String 

func (m *QuerySignerRequest) String() string

func (*QuerySignerRequest) Unmarshal 

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

func (*QuerySignerRequest) XXX_DiscardUnknown 

func (m *QuerySignerRequest) XXX_DiscardUnknown()

func (*QuerySignerRequest) XXX_Marshal 

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

func (*QuerySignerRequest) XXX_Merge 

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

func (*QuerySignerRequest) XXX_Size 

func (m *QuerySignerRequest) XXX_Size() int

func (*QuerySignerRequest) XXX_Unmarshal 

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

type QuerySignerResponse 

type QuerySignerResponse struct {
	// Validator information for the requested signer.
	Validator Validator `protobuf:"bytes,1,opt,name=validator,proto3" json:"validator"`
}

QuerySignerResponse is the response type for the GetSignerByAddress query.

func (*QuerySignerResponse) Descriptor 

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

func (*QuerySignerResponse) GetValidator 

func (m *QuerySignerResponse) GetValidator() Validator

func (*QuerySignerResponse) Marshal 

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

func (*QuerySignerResponse) MarshalTo 

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

func (*QuerySignerResponse) MarshalToSizedBuffer 

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

func (*QuerySignerResponse) ProtoMessage 

func (*QuerySignerResponse) ProtoMessage()

func (*QuerySignerResponse) Reset 

func (m *QuerySignerResponse) Reset()

func (*QuerySignerResponse) Size 

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

func (*QuerySignerResponse) String 

func (m *QuerySignerResponse) String() string

func (*QuerySignerResponse) Unmarshal 

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

func (*QuerySignerResponse) XXX_DiscardUnknown 

func (m *QuerySignerResponse) XXX_DiscardUnknown()

func (*QuerySignerResponse) XXX_Marshal 

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

func (*QuerySignerResponse) XXX_Merge 

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

func (*QuerySignerResponse) XXX_Size 

func (m *QuerySignerResponse) XXX_Size() int

func (*QuerySignerResponse) XXX_Unmarshal 

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

type QueryStakeIsOldTxRequest 

type QueryStakeIsOldTxRequest struct {
	// Transaction hash on the root chain.
	TxHash string `protobuf:"bytes,1,opt,name=tx_hash,json=txHash,proto3" json:"tx_hash,omitempty"`
	// Log index within the transaction.
	LogIndex uint64 `protobuf:"varint,2,opt,name=log_index,json=logIndex,proto3" json:"log_index,omitempty"`
}

QueryStakeIsOldTxRequest is the request type for the IsStakeTxOld query.

func (*QueryStakeIsOldTxRequest) Descriptor 

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

func (*QueryStakeIsOldTxRequest) GetLogIndex 

func (m *QueryStakeIsOldTxRequest) GetLogIndex() uint64

func (*QueryStakeIsOldTxRequest) GetTxHash 

func (m *QueryStakeIsOldTxRequest) GetTxHash() string

func (*QueryStakeIsOldTxRequest) Marshal 

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

func (*QueryStakeIsOldTxRequest) MarshalTo 

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

func (*QueryStakeIsOldTxRequest) MarshalToSizedBuffer 

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

func (*QueryStakeIsOldTxRequest) ProtoMessage 

func (*QueryStakeIsOldTxRequest) ProtoMessage()

func (*QueryStakeIsOldTxRequest) Reset 

func (m *QueryStakeIsOldTxRequest) Reset()

func (*QueryStakeIsOldTxRequest) Size 

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

func (*QueryStakeIsOldTxRequest) String 

func (m *QueryStakeIsOldTxRequest) String() string

func (*QueryStakeIsOldTxRequest) Unmarshal 

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

func (*QueryStakeIsOldTxRequest) XXX_DiscardUnknown 

func (m *QueryStakeIsOldTxRequest) XXX_DiscardUnknown()

func (*QueryStakeIsOldTxRequest) XXX_Marshal 

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

func (*QueryStakeIsOldTxRequest) XXX_Merge 

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

func (*QueryStakeIsOldTxRequest) XXX_Size 

func (m *QueryStakeIsOldTxRequest) XXX_Size() int

func (*QueryStakeIsOldTxRequest) XXX_Unmarshal 

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

type QueryStakeIsOldTxResponse 

type QueryStakeIsOldTxResponse struct {
	// True if this stake transaction has already been processed.
	IsOld bool `protobuf:"varint,1,opt,name=is_old,json=isOld,proto3" json:"is_old,omitempty"`
}

QueryStakeIsOldTxResponse is the response type for the IsStakeTxOld query.

func (*QueryStakeIsOldTxResponse) Descriptor 

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

func (*QueryStakeIsOldTxResponse) GetIsOld 

func (m *QueryStakeIsOldTxResponse) GetIsOld() bool

func (*QueryStakeIsOldTxResponse) Marshal 

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

func (*QueryStakeIsOldTxResponse) MarshalTo 

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

func (*QueryStakeIsOldTxResponse) MarshalToSizedBuffer 

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

func (*QueryStakeIsOldTxResponse) ProtoMessage 

func (*QueryStakeIsOldTxResponse) ProtoMessage()

func (*QueryStakeIsOldTxResponse) Reset 

func (m *QueryStakeIsOldTxResponse) Reset()

func (*QueryStakeIsOldTxResponse) Size 

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

func (*QueryStakeIsOldTxResponse) String 

func (m *QueryStakeIsOldTxResponse) String() string

func (*QueryStakeIsOldTxResponse) Unmarshal 

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

func (*QueryStakeIsOldTxResponse) XXX_DiscardUnknown 

func (m *QueryStakeIsOldTxResponse) XXX_DiscardUnknown()

func (*QueryStakeIsOldTxResponse) XXX_Marshal 

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

func (*QueryStakeIsOldTxResponse) XXX_Merge 

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

func (*QueryStakeIsOldTxResponse) XXX_Size 

func (m *QueryStakeIsOldTxResponse) XXX_Size() int

func (*QueryStakeIsOldTxResponse) XXX_Unmarshal 

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

type QueryTotalPowerRequest 

type QueryTotalPowerRequest struct {
}

QueryTotalPowerRequest is the request type for the GetTotalPower query.

func (*QueryTotalPowerRequest) Descriptor 

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

func (*QueryTotalPowerRequest) Marshal 

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

func (*QueryTotalPowerRequest) MarshalTo 

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

func (*QueryTotalPowerRequest) MarshalToSizedBuffer 

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

func (*QueryTotalPowerRequest) ProtoMessage 

func (*QueryTotalPowerRequest) ProtoMessage()

func (*QueryTotalPowerRequest) Reset 

func (m *QueryTotalPowerRequest) Reset()

func (*QueryTotalPowerRequest) Size 

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

func (*QueryTotalPowerRequest) String 

func (m *QueryTotalPowerRequest) String() string

func (*QueryTotalPowerRequest) Unmarshal 

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

func (*QueryTotalPowerRequest) XXX_DiscardUnknown 

func (m *QueryTotalPowerRequest) XXX_DiscardUnknown()

func (*QueryTotalPowerRequest) XXX_Marshal 

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

func (*QueryTotalPowerRequest) XXX_Merge 

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

func (*QueryTotalPowerRequest) XXX_Size 

func (m *QueryTotalPowerRequest) XXX_Size() int

func (*QueryTotalPowerRequest) XXX_Unmarshal 

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

type QueryTotalPowerResponse 

type QueryTotalPowerResponse struct {
	// Total voting power across all active validators.
	TotalPower int64 `protobuf:"varint,1,opt,name=total_power,json=totalPower,proto3" json:"total_power,omitempty"`
}

QueryTotalPowerResponse is the response type for the GetTotalPower query.

func (*QueryTotalPowerResponse) Descriptor 

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

func (*QueryTotalPowerResponse) GetTotalPower 

func (m *QueryTotalPowerResponse) GetTotalPower() int64

func (*QueryTotalPowerResponse) Marshal 

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

func (*QueryTotalPowerResponse) MarshalTo 

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

func (*QueryTotalPowerResponse) MarshalToSizedBuffer 

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

func (*QueryTotalPowerResponse) ProtoMessage 

func (*QueryTotalPowerResponse) ProtoMessage()

func (*QueryTotalPowerResponse) Reset 

func (m *QueryTotalPowerResponse) Reset()

func (*QueryTotalPowerResponse) Size 

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

func (*QueryTotalPowerResponse) String 

func (m *QueryTotalPowerResponse) String() string

func (*QueryTotalPowerResponse) Unmarshal 

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

func (*QueryTotalPowerResponse) XXX_DiscardUnknown 

func (m *QueryTotalPowerResponse) XXX_DiscardUnknown()

func (*QueryTotalPowerResponse) XXX_Marshal 

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

func (*QueryTotalPowerResponse) XXX_Merge 

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

func (*QueryTotalPowerResponse) XXX_Size 

func (m *QueryTotalPowerResponse) XXX_Size() int

func (*QueryTotalPowerResponse) XXX_Unmarshal 

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

type QueryValidatorRequest 

type QueryValidatorRequest struct {
	// Validator ID to query for.
	Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
}

QueryValidatorRequest is the request type for the GetValidatorById query.

func (*QueryValidatorRequest) Descriptor 

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

func (*QueryValidatorRequest) GetId 

func (m *QueryValidatorRequest) GetId() uint64

func (*QueryValidatorRequest) Marshal 

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

func (*QueryValidatorRequest) MarshalTo 

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

func (*QueryValidatorRequest) MarshalToSizedBuffer 

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

func (*QueryValidatorRequest) ProtoMessage 

func (*QueryValidatorRequest) ProtoMessage()

func (*QueryValidatorRequest) Reset 

func (m *QueryValidatorRequest) Reset()

func (*QueryValidatorRequest) Size 

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

func (*QueryValidatorRequest) String 

func (m *QueryValidatorRequest) String() string

func (*QueryValidatorRequest) Unmarshal 

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

func (*QueryValidatorRequest) XXX_DiscardUnknown 

func (m *QueryValidatorRequest) XXX_DiscardUnknown()

func (*QueryValidatorRequest) XXX_Marshal 

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

func (*QueryValidatorRequest) XXX_Merge 

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

func (*QueryValidatorRequest) XXX_Size 

func (m *QueryValidatorRequest) XXX_Size() int

func (*QueryValidatorRequest) XXX_Unmarshal 

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

type QueryValidatorResponse 

type QueryValidatorResponse struct {
	// Validator information for the requested ID.
	Validator Validator `protobuf:"bytes,1,opt,name=validator,proto3" json:"validator"`
}

QueryValidatorResponse is the response type for the GetValidatorById query.

func (*QueryValidatorResponse) Descriptor 

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

func (*QueryValidatorResponse) GetValidator 

func (m *QueryValidatorResponse) GetValidator() Validator

func (*QueryValidatorResponse) Marshal 

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

func (*QueryValidatorResponse) MarshalTo 

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

func (*QueryValidatorResponse) MarshalToSizedBuffer 

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

func (*QueryValidatorResponse) ProtoMessage 

func (*QueryValidatorResponse) ProtoMessage()

func (*QueryValidatorResponse) Reset 

func (m *QueryValidatorResponse) Reset()

func (*QueryValidatorResponse) Size 

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

func (*QueryValidatorResponse) String 

func (m *QueryValidatorResponse) String() string

func (*QueryValidatorResponse) Unmarshal 

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

func (*QueryValidatorResponse) XXX_DiscardUnknown 

func (m *QueryValidatorResponse) XXX_DiscardUnknown()

func (*QueryValidatorResponse) XXX_Marshal 

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

func (*QueryValidatorResponse) XXX_Merge 

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

func (*QueryValidatorResponse) XXX_Size 

func (m *QueryValidatorResponse) XXX_Size() int

func (*QueryValidatorResponse) XXX_Unmarshal 

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

type QueryValidatorStatusRequest 

type QueryValidatorStatusRequest struct {
	// Validator address to check status for.
	ValAddress string `protobuf:"bytes,1,opt,name=val_address,json=valAddress,proto3" json:"val_address,omitempty"`
}

QueryValidatorStatusRequest is the request type for the GetValidatorStatusByAddress query.

func (*QueryValidatorStatusRequest) Descriptor 

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

func (*QueryValidatorStatusRequest) GetValAddress 

func (m *QueryValidatorStatusRequest) GetValAddress() string

func (*QueryValidatorStatusRequest) Marshal 

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

func (*QueryValidatorStatusRequest) MarshalTo 

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

func (*QueryValidatorStatusRequest) MarshalToSizedBuffer 

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

func (*QueryValidatorStatusRequest) ProtoMessage 

func (*QueryValidatorStatusRequest) ProtoMessage()

func (*QueryValidatorStatusRequest) Reset 

func (m *QueryValidatorStatusRequest) Reset()

func (*QueryValidatorStatusRequest) Size 

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

func (*QueryValidatorStatusRequest) String 

func (m *QueryValidatorStatusRequest) String() string

func (*QueryValidatorStatusRequest) Unmarshal 

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

func (*QueryValidatorStatusRequest) XXX_DiscardUnknown 

func (m *QueryValidatorStatusRequest) XXX_DiscardUnknown()

func (*QueryValidatorStatusRequest) XXX_Marshal 

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

func (*QueryValidatorStatusRequest) XXX_Merge 

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

func (*QueryValidatorStatusRequest) XXX_Size 

func (m *QueryValidatorStatusRequest) XXX_Size() int

func (*QueryValidatorStatusRequest) XXX_Unmarshal 

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

type QueryValidatorStatusResponse 

type QueryValidatorStatusResponse struct {
	// True if the validator is no longer active (exited or not yet joined).
	IsOld bool `protobuf:"varint,1,opt,name=is_old,json=isOld,proto3" json:"is_old,omitempty"`
}

QueryValidatorStatusResponse is the response type for the GetValidatorStatusByAddress query.

func (*QueryValidatorStatusResponse) Descriptor 

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

func (*QueryValidatorStatusResponse) GetIsOld 

func (m *QueryValidatorStatusResponse) GetIsOld() bool

func (*QueryValidatorStatusResponse) Marshal 

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

func (*QueryValidatorStatusResponse) MarshalTo 

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

func (*QueryValidatorStatusResponse) MarshalToSizedBuffer 

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

func (*QueryValidatorStatusResponse) ProtoMessage 

func (*QueryValidatorStatusResponse) ProtoMessage()

func (*QueryValidatorStatusResponse) Reset 

func (m *QueryValidatorStatusResponse) Reset()

func (*QueryValidatorStatusResponse) Size 

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

func (*QueryValidatorStatusResponse) String 

func (m *QueryValidatorStatusResponse) String() string

func (*QueryValidatorStatusResponse) Unmarshal 

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

func (*QueryValidatorStatusResponse) XXX_DiscardUnknown 

func (m *QueryValidatorStatusResponse) XXX_DiscardUnknown()

func (*QueryValidatorStatusResponse) XXX_Marshal 

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

func (*QueryValidatorStatusResponse) XXX_Merge 

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

func (*QueryValidatorStatusResponse) XXX_Size 

func (m *QueryValidatorStatusResponse) XXX_Size() int

func (*QueryValidatorStatusResponse) XXX_Unmarshal 

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

type UnimplementedMsgServer 

type UnimplementedMsgServer struct {
}

UnimplementedMsgServer can be embedded to have forward compatible implementations.

func (*UnimplementedMsgServer) SignerUpdate 

func (*UnimplementedMsgServer) SignerUpdate(ctx context.Context, req *MsgSignerUpdate) (*MsgSignerUpdateResponse, error)

func (*UnimplementedMsgServer) StakeUpdate 

func (*UnimplementedMsgServer) StakeUpdate(ctx context.Context, req *MsgStakeUpdate) (*MsgStakeUpdateResponse, error)

func (*UnimplementedMsgServer) ValidatorExit 

func (*UnimplementedMsgServer) ValidatorExit(ctx context.Context, req *MsgValidatorExit) (*MsgValidatorExitResponse, error)

func (*UnimplementedMsgServer) ValidatorJoin 

func (*UnimplementedMsgServer) ValidatorJoin(ctx context.Context, req *MsgValidatorJoin) (*MsgValidatorJoinResponse, error)

type UnimplementedQueryServer 

type UnimplementedQueryServer struct {
}

UnimplementedQueryServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryServer) GetCurrentProposer added in v0.1.18 

func (*UnimplementedQueryServer) GetCurrentProposer(ctx context.Context, req *QueryCurrentProposerRequest) (*QueryCurrentProposerResponse, error)

func (*UnimplementedQueryServer) GetCurrentValidatorSet 

func (*UnimplementedQueryServer) GetCurrentValidatorSet(ctx context.Context, req *QueryCurrentValidatorSetRequest) (*QueryCurrentValidatorSetResponse, error)

func (*UnimplementedQueryServer) GetProposersByTimes 

func (*UnimplementedQueryServer) GetProposersByTimes(ctx context.Context, req *QueryProposersRequest) (*QueryProposersResponse, error)

func (*UnimplementedQueryServer) GetSignerByAddress 

func (*UnimplementedQueryServer) GetSignerByAddress(ctx context.Context, req *QuerySignerRequest) (*QuerySignerResponse, error)

func (*UnimplementedQueryServer) GetTotalPower 

func (*UnimplementedQueryServer) GetTotalPower(ctx context.Context, req *QueryTotalPowerRequest) (*QueryTotalPowerResponse, error)

func (*UnimplementedQueryServer) GetValidatorById 

func (*UnimplementedQueryServer) GetValidatorById(ctx context.Context, req *QueryValidatorRequest) (*QueryValidatorResponse, error)

func (*UnimplementedQueryServer) GetValidatorStatusByAddress 

func (*UnimplementedQueryServer) GetValidatorStatusByAddress(ctx context.Context, req *QueryValidatorStatusRequest) (*QueryValidatorStatusResponse, error)

func (*UnimplementedQueryServer) IsStakeTxOld 

func (*UnimplementedQueryServer) IsStakeTxOld(ctx context.Context, req *QueryStakeIsOldTxRequest) (*QueryStakeIsOldTxResponse, error)

type Validator 

type Validator struct {
	// Unique identifier for this validator.
	ValId uint64 `protobuf:"varint,1,opt,name=val_id,json=valId,proto3" json:"val_id,omitempty"`
	// Epoch when this validator becomes active.
	StartEpoch uint64 `protobuf:"varint,2,opt,name=start_epoch,json=startEpoch,proto3" json:"start_epoch,omitempty"`
	// Epoch when this validator becomes inactive. 0 means no end epoch set.
	EndEpoch uint64 `protobuf:"varint,3,opt,name=end_epoch,json=endEpoch,proto3" json:"end_epoch,omitempty"`
	// Nonce for replay protection of validator transactions.
	Nonce uint64 `protobuf:"varint,4,opt,name=nonce,proto3" json:"nonce,omitempty"`
	// Voting power based on the validator's stake amount.
	VotingPower int64 `protobuf:"varint,5,opt,name=voting_power,json=votingPower,proto3" json:"voting_power,omitempty"`
	// Public key used for block signing on the Bor chain.
	PubKey []byte `protobuf:"bytes,6,opt,name=pub_key,json=pubKey,proto3" json:"pub_key,omitempty"`
	// Heimdall address of this validator's signer.
	Signer string `protobuf:"bytes,7,opt,name=signer,proto3" json:"signer,omitempty"`
	// Block height or identifier when this validator was last updated.
	LastUpdated string `protobuf:"bytes,8,opt,name=last_updated,json=lastUpdated,proto3" json:"last_updated,omitempty"`
	// Whether this validator is currently jailed (slashed and temporarily
	// removed).
	Jailed bool `protobuf:"varint,9,opt,name=jailed,proto3" json:"jailed,omitempty"`
	// Priority value used for round-robin proposer selection in Tendermint.
	ProposerPriority int64 `protobuf:"varint,10,opt,name=proposer_priority,json=proposerPriority,proto3" json:"proposer_priority,omitempty"`
}

Validator represents a single validator in the Heimdall network. Validators are responsible for producing blocks on the Bor chain and securing the network through Proof-of-Stake consensus.

func GetUpdatedValidators 

func GetUpdatedValidators(
	currentSet *ValidatorSet,
	validators []*Validator,
	ackCount uint64,
) []*Validator

GetUpdatedValidators updates validators in validator set

func NewValidator 

func NewValidator(
	id uint64,
	startEpoch uint64,
	endEpoch uint64,
	nonce uint64,
	power int64,
	pubKey cryptotypes.PubKey,
	signer string,
) (*Validator, error)

NewValidator func creates a new validator

func SortValidatorByAddress 

func SortValidatorByAddress(a []Validator) []Validator

SortValidatorByAddress sorts a slice of validators by address. To sort it, we compare the values of the signer field

func (*Validator) Bytes 

func (v *Validator) Bytes() []byte

Bytes function computes the unique encoding of a validator with a given voting power. These are the bytes that get hashed in consensus. It excludes the address as it's redundant with the pubKey. This also excludes the ProposerPriority which changes at every round.

func (Validator) CmtConsPublicKey 

func (v Validator) CmtConsPublicKey() (cmtprotocrypto.PublicKey, error)

CmtConsPublicKey casts Validator.ConsensusPubkey to cmtprotocrypto.PubKey.

func (*Validator) CompareProposerPriority 

func (v *Validator) CompareProposerPriority(other *Validator) *Validator

CompareProposerPriority returns the one with higher ProposerPriority.

func (Validator) ConsPubKey 

func (v Validator) ConsPubKey() ([]byte, error)

ConsPubKey returns the validator PubKey as a cryptotypes.PubKey.

func (*Validator) Copy 

func (v *Validator) Copy() *Validator

Copy creates a new copy of the validator, so we can mutate accum

func (*Validator) Descriptor 

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

func (*Validator) Equal 

func (this *Validator) Equal(that interface{}) bool

func (*Validator) GetBondedTokens 

func (v *Validator) GetBondedTokens() math.Int

GetBondedTokens implements types.ValidatorI.

func (*Validator) GetCommission 

func (*Validator) GetCommission() math.LegacyDec

GetCommission implements types.ValidatorI.

func (*Validator) GetConsAddr 

func (*Validator) GetConsAddr() ([]byte, error)

GetConsAddr implements types.ValidatorI.

func (*Validator) GetConsensusPower 

func (*Validator) GetConsensusPower(_ math.Int) int64

GetConsensusPower implements types.ValidatorI.

func (*Validator) GetDelegatorShares 

func (*Validator) GetDelegatorShares() math.LegacyDec

GetDelegatorShares implements types.ValidatorI.

func (*Validator) GetEndEpoch 

func (m *Validator) GetEndEpoch() uint64

func (*Validator) GetJailed 

func (m *Validator) GetJailed() bool

func (*Validator) GetLastUpdated 

func (m *Validator) GetLastUpdated() string

func (*Validator) GetMinSelfDelegation 

func (*Validator) GetMinSelfDelegation() math.Int

GetMinSelfDelegation implements types.ValidatorI.

func (*Validator) GetMoniker 

func (*Validator) GetMoniker() string

GetMoniker implements types.ValidatorI.

func (*Validator) GetNonce 

func (m *Validator) GetNonce() uint64

func (*Validator) GetOperator 

func (v *Validator) GetOperator() string

GetOperator implements types.ValidatorI.

func (*Validator) GetProposerPriority 

func (m *Validator) GetProposerPriority() int64

func (*Validator) GetPubKey 

func (m *Validator) GetPubKey() []byte

func (*Validator) GetSigner 

func (m *Validator) GetSigner() string

func (*Validator) GetStartEpoch 

func (m *Validator) GetStartEpoch() uint64

func (*Validator) GetStatus 

func (*Validator) GetStatus() cosmosTypes.BondStatus

GetStatus implements types.ValidatorI.

func (*Validator) GetTokens 

func (*Validator) GetTokens() math.Int

GetTokens implements types.ValidatorI.

func (*Validator) GetValId 

func (m *Validator) GetValId() uint64

func (*Validator) GetVotingPower 

func (m *Validator) GetVotingPower() int64

func (*Validator) IsBonded 

func (*Validator) IsBonded() bool

IsBonded implements types.ValidatorI.

func (*Validator) IsCurrentValidator 

func (v *Validator) IsCurrentValidator(ackCount uint64) bool

IsCurrentValidator checks if the validator is in the current validator set

func (*Validator) IsJailed 

func (*Validator) IsJailed() bool

IsJailed implements types.ValidatorI.

func (*Validator) IsUnbonded 

func (*Validator) IsUnbonded() bool

IsUnbonded implements types.ValidatorI.

func (*Validator) IsUnbonding 

func (*Validator) IsUnbonding() bool

IsUnbonding implements types.ValidatorI.

func (*Validator) Marshal 

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

func (*Validator) MarshalTo 

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

func (*Validator) MarshalToSizedBuffer 

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

func (*Validator) MinimalVal 

func (v *Validator) MinimalVal() MinimalVal

MinimalVal returns block number of last validator update

func (*Validator) ProtoMessage 

func (*Validator) ProtoMessage()

func (*Validator) Reset 

func (m *Validator) Reset()

func (*Validator) SharesFromTokens 

func (*Validator) SharesFromTokens(_ math.Int) (math.LegacyDec, error)

SharesFromTokens implements types.ValidatorI.

func (*Validator) SharesFromTokensTruncated 

func (*Validator) SharesFromTokensTruncated(_ math.Int) (math.LegacyDec, error)

SharesFromTokensTruncated implements types.ValidatorI.

func (*Validator) Size 

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

func (*Validator) String 

func (m *Validator) String() string

func (*Validator) TmConsPublicKey 

func (*Validator) TmConsPublicKey() (cmtprotocrypto.PublicKey, error)

TmConsPublicKey implements types.ValidatorI.

func (*Validator) TokensFromShares 

func (*Validator) TokensFromShares(_ math.LegacyDec) math.LegacyDec

TokensFromShares implements types.ValidatorI.

func (*Validator) TokensFromSharesRoundUp 

func (*Validator) TokensFromSharesRoundUp(_ math.LegacyDec) math.LegacyDec

TokensFromSharesRoundUp implements types.ValidatorI.

func (*Validator) TokensFromSharesTruncated 

func (*Validator) TokensFromSharesTruncated(_ math.LegacyDec) math.LegacyDec

func (*Validator) Unmarshal 

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

func (*Validator) UpdatedAt 

func (v *Validator) UpdatedAt() string

UpdatedAt returns block number of the last validator update

func (*Validator) ValidateBasic 

func (v *Validator) ValidateBasic() error

ValidateBasic validates a validator struct

func (*Validator) XXX_DiscardUnknown 

func (m *Validator) XXX_DiscardUnknown()

func (*Validator) XXX_Marshal 

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

func (*Validator) XXX_Merge 

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

func (*Validator) XXX_Size 

func (m *Validator) XXX_Size() int

func (*Validator) XXX_Unmarshal 

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

type ValidatorSet 

type ValidatorSet struct {
	// List of all validators in this set.
	Validators []*Validator `protobuf:"bytes,1,rep,name=validators,proto3" json:"validators,omitempty"`
	// The validator designated as proposer for the current block.
	Proposer *Validator `protobuf:"bytes,2,opt,name=proposer,proto3" json:"proposer,omitempty"`
	// Sum of voting power across all validators in this set.
	TotalVotingPower int64 `protobuf:"varint,3,opt,name=total_voting_power,json=totalVotingPower,proto3" json:"total_voting_power,omitempty"`
}

ValidatorSet represents a complete set of validators at a specific point in time. This is used for consensus and includes the designated block proposer.

func NewValidatorSet 

func NewValidatorSet(validators []*Validator) *ValidatorSet

NewValidatorSet initializes a ValidatorSet by copying over the values from `validators`, a list of Validators. If validators are nil or empty, the new ValidatorSet will have an empty list of Validators. The addresses of validators in `validators` must be unique, otherwise the function panics.

func (*ValidatorSet) Copy 

func (vals *ValidatorSet) Copy() *ValidatorSet

Copy each validator into a new ValidatorSet.

func (*ValidatorSet) CopyIncrementProposerPriority 

func (vals *ValidatorSet) CopyIncrementProposerPriority(times int) *ValidatorSet

CopyIncrementProposerPriority increments the ProposerPriority and updates the proposer on a copy and return it.

func (*ValidatorSet) Descriptor 

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

func (*ValidatorSet) Equal 

func (this *ValidatorSet) Equal(that interface{}) bool

func (*ValidatorSet) GetByAddress 

func (vals *ValidatorSet) GetByAddress(address string) (index int, val *Validator)

GetByAddress returns an index of the validator with the address and validator itself if found. Otherwise, -1 and nil are returned.

func (*ValidatorSet) GetByIndex 

func (vals *ValidatorSet) GetByIndex(index int) (address string, val *Validator)

GetByIndex returns the validator's address and the validator itself by index. It returns nil values if the index is less than 0 or greater or equal to len(ValidatorSet.Validators).

func (*ValidatorSet) GetProposer 

func (vals *ValidatorSet) GetProposer() (proposer *Validator)

GetProposer returns the current proposer. If the validator set is empty, nil is returned.

func (*ValidatorSet) GetTotalVotingPower 

func (vals *ValidatorSet) GetTotalVotingPower() int64

GetTotalVotingPower returns the sum of the validators' voting powers. It recomputes the total voting power if required.

func (*ValidatorSet) HasAddress 

func (vals *ValidatorSet) HasAddress(address string) bool

HasAddress returns true if the address given is in the validator set, false otherwise.

func (*ValidatorSet) IncrementProposerPriority 

func (vals *ValidatorSet) IncrementProposerPriority(times int)

IncrementProposerPriority increments ProposerPriority of each validator and updates the proposer. Panics if the validator set is empty. `times` must be positive.

func (*ValidatorSet) IsNilOrEmpty 

func (vals *ValidatorSet) IsNilOrEmpty() bool

IsNilOrEmpty checks whether the validator set is empty or nil

func (*ValidatorSet) Iterate 

func (vals *ValidatorSet) Iterate(fn func(index int, val *Validator) bool)

Iterate will run the given function over the set.

func (*ValidatorSet) Len 

func (vals *ValidatorSet) Len() int

Len returns the length of the validator set.

func (*ValidatorSet) Marshal 

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

func (*ValidatorSet) MarshalTo 

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

func (*ValidatorSet) MarshalToSizedBuffer 

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

func (*ValidatorSet) ProtoMessage 

func (*ValidatorSet) ProtoMessage()

func (*ValidatorSet) RescalePriorities 

func (vals *ValidatorSet) RescalePriorities(diffMax int64)

RescalePriorities rescales the priorities

func (*ValidatorSet) Reset 

func (m *ValidatorSet) Reset()

func (*ValidatorSet) Size 

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

func (*ValidatorSet) String 

func (m *ValidatorSet) String() string

func (*ValidatorSet) Unmarshal 

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

func (*ValidatorSet) UpdateWithChangeSet 

func (vals *ValidatorSet) UpdateWithChangeSet(changes []*Validator) error

UpdateWithChangeSet attempts to update the validator set with 'changes'. It performs the following steps:

  • validates the changes making sure there are no duplicates and splits them in updates and deletes
  • verifies that applying the changes will not result in errors
  • computes the total voting power BEFORE removals to ensure that in the next steps the priorities across old and newly added validators are fair
  • computes the priorities of new validators against the final set
  • applies the updates against the validator set
  • applies the removals against the validator set
  • performs scaling and centering of priority values

If an error is detected during verification steps, it is returned and the validator set is not changed.

func (*ValidatorSet) XXX_DiscardUnknown 

func (m *ValidatorSet) XXX_DiscardUnknown()

func (*ValidatorSet) XXX_Marshal 

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

func (*ValidatorSet) XXX_Merge 

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

func (*ValidatorSet) XXX_Size 

func (m *ValidatorSet) XXX_Size() int

func (*ValidatorSet) XXX_Unmarshal 

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

type ValidatorsByAddress 

type ValidatorsByAddress []*Validator

ValidatorsByAddress sorts validators by address.

func (ValidatorsByAddress) Len 

func (vals ValidatorsByAddress) Len() int

func (ValidatorsByAddress) Less 

func (vals ValidatorsByAddress) Less(i, j int) bool

func (ValidatorsByAddress) Swap 

func (vals ValidatorsByAddress) Swap(i, j int)

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.