Documentation ¶
Index ¶
- Constants
- Variables
- func RegisterInterfaces(registry types.InterfaceRegistry)
- func RegisterMsgServer(s grpc1.Server, srv MsgServer)
- func RegisterQueryServer(s grpc1.Server, srv QueryServer)
- type Client
- type CreateFeedRequest
- type EditFeedRequest
- type Feed
- func (*Feed) Descriptor() ([]byte, []int)
- 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 (*Feed) ProtoMessage()
- 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
- func (f FeedContext) Convert() interface{}
- func (*FeedContext) Descriptor() ([]byte, []int)
- 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_irisnet_core_sdk_go_types.Coins
- func (m *FeedContext) GetServiceName() string
- func (m *FeedContext) GetState() service.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 (*FeedContext) ProtoMessage()
- func (m *FeedContext) Reset()
- func (m *FeedContext) Size() (n int)
- func (m *FeedContext) String() string
- 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 FeedValue
- func (*FeedValue) Descriptor() ([]byte, []int)
- 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 (*FeedValue) ProtoMessage()
- 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
- type Feeds
- type MsgClient
- type MsgCreateFeed
- func (*MsgCreateFeed) Descriptor() ([]byte, []int)
- 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_irisnet_core_sdk_go_types.Coins
- func (m *MsgCreateFeed) GetServiceName() string
- func (m MsgCreateFeed) GetSignBytes() []byte
- func (m MsgCreateFeed) GetSigners() []sdk.AccAddress
- 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 (*MsgCreateFeed) ProtoMessage()
- func (m *MsgCreateFeed) Reset()
- func (m MsgCreateFeed) Route() string
- func (m *MsgCreateFeed) Size() (n int)
- func (m *MsgCreateFeed) String() string
- func (m MsgCreateFeed) Type() string
- func (m *MsgCreateFeed) Unmarshal(dAtA []byte) error
- func (m MsgCreateFeed) ValidateBasic() 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
- type MsgCreateFeedResponse
- func (*MsgCreateFeedResponse) Descriptor() ([]byte, []int)
- 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 (*MsgCreateFeedResponse) ProtoMessage()
- 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
- func (*MsgEditFeed) Descriptor() ([]byte, []int)
- 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_irisnet_core_sdk_go_types.Coins
- func (m MsgEditFeed) GetSignBytes() []byte
- func (m MsgEditFeed) GetSigners() []sdk.AccAddress
- 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 (*MsgEditFeed) ProtoMessage()
- func (m *MsgEditFeed) Reset()
- func (m MsgEditFeed) Route() string
- func (m *MsgEditFeed) Size() (n int)
- func (m *MsgEditFeed) String() string
- func (m MsgEditFeed) Type() string
- func (m *MsgEditFeed) Unmarshal(dAtA []byte) error
- func (m MsgEditFeed) ValidateBasic() 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
- type MsgEditFeedResponse
- func (*MsgEditFeedResponse) Descriptor() ([]byte, []int)
- 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 (*MsgEditFeedResponse) ProtoMessage()
- 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
- func (*MsgPauseFeed) Descriptor() ([]byte, []int)
- func (m *MsgPauseFeed) GetCreator() string
- func (m *MsgPauseFeed) GetFeedName() string
- func (m MsgPauseFeed) GetSignBytes() []byte
- func (m MsgPauseFeed) GetSigners() []sdk.AccAddress
- 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 (*MsgPauseFeed) ProtoMessage()
- func (m *MsgPauseFeed) Reset()
- func (m MsgPauseFeed) Route() string
- func (m *MsgPauseFeed) Size() (n int)
- func (m *MsgPauseFeed) String() string
- func (m MsgPauseFeed) Type() string
- func (m *MsgPauseFeed) Unmarshal(dAtA []byte) error
- func (m MsgPauseFeed) ValidateBasic() 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
- type MsgPauseFeedResponse
- func (*MsgPauseFeedResponse) Descriptor() ([]byte, []int)
- 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 (*MsgPauseFeedResponse) ProtoMessage()
- 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
- type MsgStartFeed
- func (*MsgStartFeed) Descriptor() ([]byte, []int)
- func (m *MsgStartFeed) GetCreator() string
- func (m *MsgStartFeed) GetFeedName() string
- func (m MsgStartFeed) GetSignBytes() []byte
- func (m MsgStartFeed) GetSigners() []sdk.AccAddress
- 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 (*MsgStartFeed) ProtoMessage()
- func (m *MsgStartFeed) Reset()
- func (m MsgStartFeed) Route() string
- func (m *MsgStartFeed) Size() (n int)
- func (m *MsgStartFeed) String() string
- func (m MsgStartFeed) Type() string
- func (m *MsgStartFeed) Unmarshal(dAtA []byte) error
- func (m MsgStartFeed) ValidateBasic() 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
- type MsgStartFeedResponse
- func (*MsgStartFeedResponse) Descriptor() ([]byte, []int)
- 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 (*MsgStartFeedResponse) ProtoMessage()
- 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
- type QueryFeedRequest
- func (*QueryFeedRequest) Descriptor() ([]byte, []int)
- 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 (*QueryFeedRequest) ProtoMessage()
- 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 QueryFeedResp
- type QueryFeedResponse
- func (*QueryFeedResponse) Descriptor() ([]byte, []int)
- 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 (*QueryFeedResponse) ProtoMessage()
- 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 QueryFeedValueRequest
- func (*QueryFeedValueRequest) Descriptor() ([]byte, []int)
- 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 (*QueryFeedValueRequest) ProtoMessage()
- 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 QueryFeedValueResp
- type QueryFeedValueResponse
- func (*QueryFeedValueResponse) Descriptor() ([]byte, []int)
- 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 (*QueryFeedValueResponse) ProtoMessage()
- 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 QueryFeedsRequest
- func (*QueryFeedsRequest) Descriptor() ([]byte, []int)
- 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 (*QueryFeedsRequest) ProtoMessage()
- 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
- func (*QueryFeedsResponse) Descriptor() ([]byte, []int)
- 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 (*QueryFeedsResponse) ProtoMessage()
- 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
- type UnimplementedMsgServer
- 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
- 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)
Constants ¶
const (
ModuleName = "oracle"
)
Variables ¶
var ( ErrInvalidLengthOracle = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowOracle = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupOracle = fmt.Errorf("proto: unexpected end of group") )
var ( ErrInvalidLengthQuery = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowQuery = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupQuery = fmt.Errorf("proto: unexpected end of group") )
var ( ErrInvalidLengthTx = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowTx = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupTx = fmt.Errorf("proto: unexpected end of group") )
var (
ModuleCdc = codec.NewAminoCodec(amino)
)
Functions ¶
func RegisterInterfaces ¶
func RegisterInterfaces(registry types.InterfaceRegistry)
func RegisterMsgServer ¶
func RegisterQueryServer ¶
func RegisterQueryServer(s grpc1.Server, srv QueryServer)
Types ¶
type Client ¶
type Client interface { sdk.Module CreateFeed(request CreateFeedRequest, baseTx sdk.BaseTx) (sdk.ResultTx, sdk.Error) StartFeed(feedName string, baseTx sdk.BaseTx) (sdk.ResultTx, sdk.Error) PauseFeed(feedName string, baseTx sdk.BaseTx) (sdk.ResultTx, sdk.Error) EditFeedRequest(request EditFeedRequest, baseTx sdk.BaseTx) (sdk.ResultTx, sdk.Error) QueryFeed(feedName string) (QueryFeedResp, sdk.Error) QueryFeeds(state string) ([]QueryFeedResp, sdk.Error) QueryFeedValue(feedName string) ([]QueryFeedValueResp, sdk.Error) }
expose Oracle module api for user
type CreateFeedRequest ¶
type EditFeedRequest ¶
type Feed ¶
type Feed struct { FeedName string `protobuf:"bytes,1,opt,name=feed_name,json=feedName,proto3" json:"feed_name,omitempty" yaml:"feed_name"` Description string `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"` AggregateFunc string `protobuf:"bytes,3,opt,name=aggregate_func,json=aggregateFunc,proto3" json:"aggregate_func,omitempty" yaml:"aggregate_func"` ValueJsonPath string `protobuf:"bytes,4,opt,name=value_json_path,json=valueJsonPath,proto3" json:"value_json_path,omitempty" yaml:"value_json_path"` LatestHistory uint64 `protobuf:"varint,5,opt,name=latest_history,json=latestHistory,proto3" json:"latest_history,omitempty" yaml:"latest_history"` RequestContextID string `` /* 137-byte string literal not displayed */ Creator string `protobuf:"bytes,7,opt,name=creator,proto3" json:"creator,omitempty"` }
Feed defines the feed standard
func (*Feed) Descriptor ¶
func (*Feed) GetAggregateFunc ¶
func (*Feed) GetCreator ¶
func (*Feed) GetDescription ¶
func (*Feed) GetFeedName ¶
func (*Feed) GetLatestHistory ¶
func (*Feed) GetRequestContextID ¶
func (*Feed) GetValueJsonPath ¶
func (*Feed) ProtoMessage ¶
func (*Feed) ProtoMessage()
func (*Feed) XXX_DiscardUnknown ¶
func (m *Feed) XXX_DiscardUnknown()
func (*Feed) XXX_Unmarshal ¶
type FeedContext ¶
type FeedContext struct { Feed *Feed `protobuf:"bytes,1,opt,name=feed,proto3" json:"feed,omitempty"` ServiceName string `protobuf:"bytes,2,opt,name=service_name,json=serviceName,proto3" json:"service_name,omitempty" yaml:"service_name"` Providers []string `protobuf:"bytes,3,rep,name=providers,proto3" json:"providers,omitempty"` Input string `protobuf:"bytes,4,opt,name=input,proto3" json:"input,omitempty"` Timeout int64 `protobuf:"varint,5,opt,name=timeout,proto3" json:"timeout,omitempty"` ServiceFeeCap github_com_irisnet_core_sdk_go_types.Coins `` /* 171-byte string literal not displayed */ RepeatedFrequency uint64 `` /* 139-byte string literal not displayed */ ResponseThreshold uint32 `` /* 139-byte string literal not displayed */ State service.RequestContextState `protobuf:"varint,9,opt,name=state,proto3,enum=irismod.service.RequestContextState" json:"state,omitempty"` }
FeedContext defines the feed context struct
func (FeedContext) Convert ¶
func (f FeedContext) Convert() interface{}
func (*FeedContext) Descriptor ¶
func (*FeedContext) Descriptor() ([]byte, []int)
func (*FeedContext) GetFeed ¶
func (m *FeedContext) GetFeed() *Feed
func (*FeedContext) GetInput ¶
func (m *FeedContext) GetInput() string
func (*FeedContext) GetProviders ¶
func (m *FeedContext) GetProviders() []string
func (*FeedContext) GetRepeatedFrequency ¶
func (m *FeedContext) GetRepeatedFrequency() uint64
func (*FeedContext) GetResponseThreshold ¶
func (m *FeedContext) GetResponseThreshold() uint32
func (*FeedContext) GetServiceFeeCap ¶
func (m *FeedContext) GetServiceFeeCap() github_com_irisnet_core_sdk_go_types.Coins
func (*FeedContext) GetServiceName ¶
func (m *FeedContext) GetServiceName() string
func (*FeedContext) GetState ¶
func (m *FeedContext) GetState() service.RequestContextState
func (*FeedContext) GetTimeout ¶
func (m *FeedContext) GetTimeout() int64
func (*FeedContext) Marshal ¶
func (m *FeedContext) Marshal() (dAtA []byte, err error)
func (*FeedContext) MarshalToSizedBuffer ¶
func (m *FeedContext) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*FeedContext) ProtoMessage ¶
func (*FeedContext) ProtoMessage()
func (*FeedContext) Reset ¶
func (m *FeedContext) Reset()
func (*FeedContext) Size ¶
func (m *FeedContext) Size() (n int)
func (*FeedContext) String ¶
func (m *FeedContext) String() string
func (*FeedContext) Unmarshal ¶
func (m *FeedContext) Unmarshal(dAtA []byte) error
func (*FeedContext) XXX_DiscardUnknown ¶
func (m *FeedContext) XXX_DiscardUnknown()
func (*FeedContext) XXX_Marshal ¶
func (m *FeedContext) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*FeedContext) XXX_Merge ¶
func (m *FeedContext) XXX_Merge(src proto.Message)
func (*FeedContext) XXX_Size ¶
func (m *FeedContext) XXX_Size() int
func (*FeedContext) XXX_Unmarshal ¶
func (m *FeedContext) XXX_Unmarshal(b []byte) error
type FeedValue ¶
type FeedValue struct { Data string `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"` Timestamp time.Time `protobuf:"bytes,2,opt,name=timestamp,proto3,stdtime" json:"timestamp"` }
FeedValue defines the feed result standard
func (*FeedValue) Descriptor ¶
func (*FeedValue) GetTimestamp ¶
func (*FeedValue) MarshalToSizedBuffer ¶
func (*FeedValue) ProtoMessage ¶
func (*FeedValue) ProtoMessage()
func (*FeedValue) XXX_DiscardUnknown ¶
func (m *FeedValue) XXX_DiscardUnknown()
func (*FeedValue) XXX_Marshal ¶
func (*FeedValue) XXX_Unmarshal ¶
type FeedValues ¶
type FeedValues []FeedValue
func (FeedValues) Convert ¶
func (fvs FeedValues) Convert() interface{}
type MsgClient ¶
type MsgClient interface { // CreateFeed defines a method for creating a new feed. CreateFeed(ctx context.Context, in *MsgCreateFeed, opts ...grpc.CallOption) (*MsgCreateFeedResponse, error) // EditFeed defines a method for editing a feed. EditFeed(ctx context.Context, in *MsgEditFeed, opts ...grpc.CallOption) (*MsgEditFeedResponse, error) // StartFeed defines a method for starting a feed StartFeed(ctx context.Context, in *MsgStartFeed, opts ...grpc.CallOption) (*MsgStartFeedResponse, error) // PauseFeed defines a method for pausing a feed. PauseFeed(ctx context.Context, in *MsgPauseFeed, opts ...grpc.CallOption) (*MsgPauseFeedResponse, error) }
MsgClient is the client API for Msg service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewMsgClient ¶
func NewMsgClient(cc grpc1.ClientConn) MsgClient
type MsgCreateFeed ¶
type MsgCreateFeed struct { FeedName string `protobuf:"bytes,1,opt,name=feed_name,json=feedName,proto3" json:"feed_name,omitempty" yaml:"feed_name"` LatestHistory uint64 `protobuf:"varint,2,opt,name=latest_history,json=latestHistory,proto3" json:"latest_history,omitempty" yaml:"latest_history"` Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"` Creator string `protobuf:"bytes,4,opt,name=creator,proto3" json:"creator,omitempty"` ServiceName string `protobuf:"bytes,5,opt,name=service_name,json=serviceName,proto3" json:"service_name,omitempty" yaml:"service_name"` Providers []string `protobuf:"bytes,6,rep,name=providers,proto3" json:"providers,omitempty"` Input string `protobuf:"bytes,7,opt,name=input,proto3" json:"input,omitempty"` Timeout int64 `protobuf:"varint,8,opt,name=timeout,proto3" json:"timeout,omitempty"` ServiceFeeCap github_com_irisnet_core_sdk_go_types.Coins `` /* 171-byte string literal not displayed */ RepeatedFrequency uint64 `` /* 140-byte string literal not displayed */ AggregateFunc string `protobuf:"bytes,11,opt,name=aggregate_func,json=aggregateFunc,proto3" json:"aggregate_func,omitempty" yaml:"aggregate_func"` ValueJsonPath string `` /* 126-byte string literal not displayed */ ResponseThreshold uint32 `` /* 140-byte string literal not displayed */ }
MsgCreateFeed defines an sdk.Msg type that supports creating a feed
func (*MsgCreateFeed) Descriptor ¶
func (*MsgCreateFeed) Descriptor() ([]byte, []int)
func (*MsgCreateFeed) GetAggregateFunc ¶
func (m *MsgCreateFeed) GetAggregateFunc() string
func (*MsgCreateFeed) GetCreator ¶
func (m *MsgCreateFeed) GetCreator() string
func (*MsgCreateFeed) GetDescription ¶
func (m *MsgCreateFeed) GetDescription() string
func (*MsgCreateFeed) GetFeedName ¶
func (m *MsgCreateFeed) GetFeedName() string
func (*MsgCreateFeed) GetInput ¶
func (m *MsgCreateFeed) GetInput() string
func (*MsgCreateFeed) GetLatestHistory ¶
func (m *MsgCreateFeed) GetLatestHistory() uint64
func (*MsgCreateFeed) GetProviders ¶
func (m *MsgCreateFeed) GetProviders() []string
func (*MsgCreateFeed) GetRepeatedFrequency ¶
func (m *MsgCreateFeed) GetRepeatedFrequency() uint64
func (*MsgCreateFeed) GetResponseThreshold ¶
func (m *MsgCreateFeed) GetResponseThreshold() uint32
func (*MsgCreateFeed) GetServiceFeeCap ¶
func (m *MsgCreateFeed) GetServiceFeeCap() github_com_irisnet_core_sdk_go_types.Coins
func (*MsgCreateFeed) GetServiceName ¶
func (m *MsgCreateFeed) GetServiceName() string
func (MsgCreateFeed) GetSignBytes ¶
func (m MsgCreateFeed) GetSignBytes() []byte
func (MsgCreateFeed) GetSigners ¶
func (m MsgCreateFeed) GetSigners() []sdk.AccAddress
func (*MsgCreateFeed) GetTimeout ¶
func (m *MsgCreateFeed) GetTimeout() int64
func (*MsgCreateFeed) GetValueJsonPath ¶
func (m *MsgCreateFeed) GetValueJsonPath() string
func (*MsgCreateFeed) Marshal ¶
func (m *MsgCreateFeed) Marshal() (dAtA []byte, err error)
func (*MsgCreateFeed) MarshalToSizedBuffer ¶
func (m *MsgCreateFeed) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MsgCreateFeed) ProtoMessage ¶
func (*MsgCreateFeed) ProtoMessage()
func (*MsgCreateFeed) Reset ¶
func (m *MsgCreateFeed) Reset()
func (MsgCreateFeed) Route ¶
func (m MsgCreateFeed) Route() string
func (*MsgCreateFeed) Size ¶
func (m *MsgCreateFeed) Size() (n int)
func (*MsgCreateFeed) String ¶
func (m *MsgCreateFeed) String() string
func (MsgCreateFeed) Type ¶
func (m MsgCreateFeed) Type() string
func (*MsgCreateFeed) Unmarshal ¶
func (m *MsgCreateFeed) Unmarshal(dAtA []byte) error
func (MsgCreateFeed) ValidateBasic ¶
func (m MsgCreateFeed) ValidateBasic() error
func (*MsgCreateFeed) XXX_DiscardUnknown ¶
func (m *MsgCreateFeed) XXX_DiscardUnknown()
func (*MsgCreateFeed) XXX_Marshal ¶
func (m *MsgCreateFeed) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MsgCreateFeed) XXX_Merge ¶
func (m *MsgCreateFeed) XXX_Merge(src proto.Message)
func (*MsgCreateFeed) XXX_Size ¶
func (m *MsgCreateFeed) XXX_Size() int
func (*MsgCreateFeed) XXX_Unmarshal ¶
func (m *MsgCreateFeed) XXX_Unmarshal(b []byte) error
type MsgCreateFeedResponse ¶
type MsgCreateFeedResponse struct { }
MsgCreateFeedResponse defines the Msg/CreateFeed response type.
func (*MsgCreateFeedResponse) Descriptor ¶
func (*MsgCreateFeedResponse) Descriptor() ([]byte, []int)
func (*MsgCreateFeedResponse) Marshal ¶
func (m *MsgCreateFeedResponse) Marshal() (dAtA []byte, err error)
func (*MsgCreateFeedResponse) MarshalTo ¶
func (m *MsgCreateFeedResponse) MarshalTo(dAtA []byte) (int, error)
func (*MsgCreateFeedResponse) MarshalToSizedBuffer ¶
func (m *MsgCreateFeedResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MsgCreateFeedResponse) ProtoMessage ¶
func (*MsgCreateFeedResponse) ProtoMessage()
func (*MsgCreateFeedResponse) Reset ¶
func (m *MsgCreateFeedResponse) Reset()
func (*MsgCreateFeedResponse) Size ¶
func (m *MsgCreateFeedResponse) Size() (n int)
func (*MsgCreateFeedResponse) String ¶
func (m *MsgCreateFeedResponse) String() string
func (*MsgCreateFeedResponse) Unmarshal ¶
func (m *MsgCreateFeedResponse) Unmarshal(dAtA []byte) error
func (*MsgCreateFeedResponse) XXX_DiscardUnknown ¶
func (m *MsgCreateFeedResponse) XXX_DiscardUnknown()
func (*MsgCreateFeedResponse) XXX_Marshal ¶
func (m *MsgCreateFeedResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MsgCreateFeedResponse) XXX_Merge ¶
func (m *MsgCreateFeedResponse) XXX_Merge(src proto.Message)
func (*MsgCreateFeedResponse) XXX_Size ¶
func (m *MsgCreateFeedResponse) XXX_Size() int
func (*MsgCreateFeedResponse) XXX_Unmarshal ¶
func (m *MsgCreateFeedResponse) XXX_Unmarshal(b []byte) error
type MsgEditFeed ¶
type MsgEditFeed struct { FeedName string `protobuf:"bytes,1,opt,name=feed_name,json=feedName,proto3" json:"feed_name,omitempty" yaml:"feed_name"` Description string `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"` LatestHistory uint64 `protobuf:"varint,3,opt,name=latest_history,json=latestHistory,proto3" json:"latest_history,omitempty" yaml:"latest_history"` Providers []string `protobuf:"bytes,4,rep,name=providers,proto3" json:"providers,omitempty"` Timeout int64 `protobuf:"varint,5,opt,name=timeout,proto3" json:"timeout,omitempty"` ServiceFeeCap github_com_irisnet_core_sdk_go_types.Coins `` /* 171-byte string literal not displayed */ RepeatedFrequency uint64 `` /* 139-byte string literal not displayed */ ResponseThreshold uint32 `` /* 139-byte string literal not displayed */ Creator string `protobuf:"bytes,9,opt,name=creator,proto3" json:"creator,omitempty"` }
MsgEditFeed defines an sdk.Msg type that supports editing a feed
func (*MsgEditFeed) Descriptor ¶
func (*MsgEditFeed) Descriptor() ([]byte, []int)
func (*MsgEditFeed) GetCreator ¶
func (m *MsgEditFeed) GetCreator() string
func (*MsgEditFeed) GetDescription ¶
func (m *MsgEditFeed) GetDescription() string
func (*MsgEditFeed) GetFeedName ¶
func (m *MsgEditFeed) GetFeedName() string
func (*MsgEditFeed) GetLatestHistory ¶
func (m *MsgEditFeed) GetLatestHistory() uint64
func (*MsgEditFeed) GetProviders ¶
func (m *MsgEditFeed) GetProviders() []string
func (*MsgEditFeed) GetRepeatedFrequency ¶
func (m *MsgEditFeed) GetRepeatedFrequency() uint64
func (*MsgEditFeed) GetResponseThreshold ¶
func (m *MsgEditFeed) GetResponseThreshold() uint32
func (*MsgEditFeed) GetServiceFeeCap ¶
func (m *MsgEditFeed) GetServiceFeeCap() github_com_irisnet_core_sdk_go_types.Coins
func (MsgEditFeed) GetSignBytes ¶
func (m MsgEditFeed) GetSignBytes() []byte
func (MsgEditFeed) GetSigners ¶
func (m MsgEditFeed) GetSigners() []sdk.AccAddress
func (*MsgEditFeed) GetTimeout ¶
func (m *MsgEditFeed) GetTimeout() int64
func (*MsgEditFeed) Marshal ¶
func (m *MsgEditFeed) Marshal() (dAtA []byte, err error)
func (*MsgEditFeed) MarshalToSizedBuffer ¶
func (m *MsgEditFeed) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MsgEditFeed) ProtoMessage ¶
func (*MsgEditFeed) ProtoMessage()
func (*MsgEditFeed) Reset ¶
func (m *MsgEditFeed) Reset()
func (MsgEditFeed) Route ¶
func (m MsgEditFeed) Route() string
func (*MsgEditFeed) Size ¶
func (m *MsgEditFeed) Size() (n int)
func (*MsgEditFeed) String ¶
func (m *MsgEditFeed) String() string
func (MsgEditFeed) Type ¶
func (m MsgEditFeed) Type() string
func (*MsgEditFeed) Unmarshal ¶
func (m *MsgEditFeed) Unmarshal(dAtA []byte) error
func (MsgEditFeed) ValidateBasic ¶
func (m MsgEditFeed) ValidateBasic() error
func (*MsgEditFeed) XXX_DiscardUnknown ¶
func (m *MsgEditFeed) XXX_DiscardUnknown()
func (*MsgEditFeed) XXX_Marshal ¶
func (m *MsgEditFeed) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MsgEditFeed) XXX_Merge ¶
func (m *MsgEditFeed) XXX_Merge(src proto.Message)
func (*MsgEditFeed) XXX_Size ¶
func (m *MsgEditFeed) XXX_Size() int
func (*MsgEditFeed) XXX_Unmarshal ¶
func (m *MsgEditFeed) XXX_Unmarshal(b []byte) error
type MsgEditFeedResponse ¶
type MsgEditFeedResponse struct { }
MsgEditFeedResponse defines the Msg/EditFeed response type.
func (*MsgEditFeedResponse) Descriptor ¶
func (*MsgEditFeedResponse) Descriptor() ([]byte, []int)
func (*MsgEditFeedResponse) Marshal ¶
func (m *MsgEditFeedResponse) Marshal() (dAtA []byte, err error)
func (*MsgEditFeedResponse) MarshalTo ¶
func (m *MsgEditFeedResponse) MarshalTo(dAtA []byte) (int, error)
func (*MsgEditFeedResponse) MarshalToSizedBuffer ¶
func (m *MsgEditFeedResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MsgEditFeedResponse) ProtoMessage ¶
func (*MsgEditFeedResponse) ProtoMessage()
func (*MsgEditFeedResponse) Reset ¶
func (m *MsgEditFeedResponse) Reset()
func (*MsgEditFeedResponse) Size ¶
func (m *MsgEditFeedResponse) Size() (n int)
func (*MsgEditFeedResponse) String ¶
func (m *MsgEditFeedResponse) String() string
func (*MsgEditFeedResponse) Unmarshal ¶
func (m *MsgEditFeedResponse) Unmarshal(dAtA []byte) error
func (*MsgEditFeedResponse) XXX_DiscardUnknown ¶
func (m *MsgEditFeedResponse) XXX_DiscardUnknown()
func (*MsgEditFeedResponse) XXX_Marshal ¶
func (m *MsgEditFeedResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MsgEditFeedResponse) XXX_Merge ¶
func (m *MsgEditFeedResponse) XXX_Merge(src proto.Message)
func (*MsgEditFeedResponse) XXX_Size ¶
func (m *MsgEditFeedResponse) XXX_Size() int
func (*MsgEditFeedResponse) XXX_Unmarshal ¶
func (m *MsgEditFeedResponse) XXX_Unmarshal(b []byte) error
type MsgPauseFeed ¶
type MsgPauseFeed struct { FeedName string `protobuf:"bytes,1,opt,name=feed_name,json=feedName,proto3" json:"feed_name,omitempty" yaml:"feed_name"` Creator string `protobuf:"bytes,2,opt,name=creator,proto3" json:"creator,omitempty"` }
MsgPauseFeed defines an sdk.Msg type that supports pausing a feed
func (*MsgPauseFeed) Descriptor ¶
func (*MsgPauseFeed) Descriptor() ([]byte, []int)
func (*MsgPauseFeed) GetCreator ¶
func (m *MsgPauseFeed) GetCreator() string
func (*MsgPauseFeed) GetFeedName ¶
func (m *MsgPauseFeed) GetFeedName() string
func (MsgPauseFeed) GetSignBytes ¶
func (m MsgPauseFeed) GetSignBytes() []byte
func (MsgPauseFeed) GetSigners ¶
func (m MsgPauseFeed) GetSigners() []sdk.AccAddress
func (*MsgPauseFeed) Marshal ¶
func (m *MsgPauseFeed) Marshal() (dAtA []byte, err error)
func (*MsgPauseFeed) MarshalToSizedBuffer ¶
func (m *MsgPauseFeed) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MsgPauseFeed) ProtoMessage ¶
func (*MsgPauseFeed) ProtoMessage()
func (*MsgPauseFeed) Reset ¶
func (m *MsgPauseFeed) Reset()
func (MsgPauseFeed) Route ¶
func (m MsgPauseFeed) Route() string
func (*MsgPauseFeed) Size ¶
func (m *MsgPauseFeed) Size() (n int)
func (*MsgPauseFeed) String ¶
func (m *MsgPauseFeed) String() string
func (MsgPauseFeed) Type ¶
func (m MsgPauseFeed) Type() string
func (*MsgPauseFeed) Unmarshal ¶
func (m *MsgPauseFeed) Unmarshal(dAtA []byte) error
func (MsgPauseFeed) ValidateBasic ¶
func (m MsgPauseFeed) ValidateBasic() error
func (*MsgPauseFeed) XXX_DiscardUnknown ¶
func (m *MsgPauseFeed) XXX_DiscardUnknown()
func (*MsgPauseFeed) XXX_Marshal ¶
func (m *MsgPauseFeed) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MsgPauseFeed) XXX_Merge ¶
func (m *MsgPauseFeed) XXX_Merge(src proto.Message)
func (*MsgPauseFeed) XXX_Size ¶
func (m *MsgPauseFeed) XXX_Size() int
func (*MsgPauseFeed) XXX_Unmarshal ¶
func (m *MsgPauseFeed) XXX_Unmarshal(b []byte) error
type MsgPauseFeedResponse ¶
type MsgPauseFeedResponse struct { }
MsgPauseFeedResponse defines the Msg/PauseFeed response type.
func (*MsgPauseFeedResponse) Descriptor ¶
func (*MsgPauseFeedResponse) Descriptor() ([]byte, []int)
func (*MsgPauseFeedResponse) Marshal ¶
func (m *MsgPauseFeedResponse) Marshal() (dAtA []byte, err error)
func (*MsgPauseFeedResponse) MarshalTo ¶
func (m *MsgPauseFeedResponse) MarshalTo(dAtA []byte) (int, error)
func (*MsgPauseFeedResponse) MarshalToSizedBuffer ¶
func (m *MsgPauseFeedResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MsgPauseFeedResponse) ProtoMessage ¶
func (*MsgPauseFeedResponse) ProtoMessage()
func (*MsgPauseFeedResponse) Reset ¶
func (m *MsgPauseFeedResponse) Reset()
func (*MsgPauseFeedResponse) Size ¶
func (m *MsgPauseFeedResponse) Size() (n int)
func (*MsgPauseFeedResponse) String ¶
func (m *MsgPauseFeedResponse) String() string
func (*MsgPauseFeedResponse) Unmarshal ¶
func (m *MsgPauseFeedResponse) Unmarshal(dAtA []byte) error
func (*MsgPauseFeedResponse) XXX_DiscardUnknown ¶
func (m *MsgPauseFeedResponse) XXX_DiscardUnknown()
func (*MsgPauseFeedResponse) XXX_Marshal ¶
func (m *MsgPauseFeedResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MsgPauseFeedResponse) XXX_Merge ¶
func (m *MsgPauseFeedResponse) XXX_Merge(src proto.Message)
func (*MsgPauseFeedResponse) XXX_Size ¶
func (m *MsgPauseFeedResponse) XXX_Size() int
func (*MsgPauseFeedResponse) XXX_Unmarshal ¶
func (m *MsgPauseFeedResponse) XXX_Unmarshal(b []byte) error
type MsgServer ¶
type MsgServer interface { // CreateFeed defines a method for creating a new feed. CreateFeed(context.Context, *MsgCreateFeed) (*MsgCreateFeedResponse, error) // EditFeed defines a method for editing a feed. EditFeed(context.Context, *MsgEditFeed) (*MsgEditFeedResponse, error) // StartFeed defines a method for starting a feed StartFeed(context.Context, *MsgStartFeed) (*MsgStartFeedResponse, error) // PauseFeed defines a method for pausing a feed. PauseFeed(context.Context, *MsgPauseFeed) (*MsgPauseFeedResponse, error) }
MsgServer is the server API for Msg service.
type MsgStartFeed ¶
type MsgStartFeed struct { FeedName string `protobuf:"bytes,1,opt,name=feed_name,json=feedName,proto3" json:"feed_name,omitempty" yaml:"feed_name"` Creator string `protobuf:"bytes,2,opt,name=creator,proto3" json:"creator,omitempty"` }
MsgPauseFeed defines an sdk.Msg type that supports stating a feed
func (*MsgStartFeed) Descriptor ¶
func (*MsgStartFeed) Descriptor() ([]byte, []int)
func (*MsgStartFeed) GetCreator ¶
func (m *MsgStartFeed) GetCreator() string
func (*MsgStartFeed) GetFeedName ¶
func (m *MsgStartFeed) GetFeedName() string
func (MsgStartFeed) GetSignBytes ¶
func (m MsgStartFeed) GetSignBytes() []byte
func (MsgStartFeed) GetSigners ¶
func (m MsgStartFeed) GetSigners() []sdk.AccAddress
func (*MsgStartFeed) Marshal ¶
func (m *MsgStartFeed) Marshal() (dAtA []byte, err error)
func (*MsgStartFeed) MarshalToSizedBuffer ¶
func (m *MsgStartFeed) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MsgStartFeed) ProtoMessage ¶
func (*MsgStartFeed) ProtoMessage()
func (*MsgStartFeed) Reset ¶
func (m *MsgStartFeed) Reset()
func (MsgStartFeed) Route ¶
func (m MsgStartFeed) Route() string
func (*MsgStartFeed) Size ¶
func (m *MsgStartFeed) Size() (n int)
func (*MsgStartFeed) String ¶
func (m *MsgStartFeed) String() string
func (MsgStartFeed) Type ¶
func (m MsgStartFeed) Type() string
func (*MsgStartFeed) Unmarshal ¶
func (m *MsgStartFeed) Unmarshal(dAtA []byte) error
func (MsgStartFeed) ValidateBasic ¶
func (m MsgStartFeed) ValidateBasic() error
func (*MsgStartFeed) XXX_DiscardUnknown ¶
func (m *MsgStartFeed) XXX_DiscardUnknown()
func (*MsgStartFeed) XXX_Marshal ¶
func (m *MsgStartFeed) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MsgStartFeed) XXX_Merge ¶
func (m *MsgStartFeed) XXX_Merge(src proto.Message)
func (*MsgStartFeed) XXX_Size ¶
func (m *MsgStartFeed) XXX_Size() int
func (*MsgStartFeed) XXX_Unmarshal ¶
func (m *MsgStartFeed) XXX_Unmarshal(b []byte) error
type MsgStartFeedResponse ¶
type MsgStartFeedResponse struct { }
MsgStartFeedResponse defines the Msg/StartFeed response type.
func (*MsgStartFeedResponse) Descriptor ¶
func (*MsgStartFeedResponse) Descriptor() ([]byte, []int)
func (*MsgStartFeedResponse) Marshal ¶
func (m *MsgStartFeedResponse) Marshal() (dAtA []byte, err error)
func (*MsgStartFeedResponse) MarshalTo ¶
func (m *MsgStartFeedResponse) MarshalTo(dAtA []byte) (int, error)
func (*MsgStartFeedResponse) MarshalToSizedBuffer ¶
func (m *MsgStartFeedResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MsgStartFeedResponse) ProtoMessage ¶
func (*MsgStartFeedResponse) ProtoMessage()
func (*MsgStartFeedResponse) Reset ¶
func (m *MsgStartFeedResponse) Reset()
func (*MsgStartFeedResponse) Size ¶
func (m *MsgStartFeedResponse) Size() (n int)
func (*MsgStartFeedResponse) String ¶
func (m *MsgStartFeedResponse) String() string
func (*MsgStartFeedResponse) Unmarshal ¶
func (m *MsgStartFeedResponse) Unmarshal(dAtA []byte) error
func (*MsgStartFeedResponse) XXX_DiscardUnknown ¶
func (m *MsgStartFeedResponse) XXX_DiscardUnknown()
func (*MsgStartFeedResponse) XXX_Marshal ¶
func (m *MsgStartFeedResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MsgStartFeedResponse) XXX_Merge ¶
func (m *MsgStartFeedResponse) XXX_Merge(src proto.Message)
func (*MsgStartFeedResponse) XXX_Size ¶
func (m *MsgStartFeedResponse) XXX_Size() int
func (*MsgStartFeedResponse) XXX_Unmarshal ¶
func (m *MsgStartFeedResponse) XXX_Unmarshal(b []byte) error
type QueryClient ¶
type QueryClient interface { // Feed queries the feed Feed(ctx context.Context, in *QueryFeedRequest, opts ...grpc.CallOption) (*QueryFeedResponse, error) // QueryFeedsRequest queries the feed list Feeds(ctx context.Context, in *QueryFeedsRequest, opts ...grpc.CallOption) (*QueryFeedsResponse, error) // FeedValue queries the feed value FeedValue(ctx context.Context, in *QueryFeedValueRequest, opts ...grpc.CallOption) (*QueryFeedValueResponse, error) }
QueryClient is the client API for Query service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewQueryClient ¶
func NewQueryClient(cc grpc1.ClientConn) QueryClient
type QueryFeedRequest ¶
type QueryFeedRequest struct {
FeedName string `protobuf:"bytes,1,opt,name=feed_name,json=feedName,proto3" json:"feed_name,omitempty"`
}
QueryFeedRequest is request type for the Query/Feed RPC method
func (*QueryFeedRequest) Descriptor ¶
func (*QueryFeedRequest) Descriptor() ([]byte, []int)
func (*QueryFeedRequest) GetFeedName ¶
func (m *QueryFeedRequest) GetFeedName() string
func (*QueryFeedRequest) Marshal ¶
func (m *QueryFeedRequest) Marshal() (dAtA []byte, err error)
func (*QueryFeedRequest) MarshalToSizedBuffer ¶
func (m *QueryFeedRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryFeedRequest) ProtoMessage ¶
func (*QueryFeedRequest) ProtoMessage()
func (*QueryFeedRequest) Reset ¶
func (m *QueryFeedRequest) Reset()
func (*QueryFeedRequest) Size ¶
func (m *QueryFeedRequest) Size() (n int)
func (*QueryFeedRequest) String ¶
func (m *QueryFeedRequest) String() string
func (*QueryFeedRequest) Unmarshal ¶
func (m *QueryFeedRequest) Unmarshal(dAtA []byte) error
func (*QueryFeedRequest) XXX_DiscardUnknown ¶
func (m *QueryFeedRequest) XXX_DiscardUnknown()
func (*QueryFeedRequest) XXX_Marshal ¶
func (m *QueryFeedRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryFeedRequest) XXX_Merge ¶
func (m *QueryFeedRequest) XXX_Merge(src proto.Message)
func (*QueryFeedRequest) XXX_Size ¶
func (m *QueryFeedRequest) XXX_Size() int
func (*QueryFeedRequest) XXX_Unmarshal ¶
func (m *QueryFeedRequest) XXX_Unmarshal(b []byte) error
type QueryFeedResp ¶
type QueryFeedResponse ¶
type QueryFeedResponse struct {
Feed FeedContext `protobuf:"bytes,1,opt,name=feed,proto3" json:"feed"`
}
QueryFeedResponse is response type for the Query/Feed RPC method
func (*QueryFeedResponse) Descriptor ¶
func (*QueryFeedResponse) Descriptor() ([]byte, []int)
func (*QueryFeedResponse) GetFeed ¶
func (m *QueryFeedResponse) GetFeed() FeedContext
func (*QueryFeedResponse) Marshal ¶
func (m *QueryFeedResponse) Marshal() (dAtA []byte, err error)
func (*QueryFeedResponse) MarshalTo ¶
func (m *QueryFeedResponse) MarshalTo(dAtA []byte) (int, error)
func (*QueryFeedResponse) MarshalToSizedBuffer ¶
func (m *QueryFeedResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryFeedResponse) ProtoMessage ¶
func (*QueryFeedResponse) ProtoMessage()
func (*QueryFeedResponse) Reset ¶
func (m *QueryFeedResponse) Reset()
func (*QueryFeedResponse) Size ¶
func (m *QueryFeedResponse) Size() (n int)
func (*QueryFeedResponse) String ¶
func (m *QueryFeedResponse) String() string
func (*QueryFeedResponse) Unmarshal ¶
func (m *QueryFeedResponse) Unmarshal(dAtA []byte) error
func (*QueryFeedResponse) XXX_DiscardUnknown ¶
func (m *QueryFeedResponse) XXX_DiscardUnknown()
func (*QueryFeedResponse) XXX_Marshal ¶
func (m *QueryFeedResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryFeedResponse) XXX_Merge ¶
func (m *QueryFeedResponse) XXX_Merge(src proto.Message)
func (*QueryFeedResponse) XXX_Size ¶
func (m *QueryFeedResponse) XXX_Size() int
func (*QueryFeedResponse) XXX_Unmarshal ¶
func (m *QueryFeedResponse) XXX_Unmarshal(b []byte) error
type QueryFeedValueRequest ¶
type QueryFeedValueRequest struct {
FeedName string `protobuf:"bytes,1,opt,name=feed_name,json=feedName,proto3" json:"feed_name,omitempty"`
}
QueryFeedValueRequest is request type for the Query/FeedValue RPC method
func (*QueryFeedValueRequest) Descriptor ¶
func (*QueryFeedValueRequest) Descriptor() ([]byte, []int)
func (*QueryFeedValueRequest) GetFeedName ¶
func (m *QueryFeedValueRequest) GetFeedName() string
func (*QueryFeedValueRequest) Marshal ¶
func (m *QueryFeedValueRequest) Marshal() (dAtA []byte, err error)
func (*QueryFeedValueRequest) MarshalTo ¶
func (m *QueryFeedValueRequest) MarshalTo(dAtA []byte) (int, error)
func (*QueryFeedValueRequest) MarshalToSizedBuffer ¶
func (m *QueryFeedValueRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryFeedValueRequest) ProtoMessage ¶
func (*QueryFeedValueRequest) ProtoMessage()
func (*QueryFeedValueRequest) Reset ¶
func (m *QueryFeedValueRequest) Reset()
func (*QueryFeedValueRequest) Size ¶
func (m *QueryFeedValueRequest) Size() (n int)
func (*QueryFeedValueRequest) String ¶
func (m *QueryFeedValueRequest) String() string
func (*QueryFeedValueRequest) Unmarshal ¶
func (m *QueryFeedValueRequest) Unmarshal(dAtA []byte) error
func (*QueryFeedValueRequest) XXX_DiscardUnknown ¶
func (m *QueryFeedValueRequest) XXX_DiscardUnknown()
func (*QueryFeedValueRequest) XXX_Marshal ¶
func (m *QueryFeedValueRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryFeedValueRequest) XXX_Merge ¶
func (m *QueryFeedValueRequest) XXX_Merge(src proto.Message)
func (*QueryFeedValueRequest) XXX_Size ¶
func (m *QueryFeedValueRequest) XXX_Size() int
func (*QueryFeedValueRequest) XXX_Unmarshal ¶
func (m *QueryFeedValueRequest) XXX_Unmarshal(b []byte) error
type QueryFeedValueResp ¶
type QueryFeedValueResponse ¶
type QueryFeedValueResponse struct {
FeedValues []FeedValue `protobuf:"bytes,1,rep,name=feed_values,json=feedValues,proto3" json:"feed_values"`
}
QueryFeedValueResponse is response type for the Query/FeedValue RPC method
func (*QueryFeedValueResponse) Descriptor ¶
func (*QueryFeedValueResponse) Descriptor() ([]byte, []int)
func (*QueryFeedValueResponse) GetFeedValues ¶
func (m *QueryFeedValueResponse) GetFeedValues() []FeedValue
func (*QueryFeedValueResponse) Marshal ¶
func (m *QueryFeedValueResponse) Marshal() (dAtA []byte, err error)
func (*QueryFeedValueResponse) MarshalTo ¶
func (m *QueryFeedValueResponse) MarshalTo(dAtA []byte) (int, error)
func (*QueryFeedValueResponse) MarshalToSizedBuffer ¶
func (m *QueryFeedValueResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryFeedValueResponse) ProtoMessage ¶
func (*QueryFeedValueResponse) ProtoMessage()
func (*QueryFeedValueResponse) Reset ¶
func (m *QueryFeedValueResponse) Reset()
func (*QueryFeedValueResponse) Size ¶
func (m *QueryFeedValueResponse) Size() (n int)
func (*QueryFeedValueResponse) String ¶
func (m *QueryFeedValueResponse) String() string
func (*QueryFeedValueResponse) Unmarshal ¶
func (m *QueryFeedValueResponse) Unmarshal(dAtA []byte) error
func (*QueryFeedValueResponse) XXX_DiscardUnknown ¶
func (m *QueryFeedValueResponse) XXX_DiscardUnknown()
func (*QueryFeedValueResponse) XXX_Marshal ¶
func (m *QueryFeedValueResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryFeedValueResponse) XXX_Merge ¶
func (m *QueryFeedValueResponse) XXX_Merge(src proto.Message)
func (*QueryFeedValueResponse) XXX_Size ¶
func (m *QueryFeedValueResponse) XXX_Size() int
func (*QueryFeedValueResponse) XXX_Unmarshal ¶
func (m *QueryFeedValueResponse) XXX_Unmarshal(b []byte) error
type QueryFeedsRequest ¶
type QueryFeedsRequest struct { State string `protobuf:"bytes,1,opt,name=state,proto3" json:"state,omitempty"` // pagination defines an optional pagination for the request. Pagination *query.PageRequest `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"` }
QueryFeedsRequest is request type for the Query/Feeds RPC method
func (*QueryFeedsRequest) Descriptor ¶
func (*QueryFeedsRequest) Descriptor() ([]byte, []int)
func (*QueryFeedsRequest) GetPagination ¶
func (m *QueryFeedsRequest) GetPagination() *query.PageRequest
func (*QueryFeedsRequest) GetState ¶
func (m *QueryFeedsRequest) GetState() string
func (*QueryFeedsRequest) Marshal ¶
func (m *QueryFeedsRequest) Marshal() (dAtA []byte, err error)
func (*QueryFeedsRequest) MarshalTo ¶
func (m *QueryFeedsRequest) MarshalTo(dAtA []byte) (int, error)
func (*QueryFeedsRequest) MarshalToSizedBuffer ¶
func (m *QueryFeedsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryFeedsRequest) ProtoMessage ¶
func (*QueryFeedsRequest) ProtoMessage()
func (*QueryFeedsRequest) Reset ¶
func (m *QueryFeedsRequest) Reset()
func (*QueryFeedsRequest) Size ¶
func (m *QueryFeedsRequest) Size() (n int)
func (*QueryFeedsRequest) String ¶
func (m *QueryFeedsRequest) String() string
func (*QueryFeedsRequest) Unmarshal ¶
func (m *QueryFeedsRequest) Unmarshal(dAtA []byte) error
func (*QueryFeedsRequest) XXX_DiscardUnknown ¶
func (m *QueryFeedsRequest) XXX_DiscardUnknown()
func (*QueryFeedsRequest) XXX_Marshal ¶
func (m *QueryFeedsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryFeedsRequest) XXX_Merge ¶
func (m *QueryFeedsRequest) XXX_Merge(src proto.Message)
func (*QueryFeedsRequest) XXX_Size ¶
func (m *QueryFeedsRequest) XXX_Size() int
func (*QueryFeedsRequest) XXX_Unmarshal ¶
func (m *QueryFeedsRequest) XXX_Unmarshal(b []byte) error
type QueryFeedsResponse ¶
type QueryFeedsResponse struct { Feeds []FeedContext `protobuf:"bytes,1,rep,name=feeds,proto3" json:"feeds"` Pagination *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"` }
QueryFeedsResponse is response type for the Query/Feeds RPC method
func (*QueryFeedsResponse) Descriptor ¶
func (*QueryFeedsResponse) Descriptor() ([]byte, []int)
func (*QueryFeedsResponse) GetFeeds ¶
func (m *QueryFeedsResponse) GetFeeds() []FeedContext
func (*QueryFeedsResponse) GetPagination ¶
func (m *QueryFeedsResponse) GetPagination() *query.PageResponse
func (*QueryFeedsResponse) Marshal ¶
func (m *QueryFeedsResponse) Marshal() (dAtA []byte, err error)
func (*QueryFeedsResponse) MarshalTo ¶
func (m *QueryFeedsResponse) MarshalTo(dAtA []byte) (int, error)
func (*QueryFeedsResponse) MarshalToSizedBuffer ¶
func (m *QueryFeedsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryFeedsResponse) ProtoMessage ¶
func (*QueryFeedsResponse) ProtoMessage()
func (*QueryFeedsResponse) Reset ¶
func (m *QueryFeedsResponse) Reset()
func (*QueryFeedsResponse) Size ¶
func (m *QueryFeedsResponse) Size() (n int)
func (*QueryFeedsResponse) String ¶
func (m *QueryFeedsResponse) String() string
func (*QueryFeedsResponse) Unmarshal ¶
func (m *QueryFeedsResponse) Unmarshal(dAtA []byte) error
func (*QueryFeedsResponse) XXX_DiscardUnknown ¶
func (m *QueryFeedsResponse) XXX_DiscardUnknown()
func (*QueryFeedsResponse) XXX_Marshal ¶
func (m *QueryFeedsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryFeedsResponse) XXX_Merge ¶
func (m *QueryFeedsResponse) XXX_Merge(src proto.Message)
func (*QueryFeedsResponse) XXX_Size ¶
func (m *QueryFeedsResponse) XXX_Size() int
func (*QueryFeedsResponse) XXX_Unmarshal ¶
func (m *QueryFeedsResponse) XXX_Unmarshal(b []byte) error
type QueryServer ¶
type QueryServer interface { // Feed queries the feed Feed(context.Context, *QueryFeedRequest) (*QueryFeedResponse, error) // QueryFeedsRequest queries the feed list Feeds(context.Context, *QueryFeedsRequest) (*QueryFeedsResponse, error) // FeedValue queries the feed value FeedValue(context.Context, *QueryFeedValueRequest) (*QueryFeedValueResponse, error) }
QueryServer is the server API for Query service.
type UnimplementedMsgServer ¶
type UnimplementedMsgServer struct { }
UnimplementedMsgServer can be embedded to have forward compatible implementations.
func (*UnimplementedMsgServer) CreateFeed ¶
func (*UnimplementedMsgServer) CreateFeed(ctx context.Context, req *MsgCreateFeed) (*MsgCreateFeedResponse, error)
func (*UnimplementedMsgServer) EditFeed ¶
func (*UnimplementedMsgServer) EditFeed(ctx context.Context, req *MsgEditFeed) (*MsgEditFeedResponse, error)
func (*UnimplementedMsgServer) PauseFeed ¶
func (*UnimplementedMsgServer) PauseFeed(ctx context.Context, req *MsgPauseFeed) (*MsgPauseFeedResponse, error)
func (*UnimplementedMsgServer) StartFeed ¶
func (*UnimplementedMsgServer) StartFeed(ctx context.Context, req *MsgStartFeed) (*MsgStartFeedResponse, error)
type UnimplementedQueryServer ¶
type UnimplementedQueryServer struct { }
UnimplementedQueryServer can be embedded to have forward compatible implementations.
func (*UnimplementedQueryServer) Feed ¶
func (*UnimplementedQueryServer) Feed(ctx context.Context, req *QueryFeedRequest) (*QueryFeedResponse, error)
func (*UnimplementedQueryServer) FeedValue ¶
func (*UnimplementedQueryServer) FeedValue(ctx context.Context, req *QueryFeedValueRequest) (*QueryFeedValueResponse, error)
func (*UnimplementedQueryServer) Feeds ¶
func (*UnimplementedQueryServer) Feeds(ctx context.Context, req *QueryFeedsRequest) (*QueryFeedsResponse, error)