keeper

Documentation

Index

• Constants
• func NewMsgServerImpl(keeper Keeper) types.MsgServer
• func NewQuerier(k Keeper, legacyQuerierCdc *codec.LegacyAmino) sdk.Querier
• type Keeper
  • func NewKeeper(cdc codec.Marshaler, bk types.BankKeeper, ...) *Keeper
  • func (k Keeper) AddAccount(ctx sdk.Context, acc *types.MsgAccount) (int64, []byte)
  • func (k Keeper) AddDataProvider(ctx sdk.Context, addDataProvider *types.MsgAddDataProvider) (int64, []byte, error)
  • func (k Keeper) DistributeReward(ctx sdk.Context, msg *types.MsgFeedData, ...) error
  • func (k Keeper) EditAccount(ctx sdk.Context, acc *types.MsgEditAccount) (int64, []byte, error)
  • func (k Keeper) FeedOwnershipTransfer(ctx sdk.Context, feedOwnershipTransfer *types.MsgFeedOwnershipTransfer) (int64, []byte, error)
  • func (k Keeper) GetAccount(ctx sdk.Context, accReq *types.GetAccountRequest) *types.GetAccountResponse
  • func (k Keeper) GetAccountInfo(c context.Context, req *types.GetAccountRequest) (*types.GetAccountResponse, error)
  • func (k Keeper) GetAllModuleOwner(c context.Context, _ *types.GetModuleOwnerRequest) (*types.GetModuleOwnerResponse, error)
  • func (k Keeper) GetFeed(ctx sdk.Context, feedId string) *types.GetFeedByIdResponse
  • func (k Keeper) GetFeedByFeedId(c context.Context, req *types.GetFeedByIdRequest) (*types.GetFeedByIdResponse, error)
  • func (k Keeper) GetFeedRewardAvailStrategy(c context.Context, _ *types.GetFeedRewardAvailStrategiesRequest) (*types.GetFeedRewardAvailStrategiesResponse, error)
  • func (k Keeper) GetLatestRoundFeedDataByFilter(ctx sdk.Context, req *types.GetLatestRoundDataRequest) (*types.GetLatestRoundDataResponse, error)
  • func (k Keeper) GetLatestRoundId(ctx sdk.Context, feedId string) uint64
  • func (k Keeper) GetModuleOwnerList(ctx sdk.Context) *types.GetModuleOwnerResponse
  • func (k Keeper) GetRegisteredFeedRewardStrategies(_ sdk.Context) *types.GetFeedRewardAvailStrategiesResponse
  • func (k Keeper) GetRoundData(c context.Context, req *types.GetRoundDataRequest) (*types.GetRoundDataResponse, error)
  • func (k Keeper) GetRoundFeedDataByFilter(ctx sdk.Context, req *types.GetRoundDataRequest) (*types.GetRoundDataResponse, error)
  • func (k Keeper) LatestRoundData(c context.Context, req *types.GetLatestRoundDataRequest) (*types.GetLatestRoundDataResponse, error)
  • func (k Keeper) Logger(ctx sdk.Context) log.Logger
  • func (k Keeper) RemoveDataProvider(ctx sdk.Context, removeDataProvider *types.MsgRemoveDataProvider) (int64, []byte, error)
  • func (k Keeper) RemoveModuleOwner(ctx sdk.Context, transfer *types.MsgModuleOwnershipTransfer) (int64, []byte)
  • func (k Keeper) RequestNewRound(ctx sdk.Context, requestNewRound *types.MsgRequestNewRound) (int64, []byte, error)
  • func (k Keeper) SetDeviationThresholdTrigger(ctx sdk.Context, ...) (int64, []byte, error)
  • func (k Keeper) SetFeed(ctx sdk.Context, feed *types.MsgFeed) (int64, []byte)
  • func (k Keeper) SetFeedData(ctx sdk.Context, feedData *types.MsgFeedData) (int64, []byte, error)
  • func (k Keeper) SetFeedReward(ctx sdk.Context, setFeedReward *types.MsgSetFeedReward) (int64, []byte, error)
  • func (k Keeper) SetHeartbeatTrigger(ctx sdk.Context, setHeartbeatTrigger *types.MsgSetHeartbeatTrigger) (int64, []byte, error)
  • func (k Keeper) SetModuleOwner(ctx sdk.Context, moduleOwner *types.MsgModuleOwner) (int64, []byte)
  • func (k Keeper) SetSubmissionCount(ctx sdk.Context, setSubmissionCount *types.MsgSetSubmissionCount) (int64, []byte, error)

Constants

const (
	ErrIncorrectHeightFound = "incorrect height found"

	DataProviderSetChangeTypeAdd          = "Add"
	DataProviderSetChangeTypeRemove       = "Remove"
	FeedParamChangeTypeSubmissionCount    = "SubmissionCount"
	FeedParamChangeTypeHeartbeat          = "Heartbeat"
	FeedParamChangeTypeDeviationThreshold = "DeviationThreshold"
)

Functions

func NewMsgServerImpl

func NewMsgServerImpl(keeper Keeper) types.MsgServer

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

func NewQuerier

func NewQuerier(k Keeper, legacyQuerierCdc *codec.LegacyAmino) sdk.Querier

Types

type Keeper

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

func NewKeeper

func NewKeeper(
	cdc codec.Marshaler,
	bk types.BankKeeper,
	feedDataStoreKey,
	roundStoreKey,
	moduleOwnerStoreKey,
	feedInfoStoreKey,
	accountStoreKey,
	memKey sdk.StoreKey,
) *Keeper

func (Keeper) AddAccount

func (k Keeper) AddAccount(ctx sdk.Context, acc *types.MsgAccount) (int64, []byte)

func (Keeper) AddDataProvider

func (k Keeper) AddDataProvider(ctx sdk.Context, addDataProvider *types.MsgAddDataProvider) (int64, []byte, error)

func (Keeper) DistributeReward

func (k Keeper) DistributeReward(ctx sdk.Context, msg *types.MsgFeedData, feedRewardDecision []types.RewardPayout, totalRewardVal uint64) error

DistributeReward will mint the reward from the module then transfer the reward to the receiver (data provider)

func (Keeper) EditAccount

func (k Keeper) EditAccount(ctx sdk.Context, acc *types.MsgEditAccount) (int64, []byte, error)

func (Keeper) FeedOwnershipTransfer

func (k Keeper) FeedOwnershipTransfer(ctx sdk.Context, feedOwnershipTransfer *types.MsgFeedOwnershipTransfer) (int64, []byte, error)

func (Keeper) GetAccount

func (k Keeper) GetAccount(ctx sdk.Context, accReq *types.GetAccountRequest) *types.GetAccountResponse

func (Keeper) GetAccountInfo

func (k Keeper) GetAccountInfo(c context.Context, req *types.GetAccountRequest) (*types.GetAccountResponse, error)

func (Keeper) GetAllModuleOwner

func (k Keeper) GetAllModuleOwner(c context.Context, _ *types.GetModuleOwnerRequest) (*types.GetModuleOwnerResponse, error)

GetAllModuleOwner implements the Query/GetAllModuleOwner gRPC method

func (Keeper) GetFeed

func (k Keeper) GetFeed(ctx sdk.Context, feedId string) *types.GetFeedByIdResponse

func (Keeper) GetFeedByFeedId

func (k Keeper) GetFeedByFeedId(c context.Context, req *types.GetFeedByIdRequest) (*types.GetFeedByIdResponse, error)

func (Keeper) GetFeedRewardAvailStrategy

func (k Keeper) GetFeedRewardAvailStrategy(c context.Context, _ *types.GetFeedRewardAvailStrategiesRequest) (*types.GetFeedRewardAvailStrategiesResponse, error)

func (Keeper) GetLatestRoundFeedDataByFilter

func (k Keeper) GetLatestRoundFeedDataByFilter(ctx sdk.Context, req *types.GetLatestRoundDataRequest) (*types.GetLatestRoundDataResponse, error)

func (Keeper) GetLatestRoundId

func (k Keeper) GetLatestRoundId(ctx sdk.Context, feedId string) uint64

GetLatestRoundId returns the current existing latest roundId of a feedId returns the global latest roundId in roundStore regardless of feedId if feedId is not given.

func (Keeper) GetModuleOwnerList

func (k Keeper) GetModuleOwnerList(ctx sdk.Context) *types.GetModuleOwnerResponse

func (Keeper) GetRegisteredFeedRewardStrategies

func (k Keeper) GetRegisteredFeedRewardStrategies(_ sdk.Context) *types.GetFeedRewardAvailStrategiesResponse

func (Keeper) GetRoundData

func (k Keeper) GetRoundData(c context.Context, req *types.GetRoundDataRequest) (*types.GetRoundDataResponse, error)

GetRoundData implements the Query/GetRoundData gRPC method

func (Keeper) GetRoundFeedDataByFilter

func (k Keeper) GetRoundFeedDataByFilter(ctx sdk.Context, req *types.GetRoundDataRequest) (*types.GetRoundDataResponse, error)

func (Keeper) LatestRoundData

func (k Keeper) LatestRoundData(c context.Context, req *types.GetLatestRoundDataRequest) (*types.GetLatestRoundDataResponse, error)

LatestRoundData implements the Query/LatestRoundData gRPC method

func (Keeper) Logger

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

func (Keeper) RemoveDataProvider

func (k Keeper) RemoveDataProvider(ctx sdk.Context, removeDataProvider *types.MsgRemoveDataProvider) (int64, []byte, error)

func (Keeper) RemoveModuleOwner

func (k Keeper) RemoveModuleOwner(ctx sdk.Context, transfer *types.MsgModuleOwnershipTransfer) (int64, []byte)

func (Keeper) RequestNewRound

func (k Keeper) RequestNewRound(ctx sdk.Context, requestNewRound *types.MsgRequestNewRound) (int64, []byte, error)

RequestNewRound will be a transaction sent by the FeedOwner to request a new report to the chainlink network The event emitted will expect a data provider to submit a new report.

func (Keeper) SetDeviationThresholdTrigger

func (k Keeper) SetDeviationThresholdTrigger(ctx sdk.Context, setDeviationThresholdTrigger *types.MsgSetDeviationThresholdTrigger) (int64, []byte, error)

func (Keeper) SetFeed

func (k Keeper) SetFeed(ctx sdk.Context, feed *types.MsgFeed) (int64, []byte)

func (Keeper) SetFeedData

func (k Keeper) SetFeedData(ctx sdk.Context, feedData *types.MsgFeedData) (int64, []byte, error)

func (Keeper) SetFeedReward

func (k Keeper) SetFeedReward(ctx sdk.Context, setFeedReward *types.MsgSetFeedReward) (int64, []byte, error)

func (Keeper) SetHeartbeatTrigger

func (k Keeper) SetHeartbeatTrigger(ctx sdk.Context, setHeartbeatTrigger *types.MsgSetHeartbeatTrigger) (int64, []byte, error)

func (Keeper) SetModuleOwner

func (k Keeper) SetModuleOwner(ctx sdk.Context, moduleOwner *types.MsgModuleOwner) (int64, []byte)

func (Keeper) SetSubmissionCount

func (k Keeper) SetSubmissionCount(ctx sdk.Context, setSubmissionCount *types.MsgSetSubmissionCount) (int64, []byte, error)