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) AddExternalChainInfo(ctx sdk.Context, valAddr sdk.ValAddress, ...) error
  • func (k Keeper) FindSnapshotByID(ctx sdk.Context, id uint64) (*types.Snapshot, error)
  • 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, ...) ([]byte, error)
  • func (k Keeper) GetSnapshotByID(goCtx context.Context, req *types.QueryGetSnapshotByIDRequest) (*types.QueryGetSnapshotByIDResponse, error)
  • 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) RemoveExternalChainInfo(ctx sdk.Context)
  • func (k Keeper) SetParams(ctx sdk.Context, params types.Params)
  • func (k Keeper) TriggerSnapshotBuild(ctx sdk.Context) (*types.Snapshot, error)
  • func (k Keeper) ValidatorInfo(goCtx context.Context, req *types.QueryValidatorInfoRequest) (*types.QueryValidatorInfoResponse, error)

Constants

const (
	ErrValidatorWithAddrNotFound   = whoops.Errorf("validator with addr %s was not found")
	ErrMaxNumberOfExternalAccounts = whoops.Errorf("trying to submit %d accounts while the limit is %d")

	ErrSigningKeyNotFound             = whoops.Errorf("signing key for valAddr %s, chainType %s and chainID %s not found")
	ErrExternalChainAlreadyRegistered = whoops.Errorf("external account already registered: %s, %s")
)

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 {
	SnapshotListeners []types.OnSnapshotBuiltListener
	// 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) AddExternalChainInfo

func (k Keeper) AddExternalChainInfo(ctx sdk.Context, valAddr sdk.ValAddress, newChainInfo []*types.ExternalChainInfo) error

addExternalChainInfo adds external chain info, such as this conductor's address on outside chains so that we can attribute rewards for running the jobs.

func (Keeper) FindSnapshotByID

func (k Keeper) FindSnapshotByID(ctx sdk.Context, id uint64) (*types.Snapshot, error)

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, chainType, chainID, signedByAddress string) ([]byte, error)

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

func (Keeper) GetSnapshotByID

func (k Keeper) GetSnapshotByID(goCtx context.Context, req *types.QueryGetSnapshotByIDRequest) (*types.QueryGetSnapshotByIDResponse, error)

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) 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) (*types.Snapshot, 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.