Versions in this module Expand all Collapse all v1 v1.7.4 Apr 15, 2023 v1.7.3 Apr 15, 2023 Changes in this version + const AttributeKeyCreator + const AttributeKeyFeedName + const AttributeKeyFeedValue + const AttributeKeyServiceName + const AttributeValueCategory + const DoNotModify + const EventTypeCreateFeed + const EventTypeEditFeed + const EventTypePauseFeed + const EventTypeSetFeedValue + const EventTypeStartFeed + const MaxAggregateFuncNameLen + const MaxDescriptionLen + const MaxLatestHistory + const ModuleName + const QuerierRoute + const QueryFeed + const QueryFeedValue + const QueryFeeds + const RouterKey + const StoreKey + const TypeMsgCreateFeed + const TypeMsgEditFeed + const TypeMsgPauseFeed + const TypeMsgStartFeed + var ErrExistedFeedName = sdkerrors.Register(ModuleName, 4, "feed already exists") + var ErrIntOverflowGenesis = fmt.Errorf("proto: integer overflow") + var ErrIntOverflowOracle = fmt.Errorf("proto: integer overflow") + var ErrIntOverflowQuery = fmt.Errorf("proto: integer overflow") + var ErrIntOverflowTx = fmt.Errorf("proto: integer overflow") + var ErrInvalidDescription = sdkerrors.Register(ModuleName, 7, "invalid description") + var ErrInvalidFeedName = sdkerrors.Register(ModuleName, 3, "invalid feed name") + var ErrInvalidFeedState = sdkerrors.Register(ModuleName, 9, "invalid state feed") + var ErrInvalidLengthGenesis = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrInvalidLengthOracle = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrInvalidLengthQuery = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrInvalidLengthTx = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrInvalidServiceFeeCap = sdkerrors.Register(ModuleName, 10, "service fee cap is invalid") + var ErrInvalidServiceName = sdkerrors.Register(ModuleName, 6, "invalid service name") + var ErrNotRegisterFunc = sdkerrors.Register(ModuleName, 8, "method don't register") + var ErrUnauthorized = sdkerrors.Register(ModuleName, 5, "unauthorized owner") + var ErrUnexpectedEndOfGroupGenesis = fmt.Errorf("proto: unexpected end of group") + var ErrUnexpectedEndOfGroupOracle = fmt.Errorf("proto: unexpected end of group") + var ErrUnexpectedEndOfGroupQuery = fmt.Errorf("proto: unexpected end of group") + var ErrUnexpectedEndOfGroupTx = fmt.Errorf("proto: unexpected end of group") + var ErrUnknownFeedName = sdkerrors.Register(ModuleName, 2, "unknown feed") + var ModuleCdc = codec.NewAminoCodec(amino) + var PrefixFeedKey = []byte + var PrefixFeedPauseStateKey = []byte + var PrefixFeedRunningStateKey = []byte + var PrefixFeedValueKey = []byte + var PrefixReqCtxIdKey = []byte + var RequestContextStateFromString = service.RequestContextStateFromString + func Avg(data []ArgsType) string + func GetFeedKey(feedName string) []byte + func GetFeedPrefixKey() []byte + func GetFeedStateKey(feedName string, state servicetypes.RequestContextState) []byte + func GetFeedStatePrefixKey(state servicetypes.RequestContextState) []byte + func GetFeedValueKey(feedName string, batchCounter uint64) []byte + func GetFeedValuePrefixKey(feedName string) []byte + func GetReqCtxIDKey(requestContextID []byte) []byte + func Max(data []ArgsType) string + func Min(data []ArgsType) string + func Modified(target string) bool + func RegisterAggregateFunc(methodNm string, fun Aggregate) error + func RegisterInterfaces(registry types.InterfaceRegistry) + func RegisterLegacyAminoCodec(cdc *codec.LegacyAmino) + func RegisterMsgServer(s grpc1.Server, srv MsgServer) + func RegisterQueryHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error + func RegisterQueryHandlerClient(ctx context.Context, mux *runtime.ServeMux, client QueryClient) error + func RegisterQueryHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error) + func RegisterQueryHandlerServer(ctx context.Context, mux *runtime.ServeMux, server QueryServer) error + func RegisterQueryServer(s grpc1.Server, srv QueryServer) + func ValidateAggregateFunc(aggregateFunc string) error + func ValidateCreator(creator string) error + func ValidateDescription(desc string) error + func ValidateFeedName(feedName string) error + func ValidateGenesis(data GenesisState) error + func ValidateLatestHistory(latestHistory uint64) error + func ValidateResponseThreshold(responseThreshold uint32, maxCnt int) error + func ValidateServiceFeeCap(serviceFeeCap sdk.Coins) error + func ValidateServiceName(serviceName string) error + func ValidateTimeout(timeout int64, frequency uint64) error + type AccountKeeper interface + GetAccount func(ctx sdk.Context, addr sdk.AccAddress) authtypes.AccountI + type Aggregate func(args []ArgsType) string + func GetAggregateFunc(methodNm string) (Aggregate, error) + type ArgsType = gjson.Result + type AuthKeeper interface + Authorized func(ctx sdk.Context, addr sdk.AccAddress) bool + type BankKeeper interface + SpendableCoins func(ctx sdk.Context, addr sdk.AccAddress) sdk.Coins + type Feed struct + AggregateFunc string + Creator string + Description string + FeedName string + LatestHistory uint64 + RequestContextID string + ValueJsonPath string + func (*Feed) Descriptor() ([]byte, []int) + func (*Feed) ProtoMessage() + func (m *Feed) GetAggregateFunc() string + func (m *Feed) GetCreator() string + func (m *Feed) GetDescription() string + func (m *Feed) GetFeedName() string + func (m *Feed) GetLatestHistory() uint64 + func (m *Feed) GetRequestContextID() string + func (m *Feed) GetValueJsonPath() string + func (m *Feed) Marshal() (dAtA []byte, err error) + func (m *Feed) MarshalTo(dAtA []byte) (int, error) + func (m *Feed) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Feed) Reset() + func (m *Feed) Size() (n int) + func (m *Feed) String() string + func (m *Feed) Unmarshal(dAtA []byte) error + func (m *Feed) XXX_DiscardUnknown() + func (m *Feed) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Feed) XXX_Merge(src proto.Message) + func (m *Feed) XXX_Size() int + func (m *Feed) XXX_Unmarshal(b []byte) error + type FeedContext struct + Feed *Feed + Input string + Providers []string + RepeatedFrequency uint64 + ResponseThreshold uint32 + ServiceFeeCap github_com_cosmos_cosmos_sdk_types.Coins + ServiceName string + State types1.RequestContextState + Timeout int64 + func (*FeedContext) Descriptor() ([]byte, []int) + func (*FeedContext) ProtoMessage() + func (f FeedContext) String() string + func (m *FeedContext) GetFeed() *Feed + func (m *FeedContext) GetInput() string + func (m *FeedContext) GetProviders() []string + func (m *FeedContext) GetRepeatedFrequency() uint64 + func (m *FeedContext) GetResponseThreshold() uint32 + func (m *FeedContext) GetServiceFeeCap() github_com_cosmos_cosmos_sdk_types.Coins + func (m *FeedContext) GetServiceName() string + func (m *FeedContext) GetState() types1.RequestContextState + func (m *FeedContext) GetTimeout() int64 + func (m *FeedContext) Marshal() (dAtA []byte, err error) + func (m *FeedContext) MarshalTo(dAtA []byte) (int, error) + func (m *FeedContext) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *FeedContext) Reset() + func (m *FeedContext) Size() (n int) + func (m *FeedContext) Unmarshal(dAtA []byte) error + func (m *FeedContext) XXX_DiscardUnknown() + func (m *FeedContext) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *FeedContext) XXX_Merge(src proto.Message) + func (m *FeedContext) XXX_Size() int + func (m *FeedContext) XXX_Unmarshal(b []byte) error + type FeedEntry struct + Feed Feed + State types.RequestContextState + Values []FeedValue + func (*FeedEntry) Descriptor() ([]byte, []int) + func (*FeedEntry) ProtoMessage() + func (m *FeedEntry) GetFeed() Feed + func (m *FeedEntry) GetState() types.RequestContextState + func (m *FeedEntry) GetValues() []FeedValue + func (m *FeedEntry) Marshal() (dAtA []byte, err error) + func (m *FeedEntry) MarshalTo(dAtA []byte) (int, error) + func (m *FeedEntry) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *FeedEntry) Reset() + func (m *FeedEntry) Size() (n int) + func (m *FeedEntry) String() string + func (m *FeedEntry) Unmarshal(dAtA []byte) error + func (m *FeedEntry) XXX_DiscardUnknown() + func (m *FeedEntry) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *FeedEntry) XXX_Merge(src proto.Message) + func (m *FeedEntry) XXX_Size() int + func (m *FeedEntry) XXX_Unmarshal(b []byte) error + type FeedValue struct + Data string + Timestamp time.Time + func (*FeedValue) Descriptor() ([]byte, []int) + func (*FeedValue) ProtoMessage() + func (m *FeedValue) GetData() string + func (m *FeedValue) GetTimestamp() time.Time + func (m *FeedValue) Marshal() (dAtA []byte, err error) + func (m *FeedValue) MarshalTo(dAtA []byte) (int, error) + func (m *FeedValue) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *FeedValue) Reset() + func (m *FeedValue) Size() (n int) + func (m *FeedValue) String() string + func (m *FeedValue) Unmarshal(dAtA []byte) error + func (m *FeedValue) XXX_DiscardUnknown() + func (m *FeedValue) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *FeedValue) XXX_Merge(src proto.Message) + func (m *FeedValue) XXX_Size() int + func (m *FeedValue) XXX_Unmarshal(b []byte) error + type FeedValues []FeedValue + func (fv FeedValues) String() string + type FeedsContext []FeedContext + func (fc FeedsContext) String() string + type GenesisState struct + Entries []FeedEntry + func DefaultGenesisState() *GenesisState + func (*GenesisState) Descriptor() ([]byte, []int) + func (*GenesisState) ProtoMessage() + func (m *GenesisState) GetEntries() []FeedEntry + func (m *GenesisState) Marshal() (dAtA []byte, err error) + func (m *GenesisState) MarshalTo(dAtA []byte) (int, error) + func (m *GenesisState) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *GenesisState) Reset() + func (m *GenesisState) Size() (n int) + func (m *GenesisState) String() string + func (m *GenesisState) Unmarshal(dAtA []byte) error + func (m *GenesisState) XXX_DiscardUnknown() + func (m *GenesisState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GenesisState) XXX_Merge(src proto.Message) + func (m *GenesisState) XXX_Size() int + func (m *GenesisState) XXX_Unmarshal(b []byte) error + type MsgClient interface + CreateFeed func(ctx context.Context, in *MsgCreateFeed, opts ...grpc.CallOption) (*MsgCreateFeedResponse, error) + EditFeed func(ctx context.Context, in *MsgEditFeed, opts ...grpc.CallOption) (*MsgEditFeedResponse, error) + PauseFeed func(ctx context.Context, in *MsgPauseFeed, opts ...grpc.CallOption) (*MsgPauseFeedResponse, error) + StartFeed func(ctx context.Context, in *MsgStartFeed, opts ...grpc.CallOption) (*MsgStartFeedResponse, error) + func NewMsgClient(cc grpc1.ClientConn) MsgClient + type MsgCreateFeed struct + AggregateFunc string + Creator string + Description string + FeedName string + Input string + LatestHistory uint64 + Providers []string + RepeatedFrequency uint64 + ResponseThreshold uint32 + ServiceFeeCap github_com_cosmos_cosmos_sdk_types.Coins + ServiceName string + Timeout int64 + ValueJsonPath string + func (*MsgCreateFeed) Descriptor() ([]byte, []int) + func (*MsgCreateFeed) ProtoMessage() + func (m *MsgCreateFeed) GetAggregateFunc() string + func (m *MsgCreateFeed) GetCreator() string + func (m *MsgCreateFeed) GetDescription() string + func (m *MsgCreateFeed) GetFeedName() string + func (m *MsgCreateFeed) GetInput() string + func (m *MsgCreateFeed) GetLatestHistory() uint64 + func (m *MsgCreateFeed) GetProviders() []string + func (m *MsgCreateFeed) GetRepeatedFrequency() uint64 + func (m *MsgCreateFeed) GetResponseThreshold() uint32 + func (m *MsgCreateFeed) GetServiceFeeCap() github_com_cosmos_cosmos_sdk_types.Coins + func (m *MsgCreateFeed) GetServiceName() string + func (m *MsgCreateFeed) GetTimeout() int64 + func (m *MsgCreateFeed) GetValueJsonPath() string + func (m *MsgCreateFeed) Marshal() (dAtA []byte, err error) + func (m *MsgCreateFeed) MarshalTo(dAtA []byte) (int, error) + func (m *MsgCreateFeed) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *MsgCreateFeed) Reset() + func (m *MsgCreateFeed) Size() (n int) + func (m *MsgCreateFeed) String() string + func (m *MsgCreateFeed) Unmarshal(dAtA []byte) error + func (m *MsgCreateFeed) XXX_DiscardUnknown() + func (m *MsgCreateFeed) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *MsgCreateFeed) XXX_Merge(src proto.Message) + func (m *MsgCreateFeed) XXX_Size() int + func (m *MsgCreateFeed) XXX_Unmarshal(b []byte) error + func (msg MsgCreateFeed) GetSignBytes() []byte + func (msg MsgCreateFeed) GetSigners() []sdk.AccAddress + func (msg MsgCreateFeed) Route() string + func (msg MsgCreateFeed) Type() string + func (msg MsgCreateFeed) ValidateBasic() error + type MsgCreateFeedResponse struct + func (*MsgCreateFeedResponse) Descriptor() ([]byte, []int) + func (*MsgCreateFeedResponse) ProtoMessage() + func (m *MsgCreateFeedResponse) Marshal() (dAtA []byte, err error) + func (m *MsgCreateFeedResponse) MarshalTo(dAtA []byte) (int, error) + func (m *MsgCreateFeedResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *MsgCreateFeedResponse) Reset() + func (m *MsgCreateFeedResponse) Size() (n int) + func (m *MsgCreateFeedResponse) String() string + func (m *MsgCreateFeedResponse) Unmarshal(dAtA []byte) error + func (m *MsgCreateFeedResponse) XXX_DiscardUnknown() + func (m *MsgCreateFeedResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *MsgCreateFeedResponse) XXX_Merge(src proto.Message) + func (m *MsgCreateFeedResponse) XXX_Size() int + func (m *MsgCreateFeedResponse) XXX_Unmarshal(b []byte) error + type MsgEditFeed struct + Creator string + Description string + FeedName string + LatestHistory uint64 + Providers []string + RepeatedFrequency uint64 + ResponseThreshold uint32 + ServiceFeeCap github_com_cosmos_cosmos_sdk_types.Coins + Timeout int64 + func (*MsgEditFeed) Descriptor() ([]byte, []int) + func (*MsgEditFeed) ProtoMessage() + func (m *MsgEditFeed) GetCreator() string + func (m *MsgEditFeed) GetDescription() string + func (m *MsgEditFeed) GetFeedName() string + func (m *MsgEditFeed) GetLatestHistory() uint64 + func (m *MsgEditFeed) GetProviders() []string + func (m *MsgEditFeed) GetRepeatedFrequency() uint64 + func (m *MsgEditFeed) GetResponseThreshold() uint32 + func (m *MsgEditFeed) GetServiceFeeCap() github_com_cosmos_cosmos_sdk_types.Coins + func (m *MsgEditFeed) GetTimeout() int64 + func (m *MsgEditFeed) Marshal() (dAtA []byte, err error) + func (m *MsgEditFeed) MarshalTo(dAtA []byte) (int, error) + func (m *MsgEditFeed) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *MsgEditFeed) Reset() + func (m *MsgEditFeed) Size() (n int) + func (m *MsgEditFeed) String() string + func (m *MsgEditFeed) Unmarshal(dAtA []byte) error + func (m *MsgEditFeed) XXX_DiscardUnknown() + func (m *MsgEditFeed) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *MsgEditFeed) XXX_Merge(src proto.Message) + func (m *MsgEditFeed) XXX_Size() int + func (m *MsgEditFeed) XXX_Unmarshal(b []byte) error + func (msg MsgEditFeed) GetSignBytes() []byte + func (msg MsgEditFeed) GetSigners() []sdk.AccAddress + func (msg MsgEditFeed) Route() string + func (msg MsgEditFeed) Type() string + func (msg MsgEditFeed) ValidateBasic() error + type MsgEditFeedResponse struct + func (*MsgEditFeedResponse) Descriptor() ([]byte, []int) + func (*MsgEditFeedResponse) ProtoMessage() + func (m *MsgEditFeedResponse) Marshal() (dAtA []byte, err error) + func (m *MsgEditFeedResponse) MarshalTo(dAtA []byte) (int, error) + func (m *MsgEditFeedResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *MsgEditFeedResponse) Reset() + func (m *MsgEditFeedResponse) Size() (n int) + func (m *MsgEditFeedResponse) String() string + func (m *MsgEditFeedResponse) Unmarshal(dAtA []byte) error + func (m *MsgEditFeedResponse) XXX_DiscardUnknown() + func (m *MsgEditFeedResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *MsgEditFeedResponse) XXX_Merge(src proto.Message) + func (m *MsgEditFeedResponse) XXX_Size() int + func (m *MsgEditFeedResponse) XXX_Unmarshal(b []byte) error + type MsgPauseFeed struct + Creator string + FeedName string + func (*MsgPauseFeed) Descriptor() ([]byte, []int) + func (*MsgPauseFeed) ProtoMessage() + func (m *MsgPauseFeed) GetCreator() string + func (m *MsgPauseFeed) GetFeedName() string + func (m *MsgPauseFeed) Marshal() (dAtA []byte, err error) + func (m *MsgPauseFeed) MarshalTo(dAtA []byte) (int, error) + func (m *MsgPauseFeed) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *MsgPauseFeed) Reset() + func (m *MsgPauseFeed) Size() (n int) + func (m *MsgPauseFeed) String() string + func (m *MsgPauseFeed) Unmarshal(dAtA []byte) error + func (m *MsgPauseFeed) XXX_DiscardUnknown() + func (m *MsgPauseFeed) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *MsgPauseFeed) XXX_Merge(src proto.Message) + func (m *MsgPauseFeed) XXX_Size() int + func (m *MsgPauseFeed) XXX_Unmarshal(b []byte) error + func (msg MsgPauseFeed) GetSignBytes() []byte + func (msg MsgPauseFeed) GetSigners() []sdk.AccAddress + func (msg MsgPauseFeed) Route() string + func (msg MsgPauseFeed) Type() string + func (msg MsgPauseFeed) ValidateBasic() error + type MsgPauseFeedResponse struct + func (*MsgPauseFeedResponse) Descriptor() ([]byte, []int) + func (*MsgPauseFeedResponse) ProtoMessage() + func (m *MsgPauseFeedResponse) Marshal() (dAtA []byte, err error) + func (m *MsgPauseFeedResponse) MarshalTo(dAtA []byte) (int, error) + func (m *MsgPauseFeedResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *MsgPauseFeedResponse) Reset() + func (m *MsgPauseFeedResponse) Size() (n int) + func (m *MsgPauseFeedResponse) String() string + func (m *MsgPauseFeedResponse) Unmarshal(dAtA []byte) error + func (m *MsgPauseFeedResponse) XXX_DiscardUnknown() + func (m *MsgPauseFeedResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *MsgPauseFeedResponse) XXX_Merge(src proto.Message) + func (m *MsgPauseFeedResponse) XXX_Size() int + func (m *MsgPauseFeedResponse) XXX_Unmarshal(b []byte) error + type MsgServer interface + CreateFeed func(context.Context, *MsgCreateFeed) (*MsgCreateFeedResponse, error) + EditFeed func(context.Context, *MsgEditFeed) (*MsgEditFeedResponse, error) + PauseFeed func(context.Context, *MsgPauseFeed) (*MsgPauseFeedResponse, error) + StartFeed func(context.Context, *MsgStartFeed) (*MsgStartFeedResponse, error) + type MsgStartFeed struct + Creator string + FeedName string + func (*MsgStartFeed) Descriptor() ([]byte, []int) + func (*MsgStartFeed) ProtoMessage() + func (m *MsgStartFeed) GetCreator() string + func (m *MsgStartFeed) GetFeedName() string + func (m *MsgStartFeed) Marshal() (dAtA []byte, err error) + func (m *MsgStartFeed) MarshalTo(dAtA []byte) (int, error) + func (m *MsgStartFeed) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *MsgStartFeed) Reset() + func (m *MsgStartFeed) Size() (n int) + func (m *MsgStartFeed) String() string + func (m *MsgStartFeed) Unmarshal(dAtA []byte) error + func (m *MsgStartFeed) XXX_DiscardUnknown() + func (m *MsgStartFeed) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *MsgStartFeed) XXX_Merge(src proto.Message) + func (m *MsgStartFeed) XXX_Size() int + func (m *MsgStartFeed) XXX_Unmarshal(b []byte) error + func (msg MsgStartFeed) GetSignBytes() []byte + func (msg MsgStartFeed) GetSigners() []sdk.AccAddress + func (msg MsgStartFeed) Route() string + func (msg MsgStartFeed) Type() string + func (msg MsgStartFeed) ValidateBasic() error + type MsgStartFeedResponse struct + func (*MsgStartFeedResponse) Descriptor() ([]byte, []int) + func (*MsgStartFeedResponse) ProtoMessage() + func (m *MsgStartFeedResponse) Marshal() (dAtA []byte, err error) + func (m *MsgStartFeedResponse) MarshalTo(dAtA []byte) (int, error) + func (m *MsgStartFeedResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *MsgStartFeedResponse) Reset() + func (m *MsgStartFeedResponse) Size() (n int) + func (m *MsgStartFeedResponse) String() string + func (m *MsgStartFeedResponse) Unmarshal(dAtA []byte) error + func (m *MsgStartFeedResponse) XXX_DiscardUnknown() + func (m *MsgStartFeedResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *MsgStartFeedResponse) XXX_Merge(src proto.Message) + func (m *MsgStartFeedResponse) XXX_Size() int + func (m *MsgStartFeedResponse) XXX_Unmarshal(b []byte) error + type QueryClient interface + Feed func(ctx context.Context, in *QueryFeedRequest, opts ...grpc.CallOption) (*QueryFeedResponse, error) + FeedValue func(ctx context.Context, in *QueryFeedValueRequest, opts ...grpc.CallOption) (*QueryFeedValueResponse, error) + Feeds func(ctx context.Context, in *QueryFeedsRequest, opts ...grpc.CallOption) (*QueryFeedsResponse, error) + func NewQueryClient(cc grpc1.ClientConn) QueryClient + type QueryFeedParams struct + FeedName string + type QueryFeedRequest struct + FeedName string + func (*QueryFeedRequest) Descriptor() ([]byte, []int) + func (*QueryFeedRequest) ProtoMessage() + func (m *QueryFeedRequest) GetFeedName() string + func (m *QueryFeedRequest) Marshal() (dAtA []byte, err error) + func (m *QueryFeedRequest) MarshalTo(dAtA []byte) (int, error) + func (m *QueryFeedRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *QueryFeedRequest) Reset() + func (m *QueryFeedRequest) Size() (n int) + func (m *QueryFeedRequest) String() string + func (m *QueryFeedRequest) Unmarshal(dAtA []byte) error + func (m *QueryFeedRequest) XXX_DiscardUnknown() + func (m *QueryFeedRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *QueryFeedRequest) XXX_Merge(src proto.Message) + func (m *QueryFeedRequest) XXX_Size() int + func (m *QueryFeedRequest) XXX_Unmarshal(b []byte) error + type QueryFeedResponse struct + Feed FeedContext + func (*QueryFeedResponse) Descriptor() ([]byte, []int) + func (*QueryFeedResponse) ProtoMessage() + func (m *QueryFeedResponse) GetFeed() FeedContext + func (m *QueryFeedResponse) Marshal() (dAtA []byte, err error) + func (m *QueryFeedResponse) MarshalTo(dAtA []byte) (int, error) + func (m *QueryFeedResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *QueryFeedResponse) Reset() + func (m *QueryFeedResponse) Size() (n int) + func (m *QueryFeedResponse) String() string + func (m *QueryFeedResponse) Unmarshal(dAtA []byte) error + func (m *QueryFeedResponse) XXX_DiscardUnknown() + func (m *QueryFeedResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *QueryFeedResponse) XXX_Merge(src proto.Message) + func (m *QueryFeedResponse) XXX_Size() int + func (m *QueryFeedResponse) XXX_Unmarshal(b []byte) error + type QueryFeedValueParams struct + FeedName string + type QueryFeedValueRequest struct + FeedName string + func (*QueryFeedValueRequest) Descriptor() ([]byte, []int) + func (*QueryFeedValueRequest) ProtoMessage() + func (m *QueryFeedValueRequest) GetFeedName() string + func (m *QueryFeedValueRequest) Marshal() (dAtA []byte, err error) + func (m *QueryFeedValueRequest) MarshalTo(dAtA []byte) (int, error) + func (m *QueryFeedValueRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *QueryFeedValueRequest) Reset() + func (m *QueryFeedValueRequest) Size() (n int) + func (m *QueryFeedValueRequest) String() string + func (m *QueryFeedValueRequest) Unmarshal(dAtA []byte) error + func (m *QueryFeedValueRequest) XXX_DiscardUnknown() + func (m *QueryFeedValueRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *QueryFeedValueRequest) XXX_Merge(src proto.Message) + func (m *QueryFeedValueRequest) XXX_Size() int + func (m *QueryFeedValueRequest) XXX_Unmarshal(b []byte) error + type QueryFeedValueResponse struct + FeedValues []FeedValue + func (*QueryFeedValueResponse) Descriptor() ([]byte, []int) + func (*QueryFeedValueResponse) ProtoMessage() + func (m *QueryFeedValueResponse) GetFeedValues() []FeedValue + func (m *QueryFeedValueResponse) Marshal() (dAtA []byte, err error) + func (m *QueryFeedValueResponse) MarshalTo(dAtA []byte) (int, error) + func (m *QueryFeedValueResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *QueryFeedValueResponse) Reset() + func (m *QueryFeedValueResponse) Size() (n int) + func (m *QueryFeedValueResponse) String() string + func (m *QueryFeedValueResponse) Unmarshal(dAtA []byte) error + func (m *QueryFeedValueResponse) XXX_DiscardUnknown() + func (m *QueryFeedValueResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *QueryFeedValueResponse) XXX_Merge(src proto.Message) + func (m *QueryFeedValueResponse) XXX_Size() int + func (m *QueryFeedValueResponse) XXX_Unmarshal(b []byte) error + type QueryFeedsParams struct + State string + type QueryFeedsRequest struct + Pagination *query.PageRequest + State string + func (*QueryFeedsRequest) Descriptor() ([]byte, []int) + func (*QueryFeedsRequest) ProtoMessage() + func (m *QueryFeedsRequest) GetPagination() *query.PageRequest + func (m *QueryFeedsRequest) GetState() string + func (m *QueryFeedsRequest) Marshal() (dAtA []byte, err error) + func (m *QueryFeedsRequest) MarshalTo(dAtA []byte) (int, error) + func (m *QueryFeedsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *QueryFeedsRequest) Reset() + func (m *QueryFeedsRequest) Size() (n int) + func (m *QueryFeedsRequest) String() string + func (m *QueryFeedsRequest) Unmarshal(dAtA []byte) error + func (m *QueryFeedsRequest) XXX_DiscardUnknown() + func (m *QueryFeedsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *QueryFeedsRequest) XXX_Merge(src proto.Message) + func (m *QueryFeedsRequest) XXX_Size() int + func (m *QueryFeedsRequest) XXX_Unmarshal(b []byte) error + type QueryFeedsResponse struct + Feeds []FeedContext + Pagination *query.PageResponse + func (*QueryFeedsResponse) Descriptor() ([]byte, []int) + func (*QueryFeedsResponse) ProtoMessage() + func (m *QueryFeedsResponse) GetFeeds() []FeedContext + func (m *QueryFeedsResponse) GetPagination() *query.PageResponse + func (m *QueryFeedsResponse) Marshal() (dAtA []byte, err error) + func (m *QueryFeedsResponse) MarshalTo(dAtA []byte) (int, error) + func (m *QueryFeedsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *QueryFeedsResponse) Reset() + func (m *QueryFeedsResponse) Size() (n int) + func (m *QueryFeedsResponse) String() string + func (m *QueryFeedsResponse) Unmarshal(dAtA []byte) error + func (m *QueryFeedsResponse) XXX_DiscardUnknown() + func (m *QueryFeedsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *QueryFeedsResponse) XXX_Merge(src proto.Message) + func (m *QueryFeedsResponse) XXX_Size() int + func (m *QueryFeedsResponse) XXX_Unmarshal(b []byte) error + type QueryServer interface + Feed func(context.Context, *QueryFeedRequest) (*QueryFeedResponse, error) + FeedValue func(context.Context, *QueryFeedValueRequest) (*QueryFeedValueResponse, error) + Feeds func(context.Context, *QueryFeedsRequest) (*QueryFeedsResponse, error) + type ServiceKeeper interface + AddServiceBinding func(ctx sdk.Context, serviceName string, provider sdk.AccAddress, ...) error + AddServiceDefinition func(ctx sdk.Context, name, description string, tags []string, ...) error + CreateRequestContext func(ctx sdk.Context, serviceName string, providers []sdk.AccAddress, ...) (tmbytes.HexBytes, error) + GetRequestContext func(ctx sdk.Context, requestContextID tmbytes.HexBytes) (service.RequestContext, bool) + PauseRequestContext func(ctx sdk.Context, requestContextID tmbytes.HexBytes, consumer sdk.AccAddress) error + RegisterModuleService func(moduleName string, moduleService *service.ModuleService) error + RegisterResponseCallback func(moduleName string, respCallback service.ResponseCallback) error + RegisterStateCallback func(moduleName string, stateCallback service.StateCallback) error + StartRequestContext func(ctx sdk.Context, requestContextID tmbytes.HexBytes, consumer sdk.AccAddress) error + UpdateRequestContext func(ctx sdk.Context, requestContextID tmbytes.HexBytes, providers []sdk.AccAddress, ...) error + type UnimplementedMsgServer struct + func (*UnimplementedMsgServer) CreateFeed(ctx context.Context, req *MsgCreateFeed) (*MsgCreateFeedResponse, error) + func (*UnimplementedMsgServer) EditFeed(ctx context.Context, req *MsgEditFeed) (*MsgEditFeedResponse, error) + func (*UnimplementedMsgServer) PauseFeed(ctx context.Context, req *MsgPauseFeed) (*MsgPauseFeedResponse, error) + func (*UnimplementedMsgServer) StartFeed(ctx context.Context, req *MsgStartFeed) (*MsgStartFeedResponse, error) + type UnimplementedQueryServer struct + func (*UnimplementedQueryServer) Feed(ctx context.Context, req *QueryFeedRequest) (*QueryFeedResponse, error) + func (*UnimplementedQueryServer) FeedValue(ctx context.Context, req *QueryFeedValueRequest) (*QueryFeedValueResponse, error) + func (*UnimplementedQueryServer) Feeds(ctx context.Context, req *QueryFeedsRequest) (*QueryFeedsResponse, error)