keeper

Documentation

Index

• Constants
• func NewMsgServerImpl(keeper Keeper) types.MsgServer
• type Keeper
  • func NewKeeper(cdc codec.BinaryCodec, storeKey, memKey sdk.StoreKey, ps paramtypes.Subspace, ...) *Keeper
  • func (k Keeper) GetCurrentSnapshot(ctx sdk.Context) (*types.Snapshot, error)
  • func (k Keeper) GetParams(ctx sdk.Context) types.Params
  • func (k Keeper) GetSigningKey(ctx sdk.Context, valAddr sdk.ValAddress) crypto.PubKey
  • func (k Keeper) Heartbeat(ctx sdk.Context)
  • func (k Keeper) Logger(ctx sdk.Context) log.Logger
  • func (k Keeper) Params(c context.Context, req *types.QueryParamsRequest) (*types.QueryParamsResponse, error)
  • func (k Keeper) PunishValidator(ctx sdk.Context)
  • func (k Keeper) Register(ctx sdk.Context, msg *types.MsgRegisterConductor) error
  • func (k Keeper) RemoveExternalChainInfo(ctx sdk.Context)
  • func (k Keeper) SetParams(ctx sdk.Context, params types.Params)
  • func (k Keeper) TriggerSnapshotBuild(ctx sdk.Context) error
  • func (k Keeper) ValidatorInfo(goCtx context.Context, req *types.QueryValidatorInfoRequest) (*types.QueryValidatorInfoResponse, error)

Constants

const (
	ErrValidatorAlreadyRegistered     = whoops.String("validator is already registered")
	ErrValidatorWithAddrNotFound      = whoops.Errorf("validator with addr %s was not found")
	ErrPublicKeyOrSignatureIsInvalid  = whoops.String("public key or signature is invalid. couldn't validate the signature.")
	ErrExternalChainAlreadyRegistered = whoops.Errorf("external chain info for chain id %s with address %s already exists")
)

Functions

func NewMsgServerImpl

func NewMsgServerImpl(keeper Keeper) types.MsgServer

NewMsgServerImpl returns an implementation of the MsgServer interface for the provided Keeper.

Types

type Keeper

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

func NewKeeper

func NewKeeper(
	cdc codec.BinaryCodec,
	storeKey,
	memKey sdk.StoreKey,
	ps paramtypes.Subspace,
	staking types.StakingKeeper,

) *Keeper

func (Keeper) GetCurrentSnapshot

func (k Keeper) GetCurrentSnapshot(ctx sdk.Context) (*types.Snapshot, error)

GetCurrentSnapshot returns the currently active snapshot.

func (Keeper) GetParams

func (k Keeper) GetParams(ctx sdk.Context) types.Params

GetParams get all parameters as types.Params

func (Keeper) GetSigningKey

func (k Keeper) GetSigningKey(ctx sdk.Context, valAddr sdk.ValAddress) crypto.PubKey

GetSigningKey returns a signing key used by the conductor to sign arbitrary messages.

func (Keeper) Heartbeat

func (k Keeper) Heartbeat(ctx sdk.Context)

TODO: not required now

func (Keeper) Logger

func (k Keeper) Logger(ctx sdk.Context) log.Logger

func (Keeper) Params

func (k Keeper) Params(c context.Context, req *types.QueryParamsRequest) (*types.QueryParamsResponse, error)

func (Keeper) PunishValidator

func (k Keeper) PunishValidator(ctx sdk.Context)

TODO: not required now

func (Keeper) Register

func (k Keeper) Register(ctx sdk.Context, msg *types.MsgRegisterConductor) error

Register registers the validator as being a part of a conductor's network.

func (Keeper) RemoveExternalChainInfo

func (k Keeper) RemoveExternalChainInfo(ctx sdk.Context)

TODO: this is not required for the private alpha

func (Keeper) SetParams

func (k Keeper) SetParams(ctx sdk.Context, params types.Params)

SetParams set the params

func (Keeper) TriggerSnapshotBuild

func (k Keeper) TriggerSnapshotBuild(ctx sdk.Context) error

TriggerSnapshotBuild creates the snapshot of currently active validators that are active and registered as conductors.

func (Keeper) ValidatorInfo

func (k Keeper) ValidatorInfo(goCtx context.Context, req *types.QueryValidatorInfoRequest) (*types.QueryValidatorInfoResponse, error)

ValidatorInfo returns validator info. It's not related to a snapshot.