types

package
v0.7.2 Latest Latest
Warning

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

 Go to latest Published: Jun 10, 2023 License: Apache-2.0 Imports: 41 Imported by: 3

Documentation

Overview

Package types is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

View Source 
const (
	// ModuleName defines the module name
	ModuleName = "epoching"

	// StoreKey defines the primary module store key
	StoreKey = ModuleName

	// RouterKey is the message route for epoching
	RouterKey = ModuleName

	// QuerierRoute defines the module's query routing key
	QuerierRoute = ModuleName

	// MemStoreKey defines the in-memory store key
	MemStoreKey = "mem_epoching"
)
View Source 
const (
	TypeMsgWrappedDelegate        = "wrapped_delegate"
	TypeMsgWrappedUndelegate      = "wrapped_begin_unbonding"
	TypeMsgWrappedBeginRedelegate = "wrapped_begin_redelegate"
)

staking message types

View Source 
const (
	DefaultEpochInterval uint64 = 10
)
View Source 
const DefaultIndex uint64 = 1

DefaultIndex is the default capability global index

Variables

View Source 
var (
	Amino     = codec.NewLegacyAmino()
	ModuleCdc = codec.NewProtoCodec(cdctypes.NewInterfaceRegistry())
)
View Source 
var (
	ErrInvalidLengthEpoching        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowEpoching          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupEpoching = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrUnwrappedMsgType = errorsmod.Register(ModuleName, 1, `
										invalid message type in {MsgCreateValidator, MsgDelegate, MsgUndelegate, MsgBeginRedelegate}
										messages. For creating a validator use the wrapped version under 'tx checkpointing create-validator'
										and for the other messages use the wrapped versions under 'tx epoching {delegate,undelegate,redelegate}'`)
	ErrInvalidQueuedMessageType  = errorsmod.Register(ModuleName, 2, "invalid message type of a QueuedMessage")
	ErrUnknownEpochNumber        = errorsmod.Register(ModuleName, 3, "the epoch number is not known in DB")
	ErrUnknownSlashedVotingPower = errorsmod.Register(ModuleName, 5, "the slashed voting power is not known in DB. Maybe the epoch has been checkpointed?")
	ErrUnknownValidator          = errorsmod.Register(ModuleName, 6, "the validator is not known in the validator set.")
	ErrUnknownTotalVotingPower   = errorsmod.Register(ModuleName, 7, "the total voting power is not known in DB.")
	ErrMarshal                   = errorsmod.Register(ModuleName, 8, "marshal error.")
	ErrUnmarshal                 = errorsmod.Register(ModuleName, 9, "unmarshal error.")
	ErrNoWrappedMsg              = errorsmod.Register(ModuleName, 10, "the wrapped msg contains no msg inside.")
	ErrZeroEpochMsg              = errorsmod.Register(ModuleName, 11, "the 0-th epoch does not handle messages")
	ErrInvalidEpoch              = errorsmod.Register(ModuleName, 12, "the epoch is invalid")
	ErrInvalidHeight             = errorsmod.Register(ModuleName, 13, "the height is invalid")
	ErrInsufficientBalance       = errorsmod.Register(ModuleName, 14, "the delegator has insufficient balance to perform delegate")
)
View Source 
var (
	ErrInvalidLengthEvents        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowEvents          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupEvents = fmt.Errorf("proto: unexpected end of group")
)
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 (
	EpochNumberKey         = []byte{0x11} // key prefix for the epoch number
	EpochInfoKey           = []byte{0x12} // key prefix for the epoch info
	QueueLengthKey         = []byte{0x13} // key prefix for the queue length
	MsgQueueKey            = []byte{0x14} // key prefix for the message queue of an epoch
	ValidatorSetKey        = []byte{0x15} // key prefix for the validator set in a single epoch
	VotingPowerKey         = []byte{0x16} // key prefix for the total voting power of a validator set in a single epoch
	SlashedVotingPowerKey  = []byte{0x17} // key prefix for the total slashed voting power in a single epoch
	SlashedValidatorSetKey = []byte{0x18} // key prefix for slashed validator set
	ValidatorLifecycleKey  = []byte{0x19} // key prefix for validator life cycle
	DelegationLifecycleKey = []byte{0x20} // key prefix for delegation life cycle
	AppHashKey             = []byte{0x21} // key prefix for the app hash
	ParamsKey              = []byte{0x22} // key prefix for the parameters
)
View Source 
var (
	ErrInvalidLengthParams        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowParams          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupParams = 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 BondState_name = map[int32]string{
	0: "CREATED",
	1: "BONDED",
	2: "UNBONDING",
	3: "UNBONDED",
	4: "REMOVED",
}
View Source 
var BondState_value = map[string]int32{
	"CREATED":   0,
	"BONDED":    1,
	"UNBONDING": 2,
	"UNBONDED":  3,
	"REMOVED":   4,
}
View Source 
var (
	KeyEpochInterval = []byte("EpochInterval")
)

Functions

func KeyPrefix 

func KeyPrefix(p string) []byte

func RegisterCodec 

func RegisterCodec(cdc *codec.LegacyAmino)

func RegisterInterfaces 

func RegisterInterfaces(registry cdctypes.InterfaceRegistry)

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)

Types

type AccountKeeper 

type AccountKeeper interface {
	GetAccount(ctx sdk.Context, addr sdk.AccAddress) authtypes.AccountI
}

AccountKeeper defines the expected account keeper used for simulations (noalias)

type BankKeeper 

type BankKeeper interface {
	SpendableCoins(ctx sdk.Context, addr sdk.AccAddress) sdk.Coins
	GetBalance(ctx sdk.Context, addr sdk.AccAddress, denom string) sdk.Coin
}

BankKeeper defines the expected interface needed to retrieve account balances.

type BondState 

type BondState int32

BondState is the bond state of a validator or delegation 

const (
	// CREATED is when the validator/delegation has been created
	BondState_CREATED BondState = 0
	// CREATED is when the validator/delegation has become bonded
	BondState_BONDED BondState = 1
	// CREATED is when the validator/delegation has become unbonding
	BondState_UNBONDING BondState = 2
	// CREATED is when the validator/delegation has become unbonded
	BondState_UNBONDED BondState = 3
	// CREATED is when the validator/delegation has been removed
	BondState_REMOVED BondState = 4
)

func (BondState) EnumDescriptor 

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

func (BondState) String 

func (x BondState) String() string

type DelegationLifecycle 

type DelegationLifecycle struct {
	DelAddr string                   `protobuf:"bytes,1,opt,name=del_addr,json=delAddr,proto3" json:"del_addr,omitempty"`
	DelLife []*DelegationStateUpdate `protobuf:"bytes,2,rep,name=del_life,json=delLife,proto3" json:"del_life,omitempty"`
}

ValidatorLifecycle is a message that records records the lifecycle of a delegation

func (*DelegationLifecycle) Descriptor 

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

func (*DelegationLifecycle) GetDelAddr 

func (m *DelegationLifecycle) GetDelAddr() string

func (*DelegationLifecycle) GetDelLife 

func (m *DelegationLifecycle) GetDelLife() []*DelegationStateUpdate

func (*DelegationLifecycle) Marshal 

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

func (*DelegationLifecycle) MarshalTo 

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

func (*DelegationLifecycle) MarshalToSizedBuffer 

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

func (*DelegationLifecycle) ProtoMessage 

func (*DelegationLifecycle) ProtoMessage()

func (*DelegationLifecycle) Reset 

func (m *DelegationLifecycle) Reset()

func (*DelegationLifecycle) Size 

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

func (*DelegationLifecycle) String 

func (m *DelegationLifecycle) String() string

func (*DelegationLifecycle) Unmarshal 

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

func (*DelegationLifecycle) XXX_DiscardUnknown 

func (m *DelegationLifecycle) XXX_DiscardUnknown()

func (*DelegationLifecycle) XXX_Marshal 

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

func (*DelegationLifecycle) XXX_Merge 

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

func (*DelegationLifecycle) XXX_Size 

func (m *DelegationLifecycle) XXX_Size() int

func (*DelegationLifecycle) XXX_Unmarshal 

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

type DelegationStateUpdate 

type DelegationStateUpdate struct {
	State       BondState  `protobuf:"varint,1,opt,name=state,proto3,enum=babylon.epoching.v1.BondState" json:"state,omitempty"`
	ValAddr     string     `protobuf:"bytes,2,opt,name=val_addr,json=valAddr,proto3" json:"val_addr,omitempty"`
	BlockHeight uint64     `protobuf:"varint,3,opt,name=block_height,json=blockHeight,proto3" json:"block_height,omitempty"`
	BlockTime   *time.Time `protobuf:"bytes,4,opt,name=block_time,json=blockTime,proto3,stdtime" json:"block_time,omitempty"`
}

DelegationStateUpdate is the message that records a state update of a delegation

func (*DelegationStateUpdate) Descriptor 

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

func (*DelegationStateUpdate) GetBlockHeight 

func (m *DelegationStateUpdate) GetBlockHeight() uint64

func (*DelegationStateUpdate) GetBlockTime 

func (m *DelegationStateUpdate) GetBlockTime() *time.Time

func (*DelegationStateUpdate) GetState 

func (m *DelegationStateUpdate) GetState() BondState

func (*DelegationStateUpdate) GetValAddr 

func (m *DelegationStateUpdate) GetValAddr() string

func (*DelegationStateUpdate) Marshal 

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

func (*DelegationStateUpdate) MarshalTo 

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

func (*DelegationStateUpdate) MarshalToSizedBuffer 

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

func (*DelegationStateUpdate) ProtoMessage 

func (*DelegationStateUpdate) ProtoMessage()

func (*DelegationStateUpdate) Reset 

func (m *DelegationStateUpdate) Reset()

func (*DelegationStateUpdate) Size 

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

func (*DelegationStateUpdate) String 

func (m *DelegationStateUpdate) String() string

func (*DelegationStateUpdate) Unmarshal 

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

func (*DelegationStateUpdate) XXX_DiscardUnknown 

func (m *DelegationStateUpdate) XXX_DiscardUnknown()

func (*DelegationStateUpdate) XXX_Marshal 

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

func (*DelegationStateUpdate) XXX_Merge 

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

func (*DelegationStateUpdate) XXX_Size 

func (m *DelegationStateUpdate) XXX_Size() int

func (*DelegationStateUpdate) XXX_Unmarshal 

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

type Epoch 

type Epoch struct {
	EpochNumber          uint64 `protobuf:"varint,1,opt,name=epoch_number,json=epochNumber,proto3" json:"epoch_number,omitempty"`
	CurrentEpochInterval uint64 `protobuf:"varint,2,opt,name=current_epoch_interval,json=currentEpochInterval,proto3" json:"current_epoch_interval,omitempty"`
	FirstBlockHeight     uint64 `protobuf:"varint,3,opt,name=first_block_height,json=firstBlockHeight,proto3" json:"first_block_height,omitempty"`
	// last_block_header is the header of the last block in this epoch.
	// Babylon needs to remember the last header of each epoch to complete
	// unbonding validators/delegations when a previous epoch's checkpoint is
	// finalised. The last_block_header field is nil in the epoch's beginning, and
	// is set upon the end of this epoch.
	LastBlockHeader *types.Header `protobuf:"bytes,4,opt,name=last_block_header,json=lastBlockHeader,proto3" json:"last_block_header,omitempty"`
	// app_hash_root is the Merkle root of all AppHashs in this epoch
	// It will be used for proving a block is in an epoch
	AppHashRoot []byte `protobuf:"bytes,5,opt,name=app_hash_root,json=appHashRoot,proto3" json:"app_hash_root,omitempty"`
	// sealer_header is the 2nd header of the next epoch
	// This validator set has generated a BLS multisig on `last_commit_hash` of
	// the sealer header
	SealerHeader *types.Header `protobuf:"bytes,6,opt,name=sealer_header,json=sealerHeader,proto3" json:"sealer_header,omitempty"`
}

Epoch is a structure that contains the metadata of an epoch

func NewEpoch 

func NewEpoch(epochNumber uint64, epochInterval uint64, firstBlockHeight uint64, lastBlockHeader *tmproto.Header) Epoch

NewEpoch constructs a new Epoch object The relationship between block and epoch is as follows, assuming epoch interval of 5: 0 | 1 2 3 4 5 | 6 7 8 9 10 | 0 | 1 | 2 |

func (*Epoch) Descriptor 

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

func (*Epoch) GetAppHashRoot 

func (m *Epoch) GetAppHashRoot() []byte

func (*Epoch) GetCurrentEpochInterval 

func (m *Epoch) GetCurrentEpochInterval() uint64

func (*Epoch) GetEpochNumber 

func (m *Epoch) GetEpochNumber() uint64

func (*Epoch) GetFirstBlockHeight 

func (m *Epoch) GetFirstBlockHeight() uint64

func (*Epoch) GetLastBlockHeader 

func (m *Epoch) GetLastBlockHeader() *types.Header

func (Epoch) GetLastBlockHeight 

func (e Epoch) GetLastBlockHeight() uint64

func (*Epoch) GetSealerHeader 

func (m *Epoch) GetSealerHeader() *types.Header

func (Epoch) GetSecondBlockHeight 

func (e Epoch) GetSecondBlockHeight() uint64

func (Epoch) IsFirstBlock 

func (e Epoch) IsFirstBlock(ctx sdk.Context) bool

func (Epoch) IsFirstBlockOfNextEpoch 

func (e Epoch) IsFirstBlockOfNextEpoch(ctx sdk.Context) bool

IsFirstBlockOfNextEpoch checks whether the current block is the first block of the next epoch CONTRACT: IsFirstBlockOfNextEpoch can only be called by the epoching module once upon the first block of a new epoch other modules should use IsFirstBlock instead.

func (Epoch) IsLastBlock 

func (e Epoch) IsLastBlock(ctx sdk.Context) bool

func (Epoch) IsSecondBlock 

func (e Epoch) IsSecondBlock(ctx sdk.Context) bool

func (*Epoch) Marshal 

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

func (*Epoch) MarshalTo 

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

func (*Epoch) MarshalToSizedBuffer 

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

func (*Epoch) ProtoMessage 

func (*Epoch) ProtoMessage()

func (*Epoch) Reset 

func (m *Epoch) Reset()

func (*Epoch) Size 

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

func (*Epoch) String 

func (m *Epoch) String() string

func (*Epoch) Unmarshal 

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

func (Epoch) ValidateBasic 

func (e Epoch) ValidateBasic() error

ValidateBasic does sanity checks on Epoch

func (Epoch) WithinBoundary 

func (e Epoch) WithinBoundary(height uint64) bool

WithinBoundary checks whether the given height is within this epoch or not

func (*Epoch) XXX_DiscardUnknown 

func (m *Epoch) XXX_DiscardUnknown()

func (*Epoch) XXX_Marshal 

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

func (*Epoch) XXX_Merge 

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

func (*Epoch) XXX_Size 

func (m *Epoch) XXX_Size() int

func (*Epoch) XXX_Unmarshal 

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

type EpochingHooks 

type EpochingHooks interface {
	AfterEpochBegins(ctx sdk.Context, epoch uint64)            // Must be called after an epoch begins
	AfterEpochEnds(ctx sdk.Context, epoch uint64)              // Must be called after an epoch ends
	BeforeSlashThreshold(ctx sdk.Context, valSet ValidatorSet) // Must be called before a certain threshold (1/3 or 2/3) of validators are slashed in a single epoch
}

EpochingHooks event hooks for epoching validator object (noalias)

type EventBeginEpoch 

type EventBeginEpoch struct {
	EpochNumber uint64 `protobuf:"varint,1,opt,name=epoch_number,json=epochNumber,proto3" json:"epoch_number,omitempty"`
}

EventBeginEpoch is the event emitted when an epoch has started

func (*EventBeginEpoch) Descriptor 

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

func (*EventBeginEpoch) GetEpochNumber 

func (m *EventBeginEpoch) GetEpochNumber() uint64

func (*EventBeginEpoch) Marshal 

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

func (*EventBeginEpoch) MarshalTo 

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

func (*EventBeginEpoch) MarshalToSizedBuffer 

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

func (*EventBeginEpoch) ProtoMessage 

func (*EventBeginEpoch) ProtoMessage()

func (*EventBeginEpoch) Reset 

func (m *EventBeginEpoch) Reset()

func (*EventBeginEpoch) Size 

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

func (*EventBeginEpoch) String 

func (m *EventBeginEpoch) String() string

func (*EventBeginEpoch) Unmarshal 

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

func (*EventBeginEpoch) XXX_DiscardUnknown 

func (m *EventBeginEpoch) XXX_DiscardUnknown()

func (*EventBeginEpoch) XXX_Marshal 

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

func (*EventBeginEpoch) XXX_Merge 

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

func (*EventBeginEpoch) XXX_Size 

func (m *EventBeginEpoch) XXX_Size() int

func (*EventBeginEpoch) XXX_Unmarshal 

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

type EventEndEpoch 

type EventEndEpoch struct {
	EpochNumber uint64 `protobuf:"varint,1,opt,name=epoch_number,json=epochNumber,proto3" json:"epoch_number,omitempty"`
}

EventEndEpoch is the event emitted when an epoch has ended

func (*EventEndEpoch) Descriptor 

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

func (*EventEndEpoch) GetEpochNumber 

func (m *EventEndEpoch) GetEpochNumber() uint64

func (*EventEndEpoch) Marshal 

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

func (*EventEndEpoch) MarshalTo 

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

func (*EventEndEpoch) MarshalToSizedBuffer 

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

func (*EventEndEpoch) ProtoMessage 

func (*EventEndEpoch) ProtoMessage()

func (*EventEndEpoch) Reset 

func (m *EventEndEpoch) Reset()

func (*EventEndEpoch) Size 

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

func (*EventEndEpoch) String 

func (m *EventEndEpoch) String() string

func (*EventEndEpoch) Unmarshal 

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

func (*EventEndEpoch) XXX_DiscardUnknown 

func (m *EventEndEpoch) XXX_DiscardUnknown()

func (*EventEndEpoch) XXX_Marshal 

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

func (*EventEndEpoch) XXX_Merge 

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

func (*EventEndEpoch) XXX_Size 

func (m *EventEndEpoch) XXX_Size() int

func (*EventEndEpoch) XXX_Unmarshal 

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

type EventHandleQueuedMsg 

type EventHandleQueuedMsg struct {
	OriginalEventType  string                                                   `protobuf:"bytes,1,opt,name=original_event_type,json=originalEventType,proto3" json:"original_event_type,omitempty"`
	EpochNumber        uint64                                                   `protobuf:"varint,2,opt,name=epoch_number,json=epochNumber,proto3" json:"epoch_number,omitempty"`
	Height             uint64                                                   `protobuf:"varint,3,opt,name=height,proto3" json:"height,omitempty"`
	TxId               []byte                                                   `protobuf:"bytes,4,opt,name=tx_id,json=txId,proto3" json:"tx_id,omitempty"`
	MsgId              []byte                                                   `protobuf:"bytes,5,opt,name=msg_id,json=msgId,proto3" json:"msg_id,omitempty"`
	OriginalAttributes []github_com_cometbft_cometbft_abci_types.EventAttribute `` /* 181-byte string literal not displayed */
	Error              string                                                   `protobuf:"bytes,7,opt,name=error,proto3" json:"error,omitempty"`
}

EventHandleQueuedMsg is the event emitted when a queued message has been handled

func (*EventHandleQueuedMsg) Descriptor 

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

func (*EventHandleQueuedMsg) GetEpochNumber 

func (m *EventHandleQueuedMsg) GetEpochNumber() uint64

func (*EventHandleQueuedMsg) GetError 

func (m *EventHandleQueuedMsg) GetError() string

func (*EventHandleQueuedMsg) GetHeight 

func (m *EventHandleQueuedMsg) GetHeight() uint64

func (*EventHandleQueuedMsg) GetMsgId 

func (m *EventHandleQueuedMsg) GetMsgId() []byte

func (*EventHandleQueuedMsg) GetOriginalEventType 

func (m *EventHandleQueuedMsg) GetOriginalEventType() string

func (*EventHandleQueuedMsg) GetTxId 

func (m *EventHandleQueuedMsg) GetTxId() []byte

func (*EventHandleQueuedMsg) Marshal 

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

func (*EventHandleQueuedMsg) MarshalTo 

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

func (*EventHandleQueuedMsg) MarshalToSizedBuffer 

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

func (*EventHandleQueuedMsg) ProtoMessage 

func (*EventHandleQueuedMsg) ProtoMessage()

func (*EventHandleQueuedMsg) Reset 

func (m *EventHandleQueuedMsg) Reset()

func (*EventHandleQueuedMsg) Size 

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

func (*EventHandleQueuedMsg) String 

func (m *EventHandleQueuedMsg) String() string

func (*EventHandleQueuedMsg) Unmarshal 

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

func (*EventHandleQueuedMsg) XXX_DiscardUnknown 

func (m *EventHandleQueuedMsg) XXX_DiscardUnknown()

func (*EventHandleQueuedMsg) XXX_Marshal 

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

func (*EventHandleQueuedMsg) XXX_Merge 

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

func (*EventHandleQueuedMsg) XXX_Size 

func (m *EventHandleQueuedMsg) XXX_Size() int

func (*EventHandleQueuedMsg) XXX_Unmarshal 

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

type EventSlashThreshold 

type EventSlashThreshold struct {
	SlashedVotingPower int64    `protobuf:"varint,1,opt,name=slashed_voting_power,json=slashedVotingPower,proto3" json:"slashed_voting_power,omitempty"`
	TotalVotingPower   int64    `protobuf:"varint,2,opt,name=total_voting_power,json=totalVotingPower,proto3" json:"total_voting_power,omitempty"`
	SlashedValidators  [][]byte `protobuf:"bytes,3,rep,name=slashed_validators,json=slashedValidators,proto3" json:"slashed_validators,omitempty"`
}

EventSlashThreshold is the event emitted when a set of validators have been slashed

func NewEventSlashThreshold 

func NewEventSlashThreshold(slashedVotingPower int64, totalVotingPower int64, slashedValSet ValidatorSet) EventSlashThreshold

func (*EventSlashThreshold) Descriptor 

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

func (*EventSlashThreshold) GetSlashedValidators 

func (m *EventSlashThreshold) GetSlashedValidators() [][]byte

func (*EventSlashThreshold) GetSlashedVotingPower 

func (m *EventSlashThreshold) GetSlashedVotingPower() int64

func (*EventSlashThreshold) GetTotalVotingPower 

func (m *EventSlashThreshold) GetTotalVotingPower() int64

func (*EventSlashThreshold) Marshal 

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

func (*EventSlashThreshold) MarshalTo 

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

func (*EventSlashThreshold) MarshalToSizedBuffer 

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

func (*EventSlashThreshold) ProtoMessage 

func (*EventSlashThreshold) ProtoMessage()

func (*EventSlashThreshold) Reset 

func (m *EventSlashThreshold) Reset()

func (*EventSlashThreshold) Size 

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

func (*EventSlashThreshold) String 

func (m *EventSlashThreshold) String() string

func (*EventSlashThreshold) Unmarshal 

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

func (*EventSlashThreshold) XXX_DiscardUnknown 

func (m *EventSlashThreshold) XXX_DiscardUnknown()

func (*EventSlashThreshold) XXX_Marshal 

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

func (*EventSlashThreshold) XXX_Merge 

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

func (*EventSlashThreshold) XXX_Size 

func (m *EventSlashThreshold) XXX_Size() int

func (*EventSlashThreshold) XXX_Unmarshal 

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

type EventWrappedBeginRedelegate 

type EventWrappedBeginRedelegate struct {
	DelegatorAddress            string `protobuf:"bytes,1,opt,name=delegator_address,json=delegatorAddress,proto3" json:"delegator_address,omitempty"`
	SourceValidatorAddress      string `` /* 129-byte string literal not displayed */
	DestinationValidatorAddress string `` /* 144-byte string literal not displayed */
	Amount                      uint64 `protobuf:"varint,4,opt,name=amount,proto3" json:"amount,omitempty"`
	Denom                       string `protobuf:"bytes,5,opt,name=denom,proto3" json:"denom,omitempty"`
	EpochBoundary               uint64 `protobuf:"varint,6,opt,name=epoch_boundary,json=epochBoundary,proto3" json:"epoch_boundary,omitempty"`
}

EventWrappedBeginRedelegate is the event emitted when a MsgWrappedBeginRedelegate has been queued

func (*EventWrappedBeginRedelegate) Descriptor 

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

func (*EventWrappedBeginRedelegate) GetAmount 

func (m *EventWrappedBeginRedelegate) GetAmount() uint64

func (*EventWrappedBeginRedelegate) GetDelegatorAddress 

func (m *EventWrappedBeginRedelegate) GetDelegatorAddress() string

func (*EventWrappedBeginRedelegate) GetDenom 

func (m *EventWrappedBeginRedelegate) GetDenom() string

func (*EventWrappedBeginRedelegate) GetDestinationValidatorAddress 

func (m *EventWrappedBeginRedelegate) GetDestinationValidatorAddress() string

func (*EventWrappedBeginRedelegate) GetEpochBoundary 

func (m *EventWrappedBeginRedelegate) GetEpochBoundary() uint64

func (*EventWrappedBeginRedelegate) GetSourceValidatorAddress 

func (m *EventWrappedBeginRedelegate) GetSourceValidatorAddress() string

func (*EventWrappedBeginRedelegate) Marshal 

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

func (*EventWrappedBeginRedelegate) MarshalTo 

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

func (*EventWrappedBeginRedelegate) MarshalToSizedBuffer 

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

func (*EventWrappedBeginRedelegate) ProtoMessage 

func (*EventWrappedBeginRedelegate) ProtoMessage()

func (*EventWrappedBeginRedelegate) Reset 

func (m *EventWrappedBeginRedelegate) Reset()

func (*EventWrappedBeginRedelegate) Size 

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

func (*EventWrappedBeginRedelegate) String 

func (m *EventWrappedBeginRedelegate) String() string

func (*EventWrappedBeginRedelegate) Unmarshal 

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

func (*EventWrappedBeginRedelegate) XXX_DiscardUnknown 

func (m *EventWrappedBeginRedelegate) XXX_DiscardUnknown()

func (*EventWrappedBeginRedelegate) XXX_Marshal 

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

func (*EventWrappedBeginRedelegate) XXX_Merge 

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

func (*EventWrappedBeginRedelegate) XXX_Size 

func (m *EventWrappedBeginRedelegate) XXX_Size() int

func (*EventWrappedBeginRedelegate) XXX_Unmarshal 

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

type EventWrappedDelegate 

type EventWrappedDelegate struct {
	DelegatorAddress string `protobuf:"bytes,1,opt,name=delegator_address,json=delegatorAddress,proto3" json:"delegator_address,omitempty"`
	ValidatorAddress string `protobuf:"bytes,2,opt,name=validator_address,json=validatorAddress,proto3" json:"validator_address,omitempty"`
	Amount           uint64 `protobuf:"varint,3,opt,name=amount,proto3" json:"amount,omitempty"`
	Denom            string `protobuf:"bytes,4,opt,name=denom,proto3" json:"denom,omitempty"`
	EpochBoundary    uint64 `protobuf:"varint,5,opt,name=epoch_boundary,json=epochBoundary,proto3" json:"epoch_boundary,omitempty"`
}

EventWrappedDelegate is the event emitted when a MsgWrappedDelegate has been queued

func (*EventWrappedDelegate) Descriptor 

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

func (*EventWrappedDelegate) GetAmount 

func (m *EventWrappedDelegate) GetAmount() uint64

func (*EventWrappedDelegate) GetDelegatorAddress 

func (m *EventWrappedDelegate) GetDelegatorAddress() string

func (*EventWrappedDelegate) GetDenom 

func (m *EventWrappedDelegate) GetDenom() string

func (*EventWrappedDelegate) GetEpochBoundary 

func (m *EventWrappedDelegate) GetEpochBoundary() uint64

func (*EventWrappedDelegate) GetValidatorAddress 

func (m *EventWrappedDelegate) GetValidatorAddress() string

func (*EventWrappedDelegate) Marshal 

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

func (*EventWrappedDelegate) MarshalTo 

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

func (*EventWrappedDelegate) MarshalToSizedBuffer 

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

func (*EventWrappedDelegate) ProtoMessage 

func (*EventWrappedDelegate) ProtoMessage()

func (*EventWrappedDelegate) Reset 

func (m *EventWrappedDelegate) Reset()

func (*EventWrappedDelegate) Size 

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

func (*EventWrappedDelegate) String 

func (m *EventWrappedDelegate) String() string

func (*EventWrappedDelegate) Unmarshal 

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

func (*EventWrappedDelegate) XXX_DiscardUnknown 

func (m *EventWrappedDelegate) XXX_DiscardUnknown()

func (*EventWrappedDelegate) XXX_Marshal 

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

func (*EventWrappedDelegate) XXX_Merge 

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

func (*EventWrappedDelegate) XXX_Size 

func (m *EventWrappedDelegate) XXX_Size() int

func (*EventWrappedDelegate) XXX_Unmarshal 

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

type EventWrappedUndelegate 

type EventWrappedUndelegate struct {
	DelegatorAddress string `protobuf:"bytes,1,opt,name=delegator_address,json=delegatorAddress,proto3" json:"delegator_address,omitempty"`
	ValidatorAddress string `protobuf:"bytes,2,opt,name=validator_address,json=validatorAddress,proto3" json:"validator_address,omitempty"`
	Amount           uint64 `protobuf:"varint,3,opt,name=amount,proto3" json:"amount,omitempty"`
	Denom            string `protobuf:"bytes,4,opt,name=denom,proto3" json:"denom,omitempty"`
	EpochBoundary    uint64 `protobuf:"varint,5,opt,name=epoch_boundary,json=epochBoundary,proto3" json:"epoch_boundary,omitempty"`
}

EventWrappedUndelegate is the event emitted when a MsgWrappedUndelegate has been queued

func (*EventWrappedUndelegate) Descriptor 

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

func (*EventWrappedUndelegate) GetAmount 

func (m *EventWrappedUndelegate) GetAmount() uint64

func (*EventWrappedUndelegate) GetDelegatorAddress 

func (m *EventWrappedUndelegate) GetDelegatorAddress() string

func (*EventWrappedUndelegate) GetDenom 

func (m *EventWrappedUndelegate) GetDenom() string

func (*EventWrappedUndelegate) GetEpochBoundary 

func (m *EventWrappedUndelegate) GetEpochBoundary() uint64

func (*EventWrappedUndelegate) GetValidatorAddress 

func (m *EventWrappedUndelegate) GetValidatorAddress() string

func (*EventWrappedUndelegate) Marshal 

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

func (*EventWrappedUndelegate) MarshalTo 

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

func (*EventWrappedUndelegate) MarshalToSizedBuffer 

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

func (*EventWrappedUndelegate) ProtoMessage 

func (*EventWrappedUndelegate) ProtoMessage()

func (*EventWrappedUndelegate) Reset 

func (m *EventWrappedUndelegate) Reset()

func (*EventWrappedUndelegate) Size 

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

func (*EventWrappedUndelegate) String 

func (m *EventWrappedUndelegate) String() string

func (*EventWrappedUndelegate) Unmarshal 

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

func (*EventWrappedUndelegate) XXX_DiscardUnknown 

func (m *EventWrappedUndelegate) XXX_DiscardUnknown()

func (*EventWrappedUndelegate) XXX_Marshal 

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

func (*EventWrappedUndelegate) XXX_Merge 

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

func (*EventWrappedUndelegate) XXX_Size 

func (m *EventWrappedUndelegate) XXX_Size() int

func (*EventWrappedUndelegate) XXX_Unmarshal 

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

type GenesisState 

type GenesisState struct {
	Params Params `protobuf:"bytes,1,opt,name=params,proto3" json:"params"`
}

GenesisState defines the epoching module's genesis state.

func DefaultGenesis 

func DefaultGenesis() *GenesisState

DefaultGenesis returns the default Capability genesis state

func NewGenesis 

func NewGenesis(params Params) *GenesisState

NewGenesis creates a new GenesisState instance

func (*GenesisState) Descriptor 

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

func (*GenesisState) GetParams 

func (m *GenesisState) GetParams() Params

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 

func (gs GenesisState) Validate() error

Validate performs basic genesis state validation returning an error upon any failure.

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 MsgClient 

type MsgClient interface {
	// WrappedDelegate defines a method for performing a delegation of coins from
	// a delegator to a validator.
	WrappedDelegate(ctx context.Context, in *MsgWrappedDelegate, opts ...grpc.CallOption) (*MsgWrappedDelegateResponse, error)
	// WrappedUndelegate defines a method for performing an undelegation from a
	// delegate and a validator.
	WrappedUndelegate(ctx context.Context, in *MsgWrappedUndelegate, opts ...grpc.CallOption) (*MsgWrappedUndelegateResponse, error)
	// WrappedBeginRedelegate defines a method for performing a redelegation of
	// coins from a delegator and source validator to a destination validator.
	WrappedBeginRedelegate(ctx context.Context, in *MsgWrappedBeginRedelegate, opts ...grpc.CallOption) (*MsgWrappedBeginRedelegateResponse, error)
	// UpdateParams defines a method for updating epoching module parameters.
	UpdateParams(ctx context.Context, in *MsgUpdateParams, opts ...grpc.CallOption) (*MsgUpdateParamsResponse, 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 {
	// WrappedDelegate defines a method for performing a delegation of coins from
	// a delegator to a validator.
	WrappedDelegate(context.Context, *MsgWrappedDelegate) (*MsgWrappedDelegateResponse, error)
	// WrappedUndelegate defines a method for performing an undelegation from a
	// delegate and a validator.
	WrappedUndelegate(context.Context, *MsgWrappedUndelegate) (*MsgWrappedUndelegateResponse, error)
	// WrappedBeginRedelegate defines a method for performing a redelegation of
	// coins from a delegator and source validator to a destination validator.
	WrappedBeginRedelegate(context.Context, *MsgWrappedBeginRedelegate) (*MsgWrappedBeginRedelegateResponse, error)
	// UpdateParams defines a method for updating epoching module parameters.
	UpdateParams(context.Context, *MsgUpdateParams) (*MsgUpdateParamsResponse, error)
}

MsgServer is the server API for Msg service.

type MsgUpdateParams added in v0.6.0 

type MsgUpdateParams struct {
	// authority is the address of the governance account.
	// just FYI: cosmos.AddressString marks that this field should use type alias
	// for AddressString instead of string, but the functionality is not yet implemented
	// in cosmos-proto
	Authority string `protobuf:"bytes,1,opt,name=authority,proto3" json:"authority,omitempty"`
	// params defines the epoching paramaeters parameters to update.
	//
	// NOTE: All parameters must be supplied.
	Params Params `protobuf:"bytes,2,opt,name=params,proto3" json:"params"`
}

MsgUpdateParams defines a message for updating epoching module parameters.

func (*MsgUpdateParams) Descriptor added in v0.6.0 

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

func (*MsgUpdateParams) GetAuthority added in v0.6.0 

func (m *MsgUpdateParams) GetAuthority() string

func (*MsgUpdateParams) GetParams added in v0.6.0 

func (m *MsgUpdateParams) GetParams() Params

func (*MsgUpdateParams) GetSigners added in v0.6.0 

func (m *MsgUpdateParams) GetSigners() []sdk.AccAddress

GetSigners returns the expected signers for a MsgUpdateParams message.

func (*MsgUpdateParams) Marshal added in v0.6.0 

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

func (*MsgUpdateParams) MarshalTo added in v0.6.0 

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

func (*MsgUpdateParams) MarshalToSizedBuffer added in v0.6.0 

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

func (*MsgUpdateParams) ProtoMessage added in v0.6.0 

func (*MsgUpdateParams) ProtoMessage()

func (*MsgUpdateParams) Reset added in v0.6.0 

func (m *MsgUpdateParams) Reset()

func (*MsgUpdateParams) Size added in v0.6.0 

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

func (*MsgUpdateParams) String added in v0.6.0 

func (m *MsgUpdateParams) String() string

func (*MsgUpdateParams) Unmarshal added in v0.6.0 

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

func (*MsgUpdateParams) ValidateBasic added in v0.6.0 

func (m *MsgUpdateParams) ValidateBasic() error

ValidateBasic does a sanity check on the provided data.

func (*MsgUpdateParams) XXX_DiscardUnknown added in v0.6.0 

func (m *MsgUpdateParams) XXX_DiscardUnknown()

func (*MsgUpdateParams) XXX_Marshal added in v0.6.0 

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

func (*MsgUpdateParams) XXX_Merge added in v0.6.0 

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

func (*MsgUpdateParams) XXX_Size added in v0.6.0 

func (m *MsgUpdateParams) XXX_Size() int

func (*MsgUpdateParams) XXX_Unmarshal added in v0.6.0 

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

type MsgUpdateParamsResponse added in v0.6.0 

type MsgUpdateParamsResponse struct {
}

MsgUpdateParamsResponse is the response to the MsgUpdateParams message.

func (*MsgUpdateParamsResponse) Descriptor added in v0.6.0 

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

func (*MsgUpdateParamsResponse) Marshal added in v0.6.0 

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

func (*MsgUpdateParamsResponse) MarshalTo added in v0.6.0 

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

func (*MsgUpdateParamsResponse) MarshalToSizedBuffer added in v0.6.0 

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

func (*MsgUpdateParamsResponse) ProtoMessage added in v0.6.0 

func (*MsgUpdateParamsResponse) ProtoMessage()

func (*MsgUpdateParamsResponse) Reset added in v0.6.0 

func (m *MsgUpdateParamsResponse) Reset()

func (*MsgUpdateParamsResponse) Size added in v0.6.0 

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

func (*MsgUpdateParamsResponse) String added in v0.6.0 

func (m *MsgUpdateParamsResponse) String() string

func (*MsgUpdateParamsResponse) Unmarshal added in v0.6.0 

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

func (*MsgUpdateParamsResponse) XXX_DiscardUnknown added in v0.6.0 

func (m *MsgUpdateParamsResponse) XXX_DiscardUnknown()

func (*MsgUpdateParamsResponse) XXX_Marshal added in v0.6.0 

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

func (*MsgUpdateParamsResponse) XXX_Merge added in v0.6.0 

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

func (*MsgUpdateParamsResponse) XXX_Size added in v0.6.0 

func (m *MsgUpdateParamsResponse) XXX_Size() int

func (*MsgUpdateParamsResponse) XXX_Unmarshal added in v0.6.0 

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

type MsgWrappedBeginRedelegate 

type MsgWrappedBeginRedelegate struct {
	Msg *types.MsgBeginRedelegate `protobuf:"bytes,1,opt,name=msg,proto3" json:"msg,omitempty"`
}

MsgWrappedDelegate is the message for moving bonded stakes from a validator to another validator

func NewMsgWrappedBeginRedelegate 

func NewMsgWrappedBeginRedelegate(msg *stakingtypes.MsgBeginRedelegate) *MsgWrappedBeginRedelegate

NewMsgWrappedBeginRedelegate creates a new MsgWrappedBeginRedelegate instance.

func (*MsgWrappedBeginRedelegate) Descriptor 

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

func (MsgWrappedBeginRedelegate) GetSignBytes 

func (msg MsgWrappedBeginRedelegate) GetSignBytes() []byte

GetSignBytes returns the message bytes to sign over.

func (MsgWrappedBeginRedelegate) GetSigners 

func (msg MsgWrappedBeginRedelegate) GetSigners() []sdk.AccAddress

GetSigners implements the sdk.Msg interface. It returns the address(es) that must sign over msg.GetSignBytes(). If the validator address is not same as delegator's, then the validator must sign the msg as well.

func (*MsgWrappedBeginRedelegate) Marshal 

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

func (*MsgWrappedBeginRedelegate) MarshalTo 

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

func (*MsgWrappedBeginRedelegate) MarshalToSizedBuffer 

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

func (*MsgWrappedBeginRedelegate) ProtoMessage 

func (*MsgWrappedBeginRedelegate) ProtoMessage()

func (*MsgWrappedBeginRedelegate) Reset 

func (m *MsgWrappedBeginRedelegate) Reset()

func (MsgWrappedBeginRedelegate) Route 

func (msg MsgWrappedBeginRedelegate) Route() string

Route implements the sdk.Msg interface.

func (*MsgWrappedBeginRedelegate) Size 

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

func (*MsgWrappedBeginRedelegate) String 

func (m *MsgWrappedBeginRedelegate) String() string

func (MsgWrappedBeginRedelegate) Type 

func (msg MsgWrappedBeginRedelegate) Type() string

Type implements the sdk.Msg interface.

func (*MsgWrappedBeginRedelegate) Unmarshal 

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

func (MsgWrappedBeginRedelegate) ValidateBasic 

func (msg MsgWrappedBeginRedelegate) ValidateBasic() error

ValidateBasic implements the sdk.Msg interface.

func (*MsgWrappedBeginRedelegate) XXX_DiscardUnknown 

func (m *MsgWrappedBeginRedelegate) XXX_DiscardUnknown()

func (*MsgWrappedBeginRedelegate) XXX_Marshal 

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

func (*MsgWrappedBeginRedelegate) XXX_Merge 

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

func (*MsgWrappedBeginRedelegate) XXX_Size 

func (m *MsgWrappedBeginRedelegate) XXX_Size() int

func (*MsgWrappedBeginRedelegate) XXX_Unmarshal 

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

type MsgWrappedBeginRedelegateResponse 

type MsgWrappedBeginRedelegateResponse struct {
}

MsgWrappedBeginRedelegateResponse is the response to the MsgWrappedBeginRedelegate message

func (*MsgWrappedBeginRedelegateResponse) Descriptor 

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

func (*MsgWrappedBeginRedelegateResponse) Marshal 

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

func (*MsgWrappedBeginRedelegateResponse) MarshalTo 

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

func (*MsgWrappedBeginRedelegateResponse) MarshalToSizedBuffer 

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

func (*MsgWrappedBeginRedelegateResponse) ProtoMessage 

func (*MsgWrappedBeginRedelegateResponse) ProtoMessage()

func (*MsgWrappedBeginRedelegateResponse) Reset 

func (m *MsgWrappedBeginRedelegateResponse) Reset()

func (*MsgWrappedBeginRedelegateResponse) Size 

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

func (*MsgWrappedBeginRedelegateResponse) String 

func (m *MsgWrappedBeginRedelegateResponse) String() string

func (*MsgWrappedBeginRedelegateResponse) Unmarshal 

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

func (*MsgWrappedBeginRedelegateResponse) XXX_DiscardUnknown 

func (m *MsgWrappedBeginRedelegateResponse) XXX_DiscardUnknown()

func (*MsgWrappedBeginRedelegateResponse) XXX_Marshal 

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

func (*MsgWrappedBeginRedelegateResponse) XXX_Merge 

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

func (*MsgWrappedBeginRedelegateResponse) XXX_Size 

func (m *MsgWrappedBeginRedelegateResponse) XXX_Size() int

func (*MsgWrappedBeginRedelegateResponse) XXX_Unmarshal 

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

type MsgWrappedDelegate 

type MsgWrappedDelegate struct {
	Msg *types.MsgDelegate `protobuf:"bytes,1,opt,name=msg,proto3" json:"msg,omitempty"`
}

MsgWrappedDelegate is the message for delegating stakes

func NewMsgWrappedDelegate 

func NewMsgWrappedDelegate(msg *stakingtypes.MsgDelegate) *MsgWrappedDelegate

NewMsgWrappedDelegate creates a new MsgWrappedDelegate instance.

func (*MsgWrappedDelegate) Descriptor 

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

func (MsgWrappedDelegate) GetSignBytes 

func (msg MsgWrappedDelegate) GetSignBytes() []byte

GetSignBytes returns the message bytes to sign over.

func (MsgWrappedDelegate) GetSigners 

func (msg MsgWrappedDelegate) GetSigners() []sdk.AccAddress

GetSigners implements the sdk.Msg interface. It returns the address(es) that must sign over msg.GetSignBytes(). If the validator address is not same as delegator's, then the validator must sign the msg as well.

func (*MsgWrappedDelegate) Marshal 

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

func (*MsgWrappedDelegate) MarshalTo 

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

func (*MsgWrappedDelegate) MarshalToSizedBuffer 

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

func (*MsgWrappedDelegate) ProtoMessage 

func (*MsgWrappedDelegate) ProtoMessage()

func (*MsgWrappedDelegate) Reset 

func (m *MsgWrappedDelegate) Reset()

func (MsgWrappedDelegate) Route 

func (msg MsgWrappedDelegate) Route() string

Route implements the sdk.Msg interface.

func (*MsgWrappedDelegate) Size 

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

func (*MsgWrappedDelegate) String 

func (m *MsgWrappedDelegate) String() string

func (MsgWrappedDelegate) Type 

func (msg MsgWrappedDelegate) Type() string

Type implements the sdk.Msg interface.

func (*MsgWrappedDelegate) Unmarshal 

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

func (MsgWrappedDelegate) ValidateBasic 

func (msg MsgWrappedDelegate) ValidateBasic() error

ValidateBasic implements the sdk.Msg interface.

func (*MsgWrappedDelegate) XXX_DiscardUnknown 

func (m *MsgWrappedDelegate) XXX_DiscardUnknown()

func (*MsgWrappedDelegate) XXX_Marshal 

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

func (*MsgWrappedDelegate) XXX_Merge 

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

func (*MsgWrappedDelegate) XXX_Size 

func (m *MsgWrappedDelegate) XXX_Size() int

func (*MsgWrappedDelegate) XXX_Unmarshal 

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

type MsgWrappedDelegateResponse 

type MsgWrappedDelegateResponse struct {
}

MsgWrappedDelegate is the response to the MsgWrappedDelegate message

func (*MsgWrappedDelegateResponse) Descriptor 

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

func (*MsgWrappedDelegateResponse) Marshal 

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

func (*MsgWrappedDelegateResponse) MarshalTo 

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

func (*MsgWrappedDelegateResponse) MarshalToSizedBuffer 

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

func (*MsgWrappedDelegateResponse) ProtoMessage 

func (*MsgWrappedDelegateResponse) ProtoMessage()

func (*MsgWrappedDelegateResponse) Reset 

func (m *MsgWrappedDelegateResponse) Reset()

func (*MsgWrappedDelegateResponse) Size 

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

func (*MsgWrappedDelegateResponse) String 

func (m *MsgWrappedDelegateResponse) String() string

func (*MsgWrappedDelegateResponse) Unmarshal 

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

func (*MsgWrappedDelegateResponse) XXX_DiscardUnknown 

func (m *MsgWrappedDelegateResponse) XXX_DiscardUnknown()

func (*MsgWrappedDelegateResponse) XXX_Marshal 

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

func (*MsgWrappedDelegateResponse) XXX_Merge 

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

func (*MsgWrappedDelegateResponse) XXX_Size 

func (m *MsgWrappedDelegateResponse) XXX_Size() int

func (*MsgWrappedDelegateResponse) XXX_Unmarshal 

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

type MsgWrappedUndelegate 

type MsgWrappedUndelegate struct {
	Msg *types.MsgUndelegate `protobuf:"bytes,1,opt,name=msg,proto3" json:"msg,omitempty"`
}

MsgWrappedUndelegate is the message for undelegating stakes

func NewMsgWrappedUndelegate 

func NewMsgWrappedUndelegate(msg *stakingtypes.MsgUndelegate) *MsgWrappedUndelegate

NewMsgWrappedUndelegate creates a new MsgWrappedUndelegate instance.

func (*MsgWrappedUndelegate) Descriptor 

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

func (MsgWrappedUndelegate) GetSignBytes 

func (msg MsgWrappedUndelegate) GetSignBytes() []byte

GetSignBytes returns the message bytes to sign over.

func (MsgWrappedUndelegate) GetSigners 

func (msg MsgWrappedUndelegate) GetSigners() []sdk.AccAddress

GetSigners implements the sdk.Msg interface. It returns the address(es) that must sign over msg.GetSignBytes(). If the validator address is not same as delegator's, then the validator must sign the msg as well.

func (*MsgWrappedUndelegate) Marshal 

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

func (*MsgWrappedUndelegate) MarshalTo 

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

func (*MsgWrappedUndelegate) MarshalToSizedBuffer 

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

func (*MsgWrappedUndelegate) ProtoMessage 

func (*MsgWrappedUndelegate) ProtoMessage()

func (*MsgWrappedUndelegate) Reset 

func (m *MsgWrappedUndelegate) Reset()

func (MsgWrappedUndelegate) Route 

func (msg MsgWrappedUndelegate) Route() string

Route implements the sdk.Msg interface.

func (*MsgWrappedUndelegate) Size 

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

func (*MsgWrappedUndelegate) String 

func (m *MsgWrappedUndelegate) String() string

func (MsgWrappedUndelegate) Type 

func (msg MsgWrappedUndelegate) Type() string

Type implements the sdk.Msg interface.

func (*MsgWrappedUndelegate) Unmarshal 

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

func (MsgWrappedUndelegate) ValidateBasic 

func (msg MsgWrappedUndelegate) ValidateBasic() error

ValidateBasic implements the sdk.Msg interface.

func (*MsgWrappedUndelegate) XXX_DiscardUnknown 

func (m *MsgWrappedUndelegate) XXX_DiscardUnknown()

func (*MsgWrappedUndelegate) XXX_Marshal 

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

func (*MsgWrappedUndelegate) XXX_Merge 

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

func (*MsgWrappedUndelegate) XXX_Size 

func (m *MsgWrappedUndelegate) XXX_Size() int

func (*MsgWrappedUndelegate) XXX_Unmarshal 

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

type MsgWrappedUndelegateResponse 

type MsgWrappedUndelegateResponse struct {
}

MsgWrappedUndelegateResponse is the response to the MsgWrappedUndelegate message

func (*MsgWrappedUndelegateResponse) Descriptor 

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

func (*MsgWrappedUndelegateResponse) Marshal 

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

func (*MsgWrappedUndelegateResponse) MarshalTo 

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

func (*MsgWrappedUndelegateResponse) MarshalToSizedBuffer 

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

func (*MsgWrappedUndelegateResponse) ProtoMessage 

func (*MsgWrappedUndelegateResponse) ProtoMessage()

func (*MsgWrappedUndelegateResponse) Reset 

func (m *MsgWrappedUndelegateResponse) Reset()

func (*MsgWrappedUndelegateResponse) Size 

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

func (*MsgWrappedUndelegateResponse) String 

func (m *MsgWrappedUndelegateResponse) String() string

func (*MsgWrappedUndelegateResponse) Unmarshal 

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

func (*MsgWrappedUndelegateResponse) XXX_DiscardUnknown 

func (m *MsgWrappedUndelegateResponse) XXX_DiscardUnknown()

func (*MsgWrappedUndelegateResponse) XXX_Marshal 

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

func (*MsgWrappedUndelegateResponse) XXX_Merge 

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

func (*MsgWrappedUndelegateResponse) XXX_Size 

func (m *MsgWrappedUndelegateResponse) XXX_Size() int

func (*MsgWrappedUndelegateResponse) XXX_Unmarshal 

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

type MultiEpochingHooks 

type MultiEpochingHooks []EpochingHooks

func NewMultiEpochingHooks 

func NewMultiEpochingHooks(hooks ...EpochingHooks) MultiEpochingHooks

func (MultiEpochingHooks) AfterEpochBegins 

func (h MultiEpochingHooks) AfterEpochBegins(ctx sdk.Context, epoch uint64)

func (MultiEpochingHooks) AfterEpochEnds 

func (h MultiEpochingHooks) AfterEpochEnds(ctx sdk.Context, epoch uint64)

func (MultiEpochingHooks) BeforeSlashThreshold 

func (h MultiEpochingHooks) BeforeSlashThreshold(ctx sdk.Context, valSet ValidatorSet)

type Params 

type Params struct {
	// epoch_interval is the number of consecutive blocks to form an epoch
	EpochInterval uint64 `protobuf:"varint,1,opt,name=epoch_interval,json=epochInterval,proto3" json:"epoch_interval,omitempty" yaml:"epoch_interval"`
}

Params defines the parameters for the module.

func DefaultParams 

func DefaultParams() Params

DefaultParams returns a default set of parameters

func NewParams 

func NewParams(epochInterval uint64) Params

NewParams creates a new Params instance

func (*Params) Descriptor 

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

func (*Params) Equal 

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

func (*Params) GetEpochInterval 

func (m *Params) GetEpochInterval() uint64

func (*Params) Marshal 

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

func (*Params) MarshalTo 

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

func (*Params) MarshalToSizedBuffer 

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

func (*Params) ProtoMessage 

func (*Params) ProtoMessage()

func (*Params) Reset 

func (m *Params) Reset()

func (*Params) Size 

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

func (*Params) String 

func (m *Params) String() string

func (*Params) Unmarshal 

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

func (Params) Validate 

func (p Params) Validate() error

Validate validates the set of params

func (*Params) XXX_DiscardUnknown 

func (m *Params) XXX_DiscardUnknown()

func (*Params) XXX_Marshal 

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

func (*Params) XXX_Merge 

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

func (*Params) XXX_Size 

func (m *Params) XXX_Size() int

func (*Params) XXX_Unmarshal 

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

type QueryClient 

type QueryClient interface {
	// Params queries the parameters of the module.
	Params(ctx context.Context, in *QueryParamsRequest, opts ...grpc.CallOption) (*QueryParamsResponse, error)
	// EpochInfo queries the information of a given epoch
	EpochInfo(ctx context.Context, in *QueryEpochInfoRequest, opts ...grpc.CallOption) (*QueryEpochInfoResponse, error)
	// EpochsInfo queries the metadata of epochs in a given range, depending on
	// the parameters in the pagination request. Th main use case will be querying
	// the latest epochs in time order.
	EpochsInfo(ctx context.Context, in *QueryEpochsInfoRequest, opts ...grpc.CallOption) (*QueryEpochsInfoResponse, error)
	// CurrentEpoch queries the current epoch
	CurrentEpoch(ctx context.Context, in *QueryCurrentEpochRequest, opts ...grpc.CallOption) (*QueryCurrentEpochResponse, error)
	// EpochMsgs queries the messages of a given epoch
	EpochMsgs(ctx context.Context, in *QueryEpochMsgsRequest, opts ...grpc.CallOption) (*QueryEpochMsgsResponse, error)
	// LatestEpochMsgs queries the messages within a given number of most recent
	// epochs
	LatestEpochMsgs(ctx context.Context, in *QueryLatestEpochMsgsRequest, opts ...grpc.CallOption) (*QueryLatestEpochMsgsResponse, error)
	// ValidatorLifecycle queries the lifecycle of a given validator
	ValidatorLifecycle(ctx context.Context, in *QueryValidatorLifecycleRequest, opts ...grpc.CallOption) (*QueryValidatorLifecycleResponse, error)
	// DelegationLifecycle queries the lifecycle of a given delegation
	DelegationLifecycle(ctx context.Context, in *QueryDelegationLifecycleRequest, opts ...grpc.CallOption) (*QueryDelegationLifecycleResponse, error)
	// EpochValSet queries the validator set of a given epoch
	EpochValSet(ctx context.Context, in *QueryEpochValSetRequest, opts ...grpc.CallOption) (*QueryEpochValSetResponse, 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 QueryCurrentEpochRequest 

type QueryCurrentEpochRequest struct {
}

QueryCurrentEpochRequest is the request type for the Query/CurrentEpoch RPC method

func (*QueryCurrentEpochRequest) Descriptor 

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

func (*QueryCurrentEpochRequest) Marshal 

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

func (*QueryCurrentEpochRequest) MarshalTo 

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

func (*QueryCurrentEpochRequest) MarshalToSizedBuffer 

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

func (*QueryCurrentEpochRequest) ProtoMessage 

func (*QueryCurrentEpochRequest) ProtoMessage()

func (*QueryCurrentEpochRequest) Reset 

func (m *QueryCurrentEpochRequest) Reset()

func (*QueryCurrentEpochRequest) Size 

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

func (*QueryCurrentEpochRequest) String 

func (m *QueryCurrentEpochRequest) String() string

func (*QueryCurrentEpochRequest) Unmarshal 

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

func (*QueryCurrentEpochRequest) XXX_DiscardUnknown 

func (m *QueryCurrentEpochRequest) XXX_DiscardUnknown()

func (*QueryCurrentEpochRequest) XXX_Marshal 

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

func (*QueryCurrentEpochRequest) XXX_Merge 

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

func (*QueryCurrentEpochRequest) XXX_Size 

func (m *QueryCurrentEpochRequest) XXX_Size() int

func (*QueryCurrentEpochRequest) XXX_Unmarshal 

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

type QueryCurrentEpochResponse 

type QueryCurrentEpochResponse struct {
	// current_epoch is the current epoch number
	CurrentEpoch uint64 `protobuf:"varint,1,opt,name=current_epoch,json=currentEpoch,proto3" json:"current_epoch,omitempty"`
	// epoch_boundary is the height of this epoch's last block
	EpochBoundary uint64 `protobuf:"varint,2,opt,name=epoch_boundary,json=epochBoundary,proto3" json:"epoch_boundary,omitempty"`
}

QueryCurrentEpochResponse is the response type for the Query/CurrentEpoch RPC method

func (*QueryCurrentEpochResponse) Descriptor 

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

func (*QueryCurrentEpochResponse) GetCurrentEpoch 

func (m *QueryCurrentEpochResponse) GetCurrentEpoch() uint64

func (*QueryCurrentEpochResponse) GetEpochBoundary 

func (m *QueryCurrentEpochResponse) GetEpochBoundary() uint64

func (*QueryCurrentEpochResponse) Marshal 

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

func (*QueryCurrentEpochResponse) MarshalTo 

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

func (*QueryCurrentEpochResponse) MarshalToSizedBuffer 

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

func (*QueryCurrentEpochResponse) ProtoMessage 

func (*QueryCurrentEpochResponse) ProtoMessage()

func (*QueryCurrentEpochResponse) Reset 

func (m *QueryCurrentEpochResponse) Reset()

func (*QueryCurrentEpochResponse) Size 

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

func (*QueryCurrentEpochResponse) String 

func (m *QueryCurrentEpochResponse) String() string

func (*QueryCurrentEpochResponse) Unmarshal 

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

func (*QueryCurrentEpochResponse) XXX_DiscardUnknown 

func (m *QueryCurrentEpochResponse) XXX_DiscardUnknown()

func (*QueryCurrentEpochResponse) XXX_Marshal 

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

func (*QueryCurrentEpochResponse) XXX_Merge 

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

func (*QueryCurrentEpochResponse) XXX_Size 

func (m *QueryCurrentEpochResponse) XXX_Size() int

func (*QueryCurrentEpochResponse) XXX_Unmarshal 

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

type QueryDelegationLifecycleRequest 

type QueryDelegationLifecycleRequest struct {
	DelAddr string `protobuf:"bytes,1,opt,name=del_addr,json=delAddr,proto3" json:"del_addr,omitempty"`
}

QueryDelegationLifecycleRequest is the request type for the Query/DelegationLifecycle RPC method

func (*QueryDelegationLifecycleRequest) Descriptor 

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

func (*QueryDelegationLifecycleRequest) GetDelAddr 

func (m *QueryDelegationLifecycleRequest) GetDelAddr() string

func (*QueryDelegationLifecycleRequest) Marshal 

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

func (*QueryDelegationLifecycleRequest) MarshalTo 

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

func (*QueryDelegationLifecycleRequest) MarshalToSizedBuffer 

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

func (*QueryDelegationLifecycleRequest) ProtoMessage 

func (*QueryDelegationLifecycleRequest) ProtoMessage()

func (*QueryDelegationLifecycleRequest) Reset 

func (m *QueryDelegationLifecycleRequest) Reset()

func (*QueryDelegationLifecycleRequest) Size 

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

func (*QueryDelegationLifecycleRequest) String 

func (m *QueryDelegationLifecycleRequest) String() string

func (*QueryDelegationLifecycleRequest) Unmarshal 

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

func (*QueryDelegationLifecycleRequest) XXX_DiscardUnknown 

func (m *QueryDelegationLifecycleRequest) XXX_DiscardUnknown()

func (*QueryDelegationLifecycleRequest) XXX_Marshal 

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

func (*QueryDelegationLifecycleRequest) XXX_Merge 

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

func (*QueryDelegationLifecycleRequest) XXX_Size 

func (m *QueryDelegationLifecycleRequest) XXX_Size() int

func (*QueryDelegationLifecycleRequest) XXX_Unmarshal 

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

type QueryDelegationLifecycleResponse 

type QueryDelegationLifecycleResponse struct {
	DelLife *DelegationLifecycle `protobuf:"bytes,1,opt,name=del_life,json=delLife,proto3" json:"del_life,omitempty"`
}

QueryDelegationLifecycleRequest is the response type for the Query/DelegationLifecycle RPC method

func (*QueryDelegationLifecycleResponse) Descriptor 

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

func (*QueryDelegationLifecycleResponse) GetDelLife 

func (m *QueryDelegationLifecycleResponse) GetDelLife() *DelegationLifecycle

func (*QueryDelegationLifecycleResponse) Marshal 

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

func (*QueryDelegationLifecycleResponse) MarshalTo 

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

func (*QueryDelegationLifecycleResponse) MarshalToSizedBuffer 

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

func (*QueryDelegationLifecycleResponse) ProtoMessage 

func (*QueryDelegationLifecycleResponse) ProtoMessage()

func (*QueryDelegationLifecycleResponse) Reset 

func (m *QueryDelegationLifecycleResponse) Reset()

func (*QueryDelegationLifecycleResponse) Size 

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

func (*QueryDelegationLifecycleResponse) String 

func (m *QueryDelegationLifecycleResponse) String() string

func (*QueryDelegationLifecycleResponse) Unmarshal 

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

func (*QueryDelegationLifecycleResponse) XXX_DiscardUnknown 

func (m *QueryDelegationLifecycleResponse) XXX_DiscardUnknown()

func (*QueryDelegationLifecycleResponse) XXX_Marshal 

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

func (*QueryDelegationLifecycleResponse) XXX_Merge 

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

func (*QueryDelegationLifecycleResponse) XXX_Size 

func (m *QueryDelegationLifecycleResponse) XXX_Size() int

func (*QueryDelegationLifecycleResponse) XXX_Unmarshal 

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

type QueryEpochInfoRequest 

type QueryEpochInfoRequest struct {
	EpochNum uint64 `protobuf:"varint,1,opt,name=epoch_num,json=epochNum,proto3" json:"epoch_num,omitempty"`
}

QueryEpochInfoRequest is the request type for the Query/EpochInfo method

func (*QueryEpochInfoRequest) Descriptor 

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

func (*QueryEpochInfoRequest) GetEpochNum 

func (m *QueryEpochInfoRequest) GetEpochNum() uint64

func (*QueryEpochInfoRequest) Marshal 

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

func (*QueryEpochInfoRequest) MarshalTo 

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

func (*QueryEpochInfoRequest) MarshalToSizedBuffer 

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

func (*QueryEpochInfoRequest) ProtoMessage 

func (*QueryEpochInfoRequest) ProtoMessage()

func (*QueryEpochInfoRequest) Reset 

func (m *QueryEpochInfoRequest) Reset()

func (*QueryEpochInfoRequest) Size 

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

func (*QueryEpochInfoRequest) String 

func (m *QueryEpochInfoRequest) String() string

func (*QueryEpochInfoRequest) Unmarshal 

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

func (*QueryEpochInfoRequest) XXX_DiscardUnknown 

func (m *QueryEpochInfoRequest) XXX_DiscardUnknown()

func (*QueryEpochInfoRequest) XXX_Marshal 

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

func (*QueryEpochInfoRequest) XXX_Merge 

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

func (*QueryEpochInfoRequest) XXX_Size 

func (m *QueryEpochInfoRequest) XXX_Size() int

func (*QueryEpochInfoRequest) XXX_Unmarshal 

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

type QueryEpochInfoResponse 

type QueryEpochInfoResponse struct {
	Epoch *Epoch `protobuf:"bytes,1,opt,name=epoch,proto3" json:"epoch,omitempty"`
}

QueryEpochInfoRequest is the response type for the Query/EpochInfo method

func (*QueryEpochInfoResponse) Descriptor 

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

func (*QueryEpochInfoResponse) GetEpoch 

func (m *QueryEpochInfoResponse) GetEpoch() *Epoch

func (*QueryEpochInfoResponse) Marshal 

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

func (*QueryEpochInfoResponse) MarshalTo 

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

func (*QueryEpochInfoResponse) MarshalToSizedBuffer 

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

func (*QueryEpochInfoResponse) ProtoMessage 

func (*QueryEpochInfoResponse) ProtoMessage()

func (*QueryEpochInfoResponse) Reset 

func (m *QueryEpochInfoResponse) Reset()

func (*QueryEpochInfoResponse) Size 

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

func (*QueryEpochInfoResponse) String 

func (m *QueryEpochInfoResponse) String() string

func (*QueryEpochInfoResponse) Unmarshal 

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

func (*QueryEpochInfoResponse) XXX_DiscardUnknown 

func (m *QueryEpochInfoResponse) XXX_DiscardUnknown()

func (*QueryEpochInfoResponse) XXX_Marshal 

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

func (*QueryEpochInfoResponse) XXX_Merge 

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

func (*QueryEpochInfoResponse) XXX_Size 

func (m *QueryEpochInfoResponse) XXX_Size() int

func (*QueryEpochInfoResponse) XXX_Unmarshal 

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

type QueryEpochMsgsRequest 

type QueryEpochMsgsRequest struct {
	// epoch_num is the number of epoch of the requested msg queue
	EpochNum uint64 `protobuf:"varint,1,opt,name=epoch_num,json=epochNum,proto3" json:"epoch_num,omitempty"`
	// pagination defines whether to have the pagination in the request
	Pagination *query.PageRequest `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryEpochMsgsRequest is the request type for the Query/EpochMsgs RPC method

func (*QueryEpochMsgsRequest) Descriptor 

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

func (*QueryEpochMsgsRequest) GetEpochNum 

func (m *QueryEpochMsgsRequest) GetEpochNum() uint64

func (*QueryEpochMsgsRequest) GetPagination 

func (m *QueryEpochMsgsRequest) GetPagination() *query.PageRequest

func (*QueryEpochMsgsRequest) Marshal 

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

func (*QueryEpochMsgsRequest) MarshalTo 

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

func (*QueryEpochMsgsRequest) MarshalToSizedBuffer 

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

func (*QueryEpochMsgsRequest) ProtoMessage 

func (*QueryEpochMsgsRequest) ProtoMessage()

func (*QueryEpochMsgsRequest) Reset 

func (m *QueryEpochMsgsRequest) Reset()

func (*QueryEpochMsgsRequest) Size 

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

func (*QueryEpochMsgsRequest) String 

func (m *QueryEpochMsgsRequest) String() string

func (*QueryEpochMsgsRequest) Unmarshal 

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

func (*QueryEpochMsgsRequest) XXX_DiscardUnknown 

func (m *QueryEpochMsgsRequest) XXX_DiscardUnknown()

func (*QueryEpochMsgsRequest) XXX_Marshal 

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

func (*QueryEpochMsgsRequest) XXX_Merge 

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

func (*QueryEpochMsgsRequest) XXX_Size 

func (m *QueryEpochMsgsRequest) XXX_Size() int

func (*QueryEpochMsgsRequest) XXX_Unmarshal 

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

type QueryEpochMsgsResponse 

type QueryEpochMsgsResponse struct {
	// msgs is the list of messages queued in the current epoch
	Msgs []*QueuedMessage `protobuf:"bytes,1,rep,name=msgs,proto3" json:"msgs,omitempty"`
	// pagination defines the pagination in the response
	Pagination *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryEpochMsgsResponse is the response type for the Query/EpochMsgs RPC method

func (*QueryEpochMsgsResponse) Descriptor 

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

func (*QueryEpochMsgsResponse) GetMsgs 

func (m *QueryEpochMsgsResponse) GetMsgs() []*QueuedMessage

func (*QueryEpochMsgsResponse) GetPagination 

func (m *QueryEpochMsgsResponse) GetPagination() *query.PageResponse

func (*QueryEpochMsgsResponse) Marshal 

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

func (*QueryEpochMsgsResponse) MarshalTo 

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

func (*QueryEpochMsgsResponse) MarshalToSizedBuffer 

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

func (*QueryEpochMsgsResponse) ProtoMessage 

func (*QueryEpochMsgsResponse) ProtoMessage()

func (*QueryEpochMsgsResponse) Reset 

func (m *QueryEpochMsgsResponse) Reset()

func (*QueryEpochMsgsResponse) Size 

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

func (*QueryEpochMsgsResponse) String 

func (m *QueryEpochMsgsResponse) String() string

func (*QueryEpochMsgsResponse) Unmarshal 

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

func (*QueryEpochMsgsResponse) XXX_DiscardUnknown 

func (m *QueryEpochMsgsResponse) XXX_DiscardUnknown()

func (*QueryEpochMsgsResponse) XXX_Marshal 

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

func (*QueryEpochMsgsResponse) XXX_Merge 

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

func (*QueryEpochMsgsResponse) XXX_Size 

func (m *QueryEpochMsgsResponse) XXX_Size() int

func (*QueryEpochMsgsResponse) XXX_Unmarshal 

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

type QueryEpochValSetRequest 

type QueryEpochValSetRequest struct {
	EpochNum   uint64             `protobuf:"varint,1,opt,name=epoch_num,json=epochNum,proto3" json:"epoch_num,omitempty"`
	Pagination *query.PageRequest `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryEpochValSetRequest is the request type for the Query/EpochValSet RPC method

func (*QueryEpochValSetRequest) Descriptor 

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

func (*QueryEpochValSetRequest) GetEpochNum 

func (m *QueryEpochValSetRequest) GetEpochNum() uint64

func (*QueryEpochValSetRequest) GetPagination 

func (m *QueryEpochValSetRequest) GetPagination() *query.PageRequest

func (*QueryEpochValSetRequest) Marshal 

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

func (*QueryEpochValSetRequest) MarshalTo 

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

func (*QueryEpochValSetRequest) MarshalToSizedBuffer 

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

func (*QueryEpochValSetRequest) ProtoMessage 

func (*QueryEpochValSetRequest) ProtoMessage()

func (*QueryEpochValSetRequest) Reset 

func (m *QueryEpochValSetRequest) Reset()

func (*QueryEpochValSetRequest) Size 

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

func (*QueryEpochValSetRequest) String 

func (m *QueryEpochValSetRequest) String() string

func (*QueryEpochValSetRequest) Unmarshal 

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

func (*QueryEpochValSetRequest) XXX_DiscardUnknown 

func (m *QueryEpochValSetRequest) XXX_DiscardUnknown()

func (*QueryEpochValSetRequest) XXX_Marshal 

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

func (*QueryEpochValSetRequest) XXX_Merge 

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

func (*QueryEpochValSetRequest) XXX_Size 

func (m *QueryEpochValSetRequest) XXX_Size() int

func (*QueryEpochValSetRequest) XXX_Unmarshal 

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

type QueryEpochValSetResponse 

type QueryEpochValSetResponse struct {
	Validators       []*Validator        `protobuf:"bytes,1,rep,name=validators,proto3" json:"validators,omitempty"`
	TotalVotingPower int64               `protobuf:"varint,2,opt,name=total_voting_power,json=totalVotingPower,proto3" json:"total_voting_power,omitempty"`
	Pagination       *query.PageResponse `protobuf:"bytes,3,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryEpochValSetRequest is the response type for the Query/EpochValSet RPC method

func (*QueryEpochValSetResponse) Descriptor 

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

func (*QueryEpochValSetResponse) GetPagination 

func (m *QueryEpochValSetResponse) GetPagination() *query.PageResponse

func (*QueryEpochValSetResponse) GetTotalVotingPower 

func (m *QueryEpochValSetResponse) GetTotalVotingPower() int64

func (*QueryEpochValSetResponse) GetValidators 

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

func (*QueryEpochValSetResponse) Marshal 

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

func (*QueryEpochValSetResponse) MarshalTo 

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

func (*QueryEpochValSetResponse) MarshalToSizedBuffer 

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

func (*QueryEpochValSetResponse) ProtoMessage 

func (*QueryEpochValSetResponse) ProtoMessage()

func (*QueryEpochValSetResponse) Reset 

func (m *QueryEpochValSetResponse) Reset()

func (*QueryEpochValSetResponse) Size 

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

func (*QueryEpochValSetResponse) String 

func (m *QueryEpochValSetResponse) String() string

func (*QueryEpochValSetResponse) Unmarshal 

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

func (*QueryEpochValSetResponse) XXX_DiscardUnknown 

func (m *QueryEpochValSetResponse) XXX_DiscardUnknown()

func (*QueryEpochValSetResponse) XXX_Marshal 

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

func (*QueryEpochValSetResponse) XXX_Merge 

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

func (*QueryEpochValSetResponse) XXX_Size 

func (m *QueryEpochValSetResponse) XXX_Size() int

func (*QueryEpochValSetResponse) XXX_Unmarshal 

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

type QueryEpochsInfoRequest 

type QueryEpochsInfoRequest struct {
	// pagination defines whether to have the pagination in the request
	Pagination *query.PageRequest `protobuf:"bytes,1,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryEpochInfosRequest is the request type for the Query/EpochInfos method

func (*QueryEpochsInfoRequest) Descriptor 

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

func (*QueryEpochsInfoRequest) GetPagination 

func (m *QueryEpochsInfoRequest) GetPagination() *query.PageRequest

func (*QueryEpochsInfoRequest) Marshal 

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

func (*QueryEpochsInfoRequest) MarshalTo 

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

func (*QueryEpochsInfoRequest) MarshalToSizedBuffer 

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

func (*QueryEpochsInfoRequest) ProtoMessage 

func (*QueryEpochsInfoRequest) ProtoMessage()

func (*QueryEpochsInfoRequest) Reset 

func (m *QueryEpochsInfoRequest) Reset()

func (*QueryEpochsInfoRequest) Size 

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

func (*QueryEpochsInfoRequest) String 

func (m *QueryEpochsInfoRequest) String() string

func (*QueryEpochsInfoRequest) Unmarshal 

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

func (*QueryEpochsInfoRequest) XXX_DiscardUnknown 

func (m *QueryEpochsInfoRequest) XXX_DiscardUnknown()

func (*QueryEpochsInfoRequest) XXX_Marshal 

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

func (*QueryEpochsInfoRequest) XXX_Merge 

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

func (*QueryEpochsInfoRequest) XXX_Size 

func (m *QueryEpochsInfoRequest) XXX_Size() int

func (*QueryEpochsInfoRequest) XXX_Unmarshal 

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

type QueryEpochsInfoResponse 

type QueryEpochsInfoResponse struct {
	Epochs []*Epoch `protobuf:"bytes,1,rep,name=epochs,proto3" json:"epochs,omitempty"`
	// pagination defines the pagination in the response
	Pagination *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryEpochsInfoResponse is the response type for the Query/EpochInfos method

func (*QueryEpochsInfoResponse) Descriptor 

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

func (*QueryEpochsInfoResponse) GetEpochs 

func (m *QueryEpochsInfoResponse) GetEpochs() []*Epoch

func (*QueryEpochsInfoResponse) GetPagination 

func (m *QueryEpochsInfoResponse) GetPagination() *query.PageResponse

func (*QueryEpochsInfoResponse) Marshal 

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

func (*QueryEpochsInfoResponse) MarshalTo 

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

func (*QueryEpochsInfoResponse) MarshalToSizedBuffer 

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

func (*QueryEpochsInfoResponse) ProtoMessage 

func (*QueryEpochsInfoResponse) ProtoMessage()

func (*QueryEpochsInfoResponse) Reset 

func (m *QueryEpochsInfoResponse) Reset()

func (*QueryEpochsInfoResponse) Size 

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

func (*QueryEpochsInfoResponse) String 

func (m *QueryEpochsInfoResponse) String() string

func (*QueryEpochsInfoResponse) Unmarshal 

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

func (*QueryEpochsInfoResponse) XXX_DiscardUnknown 

func (m *QueryEpochsInfoResponse) XXX_DiscardUnknown()

func (*QueryEpochsInfoResponse) XXX_Marshal 

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

func (*QueryEpochsInfoResponse) XXX_Merge 

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

func (*QueryEpochsInfoResponse) XXX_Size 

func (m *QueryEpochsInfoResponse) XXX_Size() int

func (*QueryEpochsInfoResponse) XXX_Unmarshal 

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

type QueryLatestEpochMsgsRequest 

type QueryLatestEpochMsgsRequest struct {
	// end_epoch is the number of the last epoch to query
	EndEpoch uint64 `protobuf:"varint,1,opt,name=end_epoch,json=endEpoch,proto3" json:"end_epoch,omitempty"`
	// epoch_count is the number of epochs to query
	EpochCount uint64             `protobuf:"varint,2,opt,name=epoch_count,json=epochCount,proto3" json:"epoch_count,omitempty"`
	Pagination *query.PageRequest `protobuf:"bytes,3,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryLatestEpochMsgsRequest is the request type for the Query/LatestEpochMsgs RPC method it returns epoch msgs within epoch [max(1, end_epoch-epoch_count+1), end_epoch]

func (*QueryLatestEpochMsgsRequest) Descriptor 

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

func (*QueryLatestEpochMsgsRequest) GetEndEpoch 

func (m *QueryLatestEpochMsgsRequest) GetEndEpoch() uint64

func (*QueryLatestEpochMsgsRequest) GetEpochCount 

func (m *QueryLatestEpochMsgsRequest) GetEpochCount() uint64

func (*QueryLatestEpochMsgsRequest) GetPagination 

func (m *QueryLatestEpochMsgsRequest) GetPagination() *query.PageRequest

func (*QueryLatestEpochMsgsRequest) Marshal 

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

func (*QueryLatestEpochMsgsRequest) MarshalTo 

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

func (*QueryLatestEpochMsgsRequest) MarshalToSizedBuffer 

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

func (*QueryLatestEpochMsgsRequest) ProtoMessage 

func (*QueryLatestEpochMsgsRequest) ProtoMessage()

func (*QueryLatestEpochMsgsRequest) Reset 

func (m *QueryLatestEpochMsgsRequest) Reset()

func (*QueryLatestEpochMsgsRequest) Size 

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

func (*QueryLatestEpochMsgsRequest) String 

func (m *QueryLatestEpochMsgsRequest) String() string

func (*QueryLatestEpochMsgsRequest) Unmarshal 

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

func (*QueryLatestEpochMsgsRequest) XXX_DiscardUnknown 

func (m *QueryLatestEpochMsgsRequest) XXX_DiscardUnknown()

func (*QueryLatestEpochMsgsRequest) XXX_Marshal 

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

func (*QueryLatestEpochMsgsRequest) XXX_Merge 

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

func (*QueryLatestEpochMsgsRequest) XXX_Size 

func (m *QueryLatestEpochMsgsRequest) XXX_Size() int

func (*QueryLatestEpochMsgsRequest) XXX_Unmarshal 

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

type QueryLatestEpochMsgsResponse 

type QueryLatestEpochMsgsResponse struct {
	// epoch_msg_map is a list of QueuedMessageList
	// each QueuedMessageList has a field identifying the epoch number
	LatestEpochMsgs []*QueuedMessageList `protobuf:"bytes,1,rep,name=latest_epoch_msgs,json=latestEpochMsgs,proto3" json:"latest_epoch_msgs,omitempty"`
	Pagination      *query.PageResponse  `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryLatestEpochMsgsResponse is the response type for the Query/LatestEpochMsgs RPC method

func (*QueryLatestEpochMsgsResponse) Descriptor 

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

func (*QueryLatestEpochMsgsResponse) GetLatestEpochMsgs 

func (m *QueryLatestEpochMsgsResponse) GetLatestEpochMsgs() []*QueuedMessageList

func (*QueryLatestEpochMsgsResponse) GetPagination 

func (m *QueryLatestEpochMsgsResponse) GetPagination() *query.PageResponse

func (*QueryLatestEpochMsgsResponse) Marshal 

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

func (*QueryLatestEpochMsgsResponse) MarshalTo 

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

func (*QueryLatestEpochMsgsResponse) MarshalToSizedBuffer 

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

func (*QueryLatestEpochMsgsResponse) ProtoMessage 

func (*QueryLatestEpochMsgsResponse) ProtoMessage()

func (*QueryLatestEpochMsgsResponse) Reset 

func (m *QueryLatestEpochMsgsResponse) Reset()

func (*QueryLatestEpochMsgsResponse) Size 

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

func (*QueryLatestEpochMsgsResponse) String 

func (m *QueryLatestEpochMsgsResponse) String() string

func (*QueryLatestEpochMsgsResponse) Unmarshal 

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

func (*QueryLatestEpochMsgsResponse) XXX_DiscardUnknown 

func (m *QueryLatestEpochMsgsResponse) XXX_DiscardUnknown()

func (*QueryLatestEpochMsgsResponse) XXX_Marshal 

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

func (*QueryLatestEpochMsgsResponse) XXX_Merge 

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

func (*QueryLatestEpochMsgsResponse) XXX_Size 

func (m *QueryLatestEpochMsgsResponse) XXX_Size() int

func (*QueryLatestEpochMsgsResponse) XXX_Unmarshal 

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

type QueryParamsRequest 

type QueryParamsRequest struct {
}

QueryParamsRequest is the request type for the Query/Params RPC method.

func (*QueryParamsRequest) Descriptor 

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

func (*QueryParamsRequest) Marshal 

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

func (*QueryParamsRequest) MarshalTo 

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

func (*QueryParamsRequest) MarshalToSizedBuffer 

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

func (*QueryParamsRequest) ProtoMessage 

func (*QueryParamsRequest) ProtoMessage()

func (*QueryParamsRequest) Reset 

func (m *QueryParamsRequest) Reset()

func (*QueryParamsRequest) Size 

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

func (*QueryParamsRequest) String 

func (m *QueryParamsRequest) String() string

func (*QueryParamsRequest) Unmarshal 

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

func (*QueryParamsRequest) XXX_DiscardUnknown 

func (m *QueryParamsRequest) XXX_DiscardUnknown()

func (*QueryParamsRequest) XXX_Marshal 

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

func (*QueryParamsRequest) XXX_Merge 

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

func (*QueryParamsRequest) XXX_Size 

func (m *QueryParamsRequest) XXX_Size() int

func (*QueryParamsRequest) XXX_Unmarshal 

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

type QueryParamsResponse 

type QueryParamsResponse struct {
	// params holds all the parameters of this module.
	Params Params `protobuf:"bytes,1,opt,name=params,proto3" json:"params"`
}

QueryParamsResponse is the response type for the Query/Params RPC method.

func (*QueryParamsResponse) Descriptor 

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

func (*QueryParamsResponse) GetParams 

func (m *QueryParamsResponse) GetParams() Params

func (*QueryParamsResponse) Marshal 

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

func (*QueryParamsResponse) MarshalTo 

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

func (*QueryParamsResponse) MarshalToSizedBuffer 

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

func (*QueryParamsResponse) ProtoMessage 

func (*QueryParamsResponse) ProtoMessage()

func (*QueryParamsResponse) Reset 

func (m *QueryParamsResponse) Reset()

func (*QueryParamsResponse) Size 

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

func (*QueryParamsResponse) String 

func (m *QueryParamsResponse) String() string

func (*QueryParamsResponse) Unmarshal 

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

func (*QueryParamsResponse) XXX_DiscardUnknown 

func (m *QueryParamsResponse) XXX_DiscardUnknown()

func (*QueryParamsResponse) XXX_Marshal 

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

func (*QueryParamsResponse) XXX_Merge 

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

func (*QueryParamsResponse) XXX_Size 

func (m *QueryParamsResponse) XXX_Size() int

func (*QueryParamsResponse) XXX_Unmarshal 

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

type QueryServer 

type QueryServer interface {
	// Params queries the parameters of the module.
	Params(context.Context, *QueryParamsRequest) (*QueryParamsResponse, error)
	// EpochInfo queries the information of a given epoch
	EpochInfo(context.Context, *QueryEpochInfoRequest) (*QueryEpochInfoResponse, error)
	// EpochsInfo queries the metadata of epochs in a given range, depending on
	// the parameters in the pagination request. Th main use case will be querying
	// the latest epochs in time order.
	EpochsInfo(context.Context, *QueryEpochsInfoRequest) (*QueryEpochsInfoResponse, error)
	// CurrentEpoch queries the current epoch
	CurrentEpoch(context.Context, *QueryCurrentEpochRequest) (*QueryCurrentEpochResponse, error)
	// EpochMsgs queries the messages of a given epoch
	EpochMsgs(context.Context, *QueryEpochMsgsRequest) (*QueryEpochMsgsResponse, error)
	// LatestEpochMsgs queries the messages within a given number of most recent
	// epochs
	LatestEpochMsgs(context.Context, *QueryLatestEpochMsgsRequest) (*QueryLatestEpochMsgsResponse, error)
	// ValidatorLifecycle queries the lifecycle of a given validator
	ValidatorLifecycle(context.Context, *QueryValidatorLifecycleRequest) (*QueryValidatorLifecycleResponse, error)
	// DelegationLifecycle queries the lifecycle of a given delegation
	DelegationLifecycle(context.Context, *QueryDelegationLifecycleRequest) (*QueryDelegationLifecycleResponse, error)
	// EpochValSet queries the validator set of a given epoch
	EpochValSet(context.Context, *QueryEpochValSetRequest) (*QueryEpochValSetResponse, error)
}

QueryServer is the server API for Query service.

type QueryValidatorLifecycleRequest 

type QueryValidatorLifecycleRequest struct {
	ValAddr string `protobuf:"bytes,1,opt,name=val_addr,json=valAddr,proto3" json:"val_addr,omitempty"`
}

QueryValidatorLifecycleRequest is the request type for the Query/ValidatorLifecycle RPC method

func (*QueryValidatorLifecycleRequest) Descriptor 

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

func (*QueryValidatorLifecycleRequest) GetValAddr 

func (m *QueryValidatorLifecycleRequest) GetValAddr() string

func (*QueryValidatorLifecycleRequest) Marshal 

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

func (*QueryValidatorLifecycleRequest) MarshalTo 

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

func (*QueryValidatorLifecycleRequest) MarshalToSizedBuffer 

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

func (*QueryValidatorLifecycleRequest) ProtoMessage 

func (*QueryValidatorLifecycleRequest) ProtoMessage()

func (*QueryValidatorLifecycleRequest) Reset 

func (m *QueryValidatorLifecycleRequest) Reset()

func (*QueryValidatorLifecycleRequest) Size 

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

func (*QueryValidatorLifecycleRequest) String 

func (m *QueryValidatorLifecycleRequest) String() string

func (*QueryValidatorLifecycleRequest) Unmarshal 

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

func (*QueryValidatorLifecycleRequest) XXX_DiscardUnknown 

func (m *QueryValidatorLifecycleRequest) XXX_DiscardUnknown()

func (*QueryValidatorLifecycleRequest) XXX_Marshal 

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

func (*QueryValidatorLifecycleRequest) XXX_Merge 

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

func (*QueryValidatorLifecycleRequest) XXX_Size 

func (m *QueryValidatorLifecycleRequest) XXX_Size() int

func (*QueryValidatorLifecycleRequest) XXX_Unmarshal 

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

type QueryValidatorLifecycleResponse 

type QueryValidatorLifecycleResponse struct {
	ValLife *ValidatorLifecycle `protobuf:"bytes,1,opt,name=val_life,json=valLife,proto3" json:"val_life,omitempty"`
}

QueryValidatorLifecycleResponse is the response type for the Query/ValidatorLifecycle RPC method

func (*QueryValidatorLifecycleResponse) Descriptor 

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

func (*QueryValidatorLifecycleResponse) GetValLife 

func (m *QueryValidatorLifecycleResponse) GetValLife() *ValidatorLifecycle

func (*QueryValidatorLifecycleResponse) Marshal 

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

func (*QueryValidatorLifecycleResponse) MarshalTo 

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

func (*QueryValidatorLifecycleResponse) MarshalToSizedBuffer 

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

func (*QueryValidatorLifecycleResponse) ProtoMessage 

func (*QueryValidatorLifecycleResponse) ProtoMessage()

func (*QueryValidatorLifecycleResponse) Reset 

func (m *QueryValidatorLifecycleResponse) Reset()

func (*QueryValidatorLifecycleResponse) Size 

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

func (*QueryValidatorLifecycleResponse) String 

func (m *QueryValidatorLifecycleResponse) String() string

func (*QueryValidatorLifecycleResponse) Unmarshal 

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

func (*QueryValidatorLifecycleResponse) XXX_DiscardUnknown 

func (m *QueryValidatorLifecycleResponse) XXX_DiscardUnknown()

func (*QueryValidatorLifecycleResponse) XXX_Marshal 

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

func (*QueryValidatorLifecycleResponse) XXX_Merge 

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

func (*QueryValidatorLifecycleResponse) XXX_Size 

func (m *QueryValidatorLifecycleResponse) XXX_Size() int

func (*QueryValidatorLifecycleResponse) XXX_Unmarshal 

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

type QueuedMessage 

type QueuedMessage struct {
	// tx_id is the ID of the tx that contains the message
	TxId []byte `protobuf:"bytes,1,opt,name=tx_id,json=txId,proto3" json:"tx_id,omitempty"`
	// msg_id is the original message ID, i.e., hash of the marshaled message
	MsgId []byte `protobuf:"bytes,2,opt,name=msg_id,json=msgId,proto3" json:"msg_id,omitempty"`
	// block_height is the height when this msg is submitted to Babylon
	BlockHeight uint64 `protobuf:"varint,3,opt,name=block_height,json=blockHeight,proto3" json:"block_height,omitempty"`
	// block_time is the timestamp when this msg is submitted to Babylon
	BlockTime *time.Time `protobuf:"bytes,4,opt,name=block_time,json=blockTime,proto3,stdtime" json:"block_time,omitempty"`
	// msg is the actual message that is sent by a user and is queued by the
	// epoching module
	//
	// Types that are valid to be assigned to Msg:
	//	*QueuedMessage_MsgCreateValidator
	//	*QueuedMessage_MsgDelegate
	//	*QueuedMessage_MsgUndelegate
	//	*QueuedMessage_MsgBeginRedelegate
	Msg isQueuedMessage_Msg `protobuf_oneof:"msg"`
}

QueuedMessage is a message that can change the validator set and is delayed to the epoch boundary

func NewQueuedMessage 

func NewQueuedMessage(blockHeight uint64, blockTime time.Time, txid []byte, msg sdk.Msg) (QueuedMessage, error)

NewQueuedMessage creates a new QueuedMessage from a wrapped msg i.e., wrapped -> unwrapped -> QueuedMessage

func (*QueuedMessage) Descriptor 

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

func (*QueuedMessage) GetBlockHeight 

func (m *QueuedMessage) GetBlockHeight() uint64

func (*QueuedMessage) GetBlockTime 

func (m *QueuedMessage) GetBlockTime() *time.Time

func (*QueuedMessage) GetMsg 

func (m *QueuedMessage) GetMsg() isQueuedMessage_Msg

func (*QueuedMessage) GetMsgBeginRedelegate 

func (m *QueuedMessage) GetMsgBeginRedelegate() *types1.MsgBeginRedelegate

func (*QueuedMessage) GetMsgCreateValidator 

func (m *QueuedMessage) GetMsgCreateValidator() *types1.MsgCreateValidator

func (*QueuedMessage) GetMsgDelegate 

func (m *QueuedMessage) GetMsgDelegate() *types1.MsgDelegate

func (*QueuedMessage) GetMsgId 

func (m *QueuedMessage) GetMsgId() []byte

func (*QueuedMessage) GetMsgUndelegate 

func (m *QueuedMessage) GetMsgUndelegate() *types1.MsgUndelegate

func (QueuedMessage) GetSigners 

func (qm QueuedMessage) GetSigners() []sdk.AccAddress

func (*QueuedMessage) GetTxId 

func (m *QueuedMessage) GetTxId() []byte

func (*QueuedMessage) Marshal 

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

func (*QueuedMessage) MarshalTo 

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

func (*QueuedMessage) MarshalToSizedBuffer 

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

func (*QueuedMessage) ProtoMessage 

func (*QueuedMessage) ProtoMessage()

func (*QueuedMessage) Reset 

func (m *QueuedMessage) Reset()

func (*QueuedMessage) Size 

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

func (*QueuedMessage) String 

func (m *QueuedMessage) String() string

func (*QueuedMessage) Unmarshal 

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

func (QueuedMessage) UnpackInterfaces 

func (qm QueuedMessage) UnpackInterfaces(unpacker codectypes.AnyUnpacker) error

UnpackInterfaces implements UnpackInterfacesMessage.UnpackInterfaces

func (*QueuedMessage) UnwrapToSdkMsg 

func (qm *QueuedMessage) UnwrapToSdkMsg() sdk.Msg

func (QueuedMessage) ValidateBasic 

func (qm QueuedMessage) ValidateBasic() error

func (*QueuedMessage) XXX_DiscardUnknown 

func (m *QueuedMessage) XXX_DiscardUnknown()

func (*QueuedMessage) XXX_Marshal 

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

func (*QueuedMessage) XXX_Merge 

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

func (*QueuedMessage) XXX_OneofWrappers 

func (*QueuedMessage) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*QueuedMessage) XXX_Size 

func (m *QueuedMessage) XXX_Size() int

func (*QueuedMessage) XXX_Unmarshal 

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

type QueuedMessageList 

type QueuedMessageList struct {
	EpochNumber uint64           `protobuf:"varint,1,opt,name=epoch_number,json=epochNumber,proto3" json:"epoch_number,omitempty"`
	Msgs        []*QueuedMessage `protobuf:"bytes,2,rep,name=msgs,proto3" json:"msgs,omitempty"`
}

QueuedMessageList is a message that contains a list of staking-related messages queued for an epoch

func (*QueuedMessageList) Descriptor 

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

func (*QueuedMessageList) GetEpochNumber 

func (m *QueuedMessageList) GetEpochNumber() uint64

func (*QueuedMessageList) GetMsgs 

func (m *QueuedMessageList) GetMsgs() []*QueuedMessage

func (*QueuedMessageList) Marshal 

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

func (*QueuedMessageList) MarshalTo 

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

func (*QueuedMessageList) MarshalToSizedBuffer 

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

func (*QueuedMessageList) ProtoMessage 

func (*QueuedMessageList) ProtoMessage()

func (*QueuedMessageList) Reset 

func (m *QueuedMessageList) Reset()

func (*QueuedMessageList) Size 

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

func (*QueuedMessageList) String 

func (m *QueuedMessageList) String() string

func (*QueuedMessageList) Unmarshal 

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

func (*QueuedMessageList) XXX_DiscardUnknown 

func (m *QueuedMessageList) XXX_DiscardUnknown()

func (*QueuedMessageList) XXX_Marshal 

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

func (*QueuedMessageList) XXX_Merge 

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

func (*QueuedMessageList) XXX_Size 

func (m *QueuedMessageList) XXX_Size() int

func (*QueuedMessageList) XXX_Unmarshal 

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

type QueuedMessage_MsgBeginRedelegate 

type QueuedMessage_MsgBeginRedelegate struct {
	MsgBeginRedelegate *types1.MsgBeginRedelegate `protobuf:"bytes,8,opt,name=msg_begin_redelegate,json=msgBeginRedelegate,proto3,oneof" json:"msg_begin_redelegate,omitempty"`
}

func (*QueuedMessage_MsgBeginRedelegate) MarshalTo 

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

func (*QueuedMessage_MsgBeginRedelegate) MarshalToSizedBuffer 

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

func (*QueuedMessage_MsgBeginRedelegate) Size 

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

type QueuedMessage_MsgCreateValidator 

type QueuedMessage_MsgCreateValidator struct {
	MsgCreateValidator *types1.MsgCreateValidator `protobuf:"bytes,5,opt,name=msg_create_validator,json=msgCreateValidator,proto3,oneof" json:"msg_create_validator,omitempty"`
}

func (*QueuedMessage_MsgCreateValidator) MarshalTo 

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

func (*QueuedMessage_MsgCreateValidator) MarshalToSizedBuffer 

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

func (*QueuedMessage_MsgCreateValidator) Size 

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

type QueuedMessage_MsgDelegate 

type QueuedMessage_MsgDelegate struct {
	MsgDelegate *types1.MsgDelegate `protobuf:"bytes,6,opt,name=msg_delegate,json=msgDelegate,proto3,oneof" json:"msg_delegate,omitempty"`
}

func (*QueuedMessage_MsgDelegate) MarshalTo 

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

func (*QueuedMessage_MsgDelegate) MarshalToSizedBuffer 

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

func (*QueuedMessage_MsgDelegate) Size 

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

type QueuedMessage_MsgUndelegate 

type QueuedMessage_MsgUndelegate struct {
	MsgUndelegate *types1.MsgUndelegate `protobuf:"bytes,7,opt,name=msg_undelegate,json=msgUndelegate,proto3,oneof" json:"msg_undelegate,omitempty"`
}

func (*QueuedMessage_MsgUndelegate) MarshalTo 

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

func (*QueuedMessage_MsgUndelegate) MarshalToSizedBuffer 

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

func (*QueuedMessage_MsgUndelegate) Size 

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

type StakingHooks 

type StakingHooks interface {
	BeforeValidatorSlashed(ctx sdk.Context, valAddr sdk.ValAddress, fraction sdk.Dec)                     // Must be called right before a validator is slashed
	AfterValidatorCreated(ctx sdk.Context, valAddr sdk.ValAddress) error                                  // Must be called when a validator is created
	AfterValidatorRemoved(ctx sdk.Context, consAddr sdk.ConsAddress, valAddr sdk.ValAddress) error        // Must be called when a validator is deleted
	AfterValidatorBonded(ctx sdk.Context, consAddr sdk.ConsAddress, valAddr sdk.ValAddress) error         // Must be called when a validator is bonded
	AfterValidatorBeginUnbonding(ctx sdk.Context, consAddr sdk.ConsAddress, valAddr sdk.ValAddress) error // Must be called when a validator begins unbonding
}

StakingHooks event hooks for staking validator object (noalias)

type StakingKeeper 

type StakingKeeper interface {
	GetParams(ctx sdk.Context) stakingtypes.Params
	DequeueAllMatureUBDQueue(ctx sdk.Context, currTime time.Time) (matureUnbonds []stakingtypes.DVPair)
	CompleteUnbonding(ctx sdk.Context, delAddr sdk.AccAddress, valAddr sdk.ValAddress) (sdk.Coins, error)
	DequeueAllMatureRedelegationQueue(ctx sdk.Context, currTime time.Time) (matureRedelegations []stakingtypes.DVVTriplet)
	CompleteRedelegation(ctx sdk.Context, delAddr sdk.AccAddress, valSrcAddr, valDstAddr sdk.ValAddress) (sdk.Coins, error)
	ApplyAndReturnValidatorSetUpdates(ctx sdk.Context) ([]abci.ValidatorUpdate, error)
	IterateLastValidatorPowers(ctx sdk.Context, handler func(operator sdk.ValAddress, power int64) bool)
	GetValidator(ctx sdk.Context, addr sdk.ValAddress) (stakingtypes.Validator, bool)
	GetValidatorDelegations(ctx sdk.Context, valAddr sdk.ValAddress) []stakingtypes.Delegation
	HasMaxUnbondingDelegationEntries(ctx sdk.Context, delegatorAddr sdk.AccAddress, validatorAddr sdk.ValAddress) bool
	BondDenom(ctx sdk.Context) string
	HasReceivingRedelegation(ctx sdk.Context, delAddr sdk.AccAddress, valDstAddr sdk.ValAddress) bool
	HasMaxRedelegationEntries(ctx sdk.Context, delegatorAddr sdk.AccAddress, validatorSrcAddr, validatorDstAddr sdk.ValAddress) bool
	ValidateUnbondAmount(ctx sdk.Context, delAddr sdk.AccAddress, valAddr sdk.ValAddress, amt math.Int) (sdk.Dec, error)
	ValidatorQueueIterator(ctx sdk.Context, endTime time.Time, endHeight int64) sdk.Iterator
	UnbondingToUnbonded(ctx sdk.Context, validator stakingtypes.Validator) stakingtypes.Validator
	RemoveValidator(ctx sdk.Context, address sdk.ValAddress)
	UnbondAllMatureValidators(ctx sdk.Context)
	GetValidatorByConsAddr(ctx sdk.Context, consAddr sdk.ConsAddress) (stakingtypes.Validator, bool)
}

StakingKeeper defines the staking module interface contract needed by the epoching module.

type UnimplementedMsgServer 

type UnimplementedMsgServer struct {
}

UnimplementedMsgServer can be embedded to have forward compatible implementations.

func (*UnimplementedMsgServer) UpdateParams added in v0.6.0 

func (*UnimplementedMsgServer) UpdateParams(ctx context.Context, req *MsgUpdateParams) (*MsgUpdateParamsResponse, error)

func (*UnimplementedMsgServer) WrappedBeginRedelegate 

func (*UnimplementedMsgServer) WrappedBeginRedelegate(ctx context.Context, req *MsgWrappedBeginRedelegate) (*MsgWrappedBeginRedelegateResponse, error)

func (*UnimplementedMsgServer) WrappedDelegate 

func (*UnimplementedMsgServer) WrappedDelegate(ctx context.Context, req *MsgWrappedDelegate) (*MsgWrappedDelegateResponse, error)

func (*UnimplementedMsgServer) WrappedUndelegate 

func (*UnimplementedMsgServer) WrappedUndelegate(ctx context.Context, req *MsgWrappedUndelegate) (*MsgWrappedUndelegateResponse, error)

type UnimplementedQueryServer 

type UnimplementedQueryServer struct {
}

UnimplementedQueryServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryServer) CurrentEpoch 

func (*UnimplementedQueryServer) CurrentEpoch(ctx context.Context, req *QueryCurrentEpochRequest) (*QueryCurrentEpochResponse, error)

func (*UnimplementedQueryServer) DelegationLifecycle 

func (*UnimplementedQueryServer) DelegationLifecycle(ctx context.Context, req *QueryDelegationLifecycleRequest) (*QueryDelegationLifecycleResponse, error)

func (*UnimplementedQueryServer) EpochInfo 

func (*UnimplementedQueryServer) EpochInfo(ctx context.Context, req *QueryEpochInfoRequest) (*QueryEpochInfoResponse, error)

func (*UnimplementedQueryServer) EpochMsgs 

func (*UnimplementedQueryServer) EpochMsgs(ctx context.Context, req *QueryEpochMsgsRequest) (*QueryEpochMsgsResponse, error)

func (*UnimplementedQueryServer) EpochValSet 

func (*UnimplementedQueryServer) EpochValSet(ctx context.Context, req *QueryEpochValSetRequest) (*QueryEpochValSetResponse, error)

func (*UnimplementedQueryServer) EpochsInfo 

func (*UnimplementedQueryServer) EpochsInfo(ctx context.Context, req *QueryEpochsInfoRequest) (*QueryEpochsInfoResponse, error)

func (*UnimplementedQueryServer) LatestEpochMsgs 

func (*UnimplementedQueryServer) LatestEpochMsgs(ctx context.Context, req *QueryLatestEpochMsgsRequest) (*QueryLatestEpochMsgsResponse, error)

func (*UnimplementedQueryServer) Params 

func (*UnimplementedQueryServer) Params(ctx context.Context, req *QueryParamsRequest) (*QueryParamsResponse, error)

func (*UnimplementedQueryServer) ValidatorLifecycle 

func (*UnimplementedQueryServer) ValidatorLifecycle(ctx context.Context, req *QueryValidatorLifecycleRequest) (*QueryValidatorLifecycleResponse, error)

type ValStateUpdate 

type ValStateUpdate struct {
	State       BondState  `protobuf:"varint,1,opt,name=state,proto3,enum=babylon.epoching.v1.BondState" json:"state,omitempty"`
	BlockHeight uint64     `protobuf:"varint,2,opt,name=block_height,json=blockHeight,proto3" json:"block_height,omitempty"`
	BlockTime   *time.Time `protobuf:"bytes,3,opt,name=block_time,json=blockTime,proto3,stdtime" json:"block_time,omitempty"`
}

ValStateUpdate is a messages that records a state update of a validator

func (*ValStateUpdate) Descriptor 

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

func (*ValStateUpdate) GetBlockHeight 

func (m *ValStateUpdate) GetBlockHeight() uint64

func (*ValStateUpdate) GetBlockTime 

func (m *ValStateUpdate) GetBlockTime() *time.Time

func (*ValStateUpdate) GetState 

func (m *ValStateUpdate) GetState() BondState

func (*ValStateUpdate) Marshal 

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

func (*ValStateUpdate) MarshalTo 

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

func (*ValStateUpdate) MarshalToSizedBuffer 

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

func (*ValStateUpdate) ProtoMessage 

func (*ValStateUpdate) ProtoMessage()

func (*ValStateUpdate) Reset 

func (m *ValStateUpdate) Reset()

func (*ValStateUpdate) Size 

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

func (*ValStateUpdate) String 

func (m *ValStateUpdate) String() string

func (*ValStateUpdate) Unmarshal 

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

func (*ValStateUpdate) XXX_DiscardUnknown 

func (m *ValStateUpdate) XXX_DiscardUnknown()

func (*ValStateUpdate) XXX_Marshal 

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

func (*ValStateUpdate) XXX_Merge 

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

func (*ValStateUpdate) XXX_Size 

func (m *ValStateUpdate) XXX_Size() int

func (*ValStateUpdate) XXX_Unmarshal 

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

type Validator 

type Validator struct {
	// addr is the validator's address (in sdk.ValAddress)
	Addr []byte `protobuf:"bytes,1,opt,name=addr,proto3" json:"addr,omitempty"`
	// power is the validator's voting power
	Power int64 `protobuf:"varint,2,opt,name=power,proto3" json:"power,omitempty"`
}

Validator is a message that denotes a validator

func (*Validator) Descriptor 

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

func (*Validator) GetAddr 

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

func (*Validator) GetPower 

func (m *Validator) GetPower() int64

func (*Validator) GetValAddress 

func (v *Validator) GetValAddress() sdk.ValAddress

func (*Validator) GetValAddressStr 

func (v *Validator) GetValAddressStr() string

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) ProtoMessage 

func (*Validator) ProtoMessage()

func (*Validator) Reset 

func (m *Validator) Reset()

func (*Validator) Size 

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

func (*Validator) String 

func (m *Validator) String() string

func (*Validator) Unmarshal 

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

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 ValidatorLifecycle 

type ValidatorLifecycle struct {
	ValAddr string            `protobuf:"bytes,1,opt,name=val_addr,json=valAddr,proto3" json:"val_addr,omitempty"`
	ValLife []*ValStateUpdate `protobuf:"bytes,2,rep,name=val_life,json=valLife,proto3" json:"val_life,omitempty"`
}

ValidatorLifecycle is a message that records records the lifecycle of a validator

func (*ValidatorLifecycle) Descriptor 

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

func (*ValidatorLifecycle) GetValAddr 

func (m *ValidatorLifecycle) GetValAddr() string

func (*ValidatorLifecycle) GetValLife 

func (m *ValidatorLifecycle) GetValLife() []*ValStateUpdate

func (*ValidatorLifecycle) Marshal 

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

func (*ValidatorLifecycle) MarshalTo 

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

func (*ValidatorLifecycle) MarshalToSizedBuffer 

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

func (*ValidatorLifecycle) ProtoMessage 

func (*ValidatorLifecycle) ProtoMessage()

func (*ValidatorLifecycle) Reset 

func (m *ValidatorLifecycle) Reset()

func (*ValidatorLifecycle) Size 

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

func (*ValidatorLifecycle) String 

func (m *ValidatorLifecycle) String() string

func (*ValidatorLifecycle) Unmarshal 

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

func (*ValidatorLifecycle) XXX_DiscardUnknown 

func (m *ValidatorLifecycle) XXX_DiscardUnknown()

func (*ValidatorLifecycle) XXX_Marshal 

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

func (*ValidatorLifecycle) XXX_Merge 

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

func (*ValidatorLifecycle) XXX_Size 

func (m *ValidatorLifecycle) XXX_Size() int

func (*ValidatorLifecycle) XXX_Unmarshal 

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

type ValidatorSet 

type ValidatorSet []Validator

func NewSortedValidatorSet 

func NewSortedValidatorSet(vals []Validator) ValidatorSet

NewSortedValidatorSet returns a sorted ValidatorSet by validator's address in the ascending order

func NewValidatorSetFromBytes 

func NewValidatorSetFromBytes(vsBytes []byte) (ValidatorSet, error)

func (ValidatorSet) FindSubset 

func (vs ValidatorSet) FindSubset(bm bitmap.Bitmap) (ValidatorSet, error)

func (ValidatorSet) FindValidatorWithIndex 

func (vs ValidatorSet) FindValidatorWithIndex(valAddr sdk.ValAddress) (*Validator, int, error)

FindValidatorWithIndex returns the validator and its index an error is returned if the validator does not exist in the set

func (ValidatorSet) Marshal 

func (vs ValidatorSet) Marshal() ([]byte, error)

func (ValidatorSet) MustMarshal 

func (vs ValidatorSet) MustMarshal() []byte

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.