keeper

Documentation

Index

• Constants
• func ParamTypeTable() param.TypeTable
• type Keeper
  • func NewKeeper(cdc *codec.Codec, storeKey sdk.StoreKey, paramSpace param.Subspace, ...) Keeper
  • func (k Keeper) DeleteProphecy(ctx sdk.Context, id string)
  • func (k *Keeper) EnablePrometheusMetrics()
  • func (k Keeper) GetConsensusNeeded(ctx sdk.Context) (consensusNeeded sdk.Dec)
  • func (k Keeper) GetProphecy(ctx sdk.Context, id string) (types.Prophecy, bool)
  • func (k Keeper) ProcessClaim(ctx sdk.Context, claim types.Claim) (types.Prophecy, sdk.Error)
  • func (k *Keeper) PublishCrossAppFailEvent(ctx sdk.Context, from string, relayerFee int64, chainId string)
  • func (k *Keeper) SetParams(ctx sdk.Context, params types.Params)
  • func (k *Keeper) SetPbsbServer(p *pubsub.Server)
  • func (k *Keeper) SubscribeParamChange(hub pTypes.ParamChangePublisher)

Constants

const (
	DefaultParamSpace = "oracle"
)

Parameter store

Functions

func ParamTypeTable

func ParamTypeTable() param.TypeTable

Types

type Keeper

type Keeper struct {
	Pool *sdk.Pool

	ScKeeper  sidechain.Keeper
	IbcKeeper ibc.Keeper
	BkKeeper  bank.Keeper

	Metrics *metrics.Metrics
	// contains filtered or unexported fields
}

Keeper maintains the link to data storage and exposes getter/setter methods for the various parts of the state machine

func NewKeeper

func NewKeeper(cdc *codec.Codec, storeKey sdk.StoreKey, paramSpace param.Subspace, stakeKeeper types.StakingKeeper,
	scKeeper sidechain.Keeper, ibcKeeper ibc.Keeper, bkKeeper bank.Keeper, pool *sdk.Pool,
) Keeper

NewKeeper creates new instances of the oracle Keeper

func (Keeper) DeleteProphecy

func (k Keeper) DeleteProphecy(ctx sdk.Context, id string)

DeleteProphecy delete prophecy for a given id

func (*Keeper) EnablePrometheusMetrics

func (k *Keeper) EnablePrometheusMetrics()

func (Keeper) GetConsensusNeeded

func (k Keeper) GetConsensusNeeded(ctx sdk.Context) (consensusNeeded sdk.Dec)

func (Keeper) GetProphecy

func (k Keeper) GetProphecy(ctx sdk.Context, id string) (types.Prophecy, bool)

GetProphecy gets the entire prophecy data struct for a given id

func (Keeper) ProcessClaim

func (k Keeper) ProcessClaim(ctx sdk.Context, claim types.Claim) (types.Prophecy, sdk.Error)

ProcessClaim ...

func (*Keeper) PublishCrossAppFailEvent

func (k *Keeper) PublishCrossAppFailEvent(ctx sdk.Context, from string, relayerFee int64, chainId string)

func (*Keeper) SetParams

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

func (*Keeper) SetPbsbServer

func (k *Keeper) SetPbsbServer(p *pubsub.Server)

func (*Keeper) SubscribeParamChange

func (k *Keeper) SubscribeParamChange(hub pTypes.ParamChangePublisher)