oracle

package
v1.0.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Aug 11, 2020 License: Apache-2.0 Imports: 16 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	// ModuleName define module name
	ModuleName = "oracle"

	RUNNING   = "running"
	PAUSED    = "paused"
	COMPLETED = "completed"
)

Variables

View Source 
var (
	ErrInvalidLengthTypes        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTypes          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupTypes = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ModuleCdc = codec.NewHybridCodec(amino, types.NewInterfaceRegistry())
)

Functions

This section is empty.

Types

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 github_com_tendermint_tendermint_libs_bytes.HexBytes `` /* 199-byte string literal not displayed */
	Creator          github_com_bianjieai_irita_sdk_go_types.AccAddress   `` /* 127-byte string literal not displayed */
}

Feed defines the feed standard

func (*Feed) Descriptor 

func (*Feed) Descriptor() ([]byte, []int)

func (*Feed) Marshal 

func (m *Feed) Marshal() (dAtA []byte, err error)

func (*Feed) MarshalTo 

func (m *Feed) MarshalTo(dAtA []byte) (int, error)

func (*Feed) MarshalToSizedBuffer 

func (m *Feed) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Feed) ProtoMessage 

func (*Feed) ProtoMessage()

func (*Feed) Reset 

func (m *Feed) Reset()

func (*Feed) Size 

func (m *Feed) Size() (n int)

func (*Feed) String 

func (m *Feed) String() string

func (*Feed) Unmarshal 

func (m *Feed) Unmarshal(dAtA []byte) error

func (*Feed) XXX_DiscardUnknown 

func (m *Feed) XXX_DiscardUnknown()

func (*Feed) XXX_Marshal 

func (m *Feed) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Feed) XXX_Merge 

func (m *Feed) XXX_Merge(src proto.Message)

func (*Feed) XXX_Size 

func (m *Feed) XXX_Size() int

func (*Feed) XXX_Unmarshal 

func (m *Feed) XXX_Unmarshal(b []byte) error

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         []github_com_bianjieai_irita_sdk_go_types.AccAddress `` /* 131-byte string literal not displayed */
	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_bianjieai_irita_sdk_go_types.Coins        `` /* 174-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 (this FeedContext) Convert() interface{}

func (*FeedContext) Descriptor 

func (*FeedContext) Descriptor() ([]byte, []int)

func (*FeedContext) Marshal 

func (m *FeedContext) Marshal() (dAtA []byte, err error)

func (*FeedContext) MarshalTo 

func (m *FeedContext) MarshalTo(dAtA []byte) (int, 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 FeedCreateRequest 

type FeedCreateRequest struct {
	FeedName          string       `json:"feed_name"`
	LatestHistory     uint64       `json:"latest_history"`
	Description       string       `json:"description"`
	ServiceName       string       `json:"service_name"`
	Providers         []string     `json:"providers"`
	Input             string       `json:"input"`
	Timeout           int64        `json:"timeout"`
	ServiceFeeCap     sdk.DecCoins `json:"service_fee_cap"`
	RepeatedFrequency uint64       `json:"repeated_frequency"`
	AggregateFunc     string       `json:"aggregate_func"`
	ValueJsonPath     string       `json:"value_json_path"`
	ResponseThreshold uint32       `json:"response_threshold"`
}

FeedCreateRequest - struct for create a feed

type FeedEditRequest 

type FeedEditRequest struct {
	FeedName          string       `json:"feed_name"`
	Description       string       `json:"description"`
	LatestHistory     uint64       `json:"latest_history"`
	Providers         []string     `json:"providers"`
	Timeout           int64        `json:"timeout"`
	ServiceFeeCap     sdk.DecCoins `json:"service_fee_cap"`
	RepeatedFrequency uint64       `json:"repeated_frequency"`
	ResponseThreshold uint32       `json:"response_threshold"`
}

FeedEditRequest - struct for edit a existed feed

type FeedValue 

type FeedValue struct {
	Data      string    `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	Timestamp time.Time `protobuf:"bytes,6,opt,name=timestamp,proto3,stdtime" json:"timestamp"`
}

FeedValue defines the feed result standard

func (FeedValue) Convert 

func (this FeedValue) Convert() interface{}

func (*FeedValue) Descriptor 

func (*FeedValue) Descriptor() ([]byte, []int)

func (*FeedValue) Marshal 

func (m *FeedValue) Marshal() (dAtA []byte, err error)

func (*FeedValue) MarshalTo 

func (m *FeedValue) MarshalTo(dAtA []byte) (int, error)

func (*FeedValue) MarshalToSizedBuffer 

func (m *FeedValue) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*FeedValue) ProtoMessage 

func (*FeedValue) ProtoMessage()

func (*FeedValue) Reset 

func (m *FeedValue) Reset()

func (*FeedValue) Size 

func (m *FeedValue) Size() (n int)

func (*FeedValue) String 

func (m *FeedValue) String() string

func (*FeedValue) Unmarshal 

func (m *FeedValue) Unmarshal(dAtA []byte) error

func (*FeedValue) XXX_DiscardUnknown 

func (m *FeedValue) XXX_DiscardUnknown()

func (*FeedValue) XXX_Marshal 

func (m *FeedValue) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FeedValue) XXX_Merge 

func (m *FeedValue) XXX_Merge(src proto.Message)

func (*FeedValue) XXX_Size 

func (m *FeedValue) XXX_Size() int

func (*FeedValue) XXX_Unmarshal 

func (m *FeedValue) XXX_Unmarshal(b []byte) error

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           github_com_bianjieai_irita_sdk_go_types.AccAddress   `` /* 127-byte string literal not displayed */
	ServiceName       string                                               `protobuf:"bytes,5,opt,name=service_name,json=serviceName,proto3" json:"service_name,omitempty" yaml:"service_name"`
	Providers         []github_com_bianjieai_irita_sdk_go_types.AccAddress `` /* 131-byte string literal not displayed */
	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_bianjieai_irita_sdk_go_types.Coins        `` /* 174-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) GetSignBytes 

func (msg MsgCreateFeed) GetSignBytes() []byte

GetSignBytes implements Msg.

func (MsgCreateFeed) GetSigners 

func (msg MsgCreateFeed) GetSigners() []sdk.AccAddress

GetSigners implements Msg.

func (*MsgCreateFeed) Marshal 

func (m *MsgCreateFeed) Marshal() (dAtA []byte, err error)

func (*MsgCreateFeed) MarshalTo 

func (m *MsgCreateFeed) MarshalTo(dAtA []byte) (int, 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 (msg MsgCreateFeed) Route() string

func (*MsgCreateFeed) Size 

func (m *MsgCreateFeed) Size() (n int)

func (*MsgCreateFeed) String 

func (m *MsgCreateFeed) String() string

func (MsgCreateFeed) Type 

func (msg MsgCreateFeed) Type() string

Type implements Msg.

func (*MsgCreateFeed) Unmarshal 

func (m *MsgCreateFeed) Unmarshal(dAtA []byte) error

func (MsgCreateFeed) ValidateBasic 

func (msg MsgCreateFeed) ValidateBasic() error

ValidateBasic implements Msg.

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 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         []github_com_bianjieai_irita_sdk_go_types.AccAddress `` /* 131-byte string literal not displayed */
	Timeout           int64                                                `protobuf:"varint,5,opt,name=timeout,proto3" json:"timeout,omitempty"`
	ServiceFeeCap     github_com_bianjieai_irita_sdk_go_types.Coins        `` /* 174-byte string literal not displayed */
	RepeatedFrequency uint64                                               `` /* 139-byte string literal not displayed */
	ResponseThreshold uint32                                               `` /* 139-byte string literal not displayed */
	Creator           github_com_bianjieai_irita_sdk_go_types.AccAddress   `` /* 127-byte string literal not displayed */
}

MsgEditFeed defines an sdk.Msg type that supports editing a feed

func (*MsgEditFeed) Descriptor 

func (*MsgEditFeed) Descriptor() ([]byte, []int)

func (MsgEditFeed) GetSignBytes 

func (msg MsgEditFeed) GetSignBytes() []byte

GetSignBytes implements Msg.

func (MsgEditFeed) GetSigners 

func (msg MsgEditFeed) GetSigners() []sdk.AccAddress

GetSigners implements Msg.

func (*MsgEditFeed) Marshal 

func (m *MsgEditFeed) Marshal() (dAtA []byte, err error)

func (*MsgEditFeed) MarshalTo 

func (m *MsgEditFeed) MarshalTo(dAtA []byte) (int, 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 (msg MsgEditFeed) Route() string

func (*MsgEditFeed) Size 

func (m *MsgEditFeed) Size() (n int)

func (*MsgEditFeed) String 

func (m *MsgEditFeed) String() string

func (MsgEditFeed) Type 

func (msg MsgEditFeed) Type() string

Type implements Msg.

func (*MsgEditFeed) Unmarshal 

func (m *MsgEditFeed) Unmarshal(dAtA []byte) error

func (MsgEditFeed) ValidateBasic 

func (msg MsgEditFeed) ValidateBasic() error

ValidateBasic implements Msg.

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 MsgPauseFeed 

type MsgPauseFeed struct {
	FeedName string                                             `protobuf:"bytes,1,opt,name=feed_name,json=feedName,proto3" json:"feed_name,omitempty" yaml:"feed_name"`
	Creator  github_com_bianjieai_irita_sdk_go_types.AccAddress `` /* 127-byte string literal not displayed */
}

MsgPauseFeed defines an sdk.Msg type that supports pausing a feed

func (*MsgPauseFeed) Descriptor 

func (*MsgPauseFeed) Descriptor() ([]byte, []int)

func (MsgPauseFeed) GetSignBytes 

func (msg MsgPauseFeed) GetSignBytes() []byte

GetSignBytes implements Msg.

func (MsgPauseFeed) GetSigners 

func (msg MsgPauseFeed) GetSigners() []sdk.AccAddress

GetSigners implements Msg.

func (*MsgPauseFeed) Marshal 

func (m *MsgPauseFeed) Marshal() (dAtA []byte, err error)

func (*MsgPauseFeed) MarshalTo 

func (m *MsgPauseFeed) MarshalTo(dAtA []byte) (int, 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 (msg MsgPauseFeed) Route() string

func (*MsgPauseFeed) Size 

func (m *MsgPauseFeed) Size() (n int)

func (*MsgPauseFeed) String 

func (m *MsgPauseFeed) String() string

func (MsgPauseFeed) Type 

func (msg MsgPauseFeed) Type() string

Type implements Msg.

func (*MsgPauseFeed) Unmarshal 

func (m *MsgPauseFeed) Unmarshal(dAtA []byte) error

func (MsgPauseFeed) ValidateBasic 

func (msg MsgPauseFeed) ValidateBasic() error

ValidateBasic implements Msg.

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 MsgStartFeed 

type MsgStartFeed struct {
	FeedName string                                             `protobuf:"bytes,1,opt,name=feed_name,json=feedName,proto3" json:"feed_name,omitempty" yaml:"feed_name"`
	Creator  github_com_bianjieai_irita_sdk_go_types.AccAddress `` /* 127-byte string literal not displayed */
}

MsgPauseFeed defines an sdk.Msg type that supports stating a feed

func (*MsgStartFeed) Descriptor 

func (*MsgStartFeed) Descriptor() ([]byte, []int)

func (MsgStartFeed) GetSignBytes 

func (msg MsgStartFeed) GetSignBytes() []byte

GetSignBytes implements Msg.

func (MsgStartFeed) GetSigners 

func (msg MsgStartFeed) GetSigners() []sdk.AccAddress

GetSigners implements Msg.

func (*MsgStartFeed) Marshal 

func (m *MsgStartFeed) Marshal() (dAtA []byte, err error)

func (*MsgStartFeed) MarshalTo 

func (m *MsgStartFeed) MarshalTo(dAtA []byte) (int, 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 (msg MsgStartFeed) Route() string

func (*MsgStartFeed) Size 

func (m *MsgStartFeed) Size() (n int)

func (*MsgStartFeed) String 

func (m *MsgStartFeed) String() string

func (MsgStartFeed) Type 

func (msg MsgStartFeed) Type() string

Type implements Msg.

func (*MsgStartFeed) Unmarshal 

func (m *MsgStartFeed) Unmarshal(dAtA []byte) error

func (MsgStartFeed) ValidateBasic 

func (msg MsgStartFeed) ValidateBasic() error

ValidateBasic implements Msg.

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 OracleI 

type OracleI interface {
	sdk.Module
	OracleTx
	OracleQuery
}

func NewClient 

func NewClient(bc sdk.BaseClient, cdc codec.Marshaler) OracleI

type OracleQuery 

type OracleQuery interface {
	QueryFeed(feedName string) (QueryFeedResponse, sdk.Error)
	QueryFeeds(state string) ([]QueryFeedResponse, sdk.Error)
	QueryFeedValue(feedName string) ([]QueryFeedValueResponse, sdk.Error)
}

type OracleTx 

type OracleTx interface {
	CreateFeed(request FeedCreateRequest, baseTx sdk.BaseTx) (sdk.ResultTx, sdk.Error)
	StartFeed(feedName string, baseTx sdk.BaseTx) (sdk.ResultTx, sdk.Error)
	CreateAndStartFeed(request FeedCreateRequest, baseTx sdk.BaseTx) (sdk.ResultTx, sdk.Error)
	PauseFeed(feedName string, baseTx sdk.BaseTx) (sdk.ResultTx, sdk.Error)
	EditFeed(request FeedEditRequest, baseTx sdk.BaseTx) (sdk.ResultTx, sdk.Error)
	SubscribeFeedValue(feedName string, callback func(value FeedValue)) (sdk.Subscription, sdk.Error)
}

type QueryFeedResponse 

type QueryFeedResponse struct {
	Feed              *Feed                       `json:"feed"`
	ServiceName       string                      `json:"service_name"`
	Providers         []sdk.AccAddress            `json:"providers"`
	Input             string                      `json:"input"`
	Timeout           int64                       `json:"timeout"`
	ServiceFeeCap     sdk.Coins                   `json:"service_fee_cap"`
	RepeatedFrequency uint64                      `json:"repeated_frequency"`
	ResponseThreshold uint32                      `json:"response_threshold"`
	State             service.RequestContextState `json:"state"`
}

type QueryFeedValueResponse 

type QueryFeedValueResponse struct {
	Data      string    `json:"data"`
	Timestamp time.Time `json:"timestamp"`
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.