Versions in this module Expand all Collapse all v1 v1.7.3 Jan 2, 2023 v1.7.2 Jan 2, 2023 Changes in this version + func BuildFeedContext(ctx sdk.Context, k Keeper, feed types.Feed) (feedCtx types.FeedContext) + func NewMsgServerImpl(keeper Keeper) types.MsgServer + func NewQuerier(k Keeper, legacyQuerierCdc *codec.LegacyAmino) sdk.Querier + type Keeper struct + func NewKeeper(cdc codec.Codec, storeKey storetypes.StoreKey, paramSpace paramtypes.Subspace, ...) Keeper + func (k Keeper) CreateFeed(ctx sdk.Context, msg *types.MsgCreateFeed) error + func (k Keeper) Dequeue(ctx sdk.Context, feedName string, state servicetypes.RequestContextState) + func (k Keeper) EditFeed(ctx sdk.Context, msg *types.MsgEditFeed) error + func (k Keeper) Enqueue(ctx sdk.Context, feedName string, state servicetypes.RequestContextState) + func (k Keeper) Feed(c context.Context, req *types.QueryFeedRequest) (*types.QueryFeedResponse, error) + func (k Keeper) FeedValue(c context.Context, req *types.QueryFeedValueRequest) (*types.QueryFeedValueResponse, error) + func (k Keeper) Feeds(c context.Context, req *types.QueryFeedsRequest) (*types.QueryFeedsResponse, error) + func (k Keeper) GetFeed(ctx sdk.Context, feedName string) (feed types.Feed, found bool) + func (k Keeper) GetFeedByReqCtxID(ctx sdk.Context, requestContextID tmbytes.HexBytes) (feed types.Feed, found bool) + func (k Keeper) GetFeedValues(ctx sdk.Context, feedName string) (result types.FeedValues) + func (k Keeper) GetRequestContext(ctx sdk.Context, requestContextID tmbytes.HexBytes) (serviceexported.RequestContext, bool) + func (k Keeper) GetServiceKeeper() types.ServiceKeeper + func (k Keeper) HandlerResponse(ctx sdk.Context, requestContextID tmbytes.HexBytes, responseOutput []string, ...) + func (k Keeper) HandlerStateChanged(ctx sdk.Context, requestContextID tmbytes.HexBytes, _ string) + func (k Keeper) IteratorFeeds(ctx sdk.Context, fn func(feed types.Feed)) + func (k Keeper) IteratorFeedsByState(ctx sdk.Context, state servicetypes.RequestContextState, ...) + func (k Keeper) ModuleServiceRequest(ctx sdk.Context, input string) (result string, output string) + func (k Keeper) PauseFeed(ctx sdk.Context, msg *types.MsgPauseFeed) error + func (k Keeper) ResetFeedEntryState(ctx sdk.Context) error + func (k Keeper) SetFeed(ctx sdk.Context, feed types.Feed) + func (k Keeper) SetFeedValue(ctx sdk.Context, feedName string, batchCounter uint64, latestHistory uint64, ...) + func (k Keeper) StartFeed(ctx sdk.Context, msg *types.MsgStartFeed) error + type ValidateOracleAuthDecorator struct + func NewValidateOracleAuthDecorator(k Keeper, ak types.AuthKeeper) ValidateOracleAuthDecorator + func (dtf ValidateOracleAuthDecorator) AnteHandle(ctx sdk.Context, tx sdk.Tx, simulate bool, next sdk.AnteHandler) (sdk.Context, error)