keeper

package

v0.0.0-...-7183b0c Latest Latest Go to latest Published: Sep 15, 2021 License: MIT Imports: 12 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/ChainSafe/chainlink-cosmos

Links

Open Source Insights

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

Constants ¶

View Source

const (
	ErrIncorrectHeightFound = "incorrect height found"

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

Variables ¶

This section is empty.

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)

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL