Documentation ¶
Index ¶
- func BuildFeedContext(ctx sdk.Context, k Keeper, feed types.Feed) (feedCtx types.FeedContext)
- func NewQuerier(k Keeper, legacyQuerierCdc codec.JSONMarshaler) sdk.Querier
- type 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) (servicetypes.RequestContext, bool)
- 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) 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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func BuildFeedContext ¶
func NewQuerier ¶
func NewQuerier(k Keeper, legacyQuerierCdc codec.JSONMarshaler) sdk.Querier
NewQuerier creates a querier for the oracle module
Types ¶
type Keeper ¶
type Keeper struct {
// contains filtered or unexported fields
}
Keeper
func NewKeeper ¶
func NewKeeper( cdc codec.Marshaler, storeKey sdk.StoreKey, paramSpace paramtypes.Subspace, gk types.GuardianKeeper, sk types.ServiceKeeper, ) Keeper
NewKeeper
func (Keeper) CreateFeed ¶
CreateFeed create a stopped feed
func (Keeper) Dequeue ¶
func (k Keeper) Dequeue(ctx sdk.Context, feedName string, state servicetypes.RequestContextState)
Dequeue will remove from the 'state' queue
func (Keeper) Enqueue ¶
func (k Keeper) Enqueue(ctx sdk.Context, feedName string, state servicetypes.RequestContextState)
Enqueue will put feedName to a 'state' queue
func (Keeper) Feed ¶
func (k Keeper) Feed(c context.Context, req *types.QueryFeedRequest) (*types.QueryFeedResponse, error)
Feed queries a feed by feed name
func (Keeper) FeedValue ¶
func (k Keeper) FeedValue(c context.Context, req *types.QueryFeedValueRequest) (*types.QueryFeedValueResponse, error)
func (Keeper) Feeds ¶
func (k Keeper) Feeds(c context.Context, req *types.QueryFeedsRequest) (*types.QueryFeedsResponse, error)
func (Keeper) GetFeedByReqCtxID ¶
func (k Keeper) GetFeedByReqCtxID(ctx sdk.Context, requestContextID tmbytes.HexBytes) (feed types.Feed, found bool)
GetFeedByReqCtxID return feed by requestContextID
func (Keeper) GetFeedValues ¶
GetFeedValues return all feed values by feedName
func (Keeper) GetRequestContext ¶
func (k Keeper) GetRequestContext(ctx sdk.Context, requestContextID tmbytes.HexBytes) (servicetypes.RequestContext, bool)
func (Keeper) HandlerResponse ¶
func (k Keeper) HandlerResponse(ctx sdk.Context, requestContextID tmbytes.HexBytes, responseOutput []string, err error)
HandlerResponse is responsible for processing the data returned from the servicetypes module, processed by the aggregate function, and then saved
func (Keeper) HandlerStateChanged ¶
HandlerStateChanged is responsible for update feed state
func (Keeper) IteratorFeeds ¶
IteratorFeeds will foreach all feeds
func (Keeper) IteratorFeedsByState ¶
func (k Keeper) IteratorFeedsByState( ctx sdk.Context, state servicetypes.RequestContextState, fn func(feed types.Feed), )
IteratorFeedsByState will foreach all feeds by state
Click to show internal directories.
Click to hide internal directories.