Documentation ¶
Overview ¶
Package types is a reverse proxy.
It translates gRPC into RESTful JSON APIs.
Index ¶
- Constants
- Variables
- func GetKeyPrefixOracle(oracleAddr sdk.AccAddress) []byte
- func RegisterCodec(cdc *codec.LegacyAmino)
- func RegisterInterfaces(registry cdctypes.InterfaceRegistry)
- 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)
- type AccountKeeper
- type GenesisState
- func (*GenesisState) Descriptor() ([]byte, []int)
- func (m *GenesisState) GetOracles() []Oracle
- 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 (*GenesisState) ProtoMessage()
- func (m *GenesisState) Reset()
- func (m *GenesisState) Size() (n int)
- func (m *GenesisState) String() string
- func (m *GenesisState) Unmarshal(dAtA []byte) error
- func (gs GenesisState) Validate() 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
- type MsgRegisterOracle
- func (*MsgRegisterOracle) Descriptor() ([]byte, []int)
- func (m *MsgRegisterOracle) GetOracleDetail() *Oracle
- func (msg *MsgRegisterOracle) GetSignBytes() []byte
- func (msg *MsgRegisterOracle) GetSigners() []sdk.AccAddress
- func (m *MsgRegisterOracle) Marshal() (dAtA []byte, err error)
- func (m *MsgRegisterOracle) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgRegisterOracle) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgRegisterOracle) ProtoMessage()
- func (m *MsgRegisterOracle) Reset()
- func (msg *MsgRegisterOracle) Route() string
- func (m *MsgRegisterOracle) Size() (n int)
- func (m *MsgRegisterOracle) String() string
- func (msg *MsgRegisterOracle) Type() string
- func (m *MsgRegisterOracle) Unmarshal(dAtA []byte) error
- func (msg *MsgRegisterOracle) ValidateBasic() error
- func (m *MsgRegisterOracle) XXX_DiscardUnknown()
- func (m *MsgRegisterOracle) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgRegisterOracle) XXX_Merge(src proto.Message)
- func (m *MsgRegisterOracle) XXX_Size() int
- func (m *MsgRegisterOracle) XXX_Unmarshal(b []byte) error
- type MsgRegisterOracleResponse
- func (*MsgRegisterOracleResponse) Descriptor() ([]byte, []int)
- func (m *MsgRegisterOracleResponse) Marshal() (dAtA []byte, err error)
- func (m *MsgRegisterOracleResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgRegisterOracleResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgRegisterOracleResponse) ProtoMessage()
- func (m *MsgRegisterOracleResponse) Reset()
- func (m *MsgRegisterOracleResponse) Size() (n int)
- func (m *MsgRegisterOracleResponse) String() string
- func (m *MsgRegisterOracleResponse) Unmarshal(dAtA []byte) error
- func (m *MsgRegisterOracleResponse) XXX_DiscardUnknown()
- func (m *MsgRegisterOracleResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgRegisterOracleResponse) XXX_Merge(src proto.Message)
- func (m *MsgRegisterOracleResponse) XXX_Size() int
- func (m *MsgRegisterOracleResponse) XXX_Unmarshal(b []byte) error
- type MsgServer
- type MsgUpdateOracle
- func (*MsgUpdateOracle) Descriptor() ([]byte, []int)
- func (m *MsgUpdateOracle) GetEndpoint() string
- func (m *MsgUpdateOracle) GetOracle() string
- func (msg *MsgUpdateOracle) GetSignBytes() []byte
- func (msg *MsgUpdateOracle) GetSigners() []sdk.AccAddress
- func (m *MsgUpdateOracle) Marshal() (dAtA []byte, err error)
- func (m *MsgUpdateOracle) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgUpdateOracle) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgUpdateOracle) ProtoMessage()
- func (m *MsgUpdateOracle) Reset()
- func (msg *MsgUpdateOracle) Route() string
- func (m *MsgUpdateOracle) Size() (n int)
- func (m *MsgUpdateOracle) String() string
- func (msg *MsgUpdateOracle) Type() string
- func (m *MsgUpdateOracle) Unmarshal(dAtA []byte) error
- func (msg *MsgUpdateOracle) ValidateBasic() error
- func (m *MsgUpdateOracle) XXX_DiscardUnknown()
- func (m *MsgUpdateOracle) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgUpdateOracle) XXX_Merge(src proto.Message)
- func (m *MsgUpdateOracle) XXX_Size() int
- func (m *MsgUpdateOracle) XXX_Unmarshal(b []byte) error
- type MsgUpdateOracleResponse
- func (*MsgUpdateOracleResponse) Descriptor() ([]byte, []int)
- func (m *MsgUpdateOracleResponse) Marshal() (dAtA []byte, err error)
- func (m *MsgUpdateOracleResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgUpdateOracleResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgUpdateOracleResponse) ProtoMessage()
- func (m *MsgUpdateOracleResponse) Reset()
- func (m *MsgUpdateOracleResponse) Size() (n int)
- func (m *MsgUpdateOracleResponse) String() string
- func (m *MsgUpdateOracleResponse) Unmarshal(dAtA []byte) error
- func (m *MsgUpdateOracleResponse) XXX_DiscardUnknown()
- func (m *MsgUpdateOracleResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgUpdateOracleResponse) XXX_Merge(src proto.Message)
- func (m *MsgUpdateOracleResponse) XXX_Size() int
- func (m *MsgUpdateOracleResponse) XXX_Unmarshal(b []byte) error
- type Oracle
- func (*Oracle) Descriptor() ([]byte, []int)
- func (m *Oracle) GetAddress() string
- func (m *Oracle) GetEndpoint() string
- func (m *Oracle) Marshal() (dAtA []byte, err error)
- func (m *Oracle) MarshalTo(dAtA []byte) (int, error)
- func (m *Oracle) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Oracle) ProtoMessage()
- func (m *Oracle) Reset()
- func (m *Oracle) Size() (n int)
- func (m *Oracle) String() string
- func (m *Oracle) Unmarshal(dAtA []byte) error
- func (m *Oracle) XXX_DiscardUnknown()
- func (m *Oracle) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Oracle) XXX_Merge(src proto.Message)
- func (m *Oracle) XXX_Size() int
- func (m *Oracle) XXX_Unmarshal(b []byte) error
- type QueryClient
- type QueryOracleRequest
- func (*QueryOracleRequest) Descriptor() ([]byte, []int)
- func (m *QueryOracleRequest) GetAddress() string
- func (m *QueryOracleRequest) Marshal() (dAtA []byte, err error)
- func (m *QueryOracleRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryOracleRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryOracleRequest) ProtoMessage()
- func (m *QueryOracleRequest) Reset()
- func (m *QueryOracleRequest) Size() (n int)
- func (m *QueryOracleRequest) String() string
- func (m *QueryOracleRequest) Unmarshal(dAtA []byte) error
- func (m *QueryOracleRequest) XXX_DiscardUnknown()
- func (m *QueryOracleRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryOracleRequest) XXX_Merge(src proto.Message)
- func (m *QueryOracleRequest) XXX_Size() int
- func (m *QueryOracleRequest) XXX_Unmarshal(b []byte) error
- type QueryOracleResponse
- func (*QueryOracleResponse) Descriptor() ([]byte, []int)
- func (m *QueryOracleResponse) GetOracle() *Oracle
- func (m *QueryOracleResponse) Marshal() (dAtA []byte, err error)
- func (m *QueryOracleResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryOracleResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryOracleResponse) ProtoMessage()
- func (m *QueryOracleResponse) Reset()
- func (m *QueryOracleResponse) Size() (n int)
- func (m *QueryOracleResponse) String() string
- func (m *QueryOracleResponse) Unmarshal(dAtA []byte) error
- func (m *QueryOracleResponse) XXX_DiscardUnknown()
- func (m *QueryOracleResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryOracleResponse) XXX_Merge(src proto.Message)
- func (m *QueryOracleResponse) XXX_Size() int
- func (m *QueryOracleResponse) XXX_Unmarshal(b []byte) error
- type QueryServer
- type UnimplementedMsgServer
- type UnimplementedQueryServer
Constants ¶
const ( // ModuleName defines the module name ModuleName = "oracle" // StoreKey defines the primary module store key StoreKey = ModuleName // RouterKey is the message route for slashing RouterKey = ModuleName // QuerierRoute defines the module's query routing key QuerierRoute = ModuleName // MemStoreKey defines the in-memory store key MemStoreKey = "mem_oracle" )
Variables ¶
var ( ErrOracleNotFound = sdkerrors.Register(ModuleName, 1, "oracle not found") ErrOracleAlreadyExist = sdkerrors.Register(ModuleName, 2, "oracle already exists") ErrInvalidUpdateRequester = sdkerrors.Register(ModuleName, 3, "invalid update requester") ErrNotRegisteredOracle = sdkerrors.Register(ModuleName, 4, "oracle is not registered") ErrInvalidOracleAccAddress = sdkerrors.Register(ModuleName, 5, "invalid oracle account address") )
var ( ErrInvalidLengthGenesis = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowGenesis = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupGenesis = fmt.Errorf("proto: unexpected end of group") )
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 ( // KeyPrefixOracles defines key to store oracle KeyPrefixOracles = []byte{0x01} )
var (
ModuleCdc = codec.NewAminoCodec(amino)
)
Functions ¶
func GetKeyPrefixOracle ¶
func GetKeyPrefixOracle(oracleAddr sdk.AccAddress) []byte
func RegisterCodec ¶
func RegisterCodec(cdc *codec.LegacyAmino)
func RegisterInterfaces ¶
func RegisterInterfaces(registry cdctypes.InterfaceRegistry)
func RegisterMsgServer ¶
func RegisterQueryHandler ¶
RegisterQueryHandler registers the http handlers for service Query to "mux". The handlers forward requests to the grpc endpoint over "conn".
func RegisterQueryHandlerClient ¶
func RegisterQueryHandlerClient(ctx context.Context, mux *runtime.ServeMux, client QueryClient) error
RegisterQueryHandlerClient registers the http handlers for service Query to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "QueryClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "QueryClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "QueryClient" to call the correct interceptors.
func RegisterQueryHandlerFromEndpoint ¶
func RegisterQueryHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)
RegisterQueryHandlerFromEndpoint is same as RegisterQueryHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.
func RegisterQueryHandlerServer ¶
func RegisterQueryHandlerServer(ctx context.Context, mux *runtime.ServeMux, server QueryServer) error
RegisterQueryHandlerServer registers the http handlers for service Query to "mux". UnaryRPC :call QueryServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features (such as grpc.SendHeader, etc) to stop working. Consider using RegisterQueryHandlerFromEndpoint instead.
func RegisterQueryServer ¶
func RegisterQueryServer(s grpc1.Server, srv QueryServer)
Types ¶
type AccountKeeper ¶
type AccountKeeper interface {
GetPubKey(sdk.Context, sdk.AccAddress) (cryptotypes.PubKey, error)
}
type GenesisState ¶
type GenesisState struct {
Oracles []Oracle `protobuf:"bytes,1,rep,name=oracles,proto3" json:"oracles"`
}
GenesisState defines the oracle module's genesis state.
func DefaultGenesis ¶
func DefaultGenesis() *GenesisState
DefaultGenesis returns the default Capability genesis state
func (*GenesisState) Descriptor ¶
func (*GenesisState) Descriptor() ([]byte, []int)
func (*GenesisState) GetOracles ¶
func (m *GenesisState) GetOracles() []Oracle
func (*GenesisState) Marshal ¶
func (m *GenesisState) Marshal() (dAtA []byte, err error)
func (*GenesisState) MarshalToSizedBuffer ¶
func (m *GenesisState) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GenesisState) ProtoMessage ¶
func (*GenesisState) ProtoMessage()
func (*GenesisState) Reset ¶
func (m *GenesisState) Reset()
func (*GenesisState) Size ¶
func (m *GenesisState) Size() (n int)
func (*GenesisState) String ¶
func (m *GenesisState) String() string
func (*GenesisState) Unmarshal ¶
func (m *GenesisState) Unmarshal(dAtA []byte) error
func (GenesisState) Validate ¶
func (gs GenesisState) Validate() error
Validate performs basic genesis state validation returning an error upon any failure.
func (*GenesisState) XXX_DiscardUnknown ¶
func (m *GenesisState) XXX_DiscardUnknown()
func (*GenesisState) XXX_Marshal ¶
func (m *GenesisState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GenesisState) XXX_Merge ¶
func (m *GenesisState) XXX_Merge(src proto.Message)
func (*GenesisState) XXX_Size ¶
func (m *GenesisState) XXX_Size() int
func (*GenesisState) XXX_Unmarshal ¶
func (m *GenesisState) XXX_Unmarshal(b []byte) error
type MsgClient ¶
type MsgClient interface { // RegisterOracle defines a method for registration of oracle. RegisterOracle(ctx context.Context, in *MsgRegisterOracle, opts ...grpc.CallOption) (*MsgRegisterOracleResponse, error) // UpdateOracle defines a method for updating of oracle. UpdateOracle(ctx context.Context, in *MsgUpdateOracle, opts ...grpc.CallOption) (*MsgUpdateOracleResponse, 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 MsgRegisterOracle ¶
type MsgRegisterOracle struct {
OracleDetail *Oracle `protobuf:"bytes,1,opt,name=oracle_detail,json=oracleDetail,proto3" json:"oracle_detail,omitempty"`
}
MsgRegisterOracle defines the Msg/RegisterOracle request type.
func NewMsgRegisterOracle ¶
func NewMsgRegisterOracle(oracle *Oracle) *MsgRegisterOracle
func (*MsgRegisterOracle) Descriptor ¶
func (*MsgRegisterOracle) Descriptor() ([]byte, []int)
func (*MsgRegisterOracle) GetOracleDetail ¶
func (m *MsgRegisterOracle) GetOracleDetail() *Oracle
func (*MsgRegisterOracle) GetSignBytes ¶
func (msg *MsgRegisterOracle) GetSignBytes() []byte
func (*MsgRegisterOracle) GetSigners ¶
func (msg *MsgRegisterOracle) GetSigners() []sdk.AccAddress
func (*MsgRegisterOracle) Marshal ¶
func (m *MsgRegisterOracle) Marshal() (dAtA []byte, err error)
func (*MsgRegisterOracle) MarshalTo ¶
func (m *MsgRegisterOracle) MarshalTo(dAtA []byte) (int, error)
func (*MsgRegisterOracle) MarshalToSizedBuffer ¶
func (m *MsgRegisterOracle) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MsgRegisterOracle) ProtoMessage ¶
func (*MsgRegisterOracle) ProtoMessage()
func (*MsgRegisterOracle) Reset ¶
func (m *MsgRegisterOracle) Reset()
func (*MsgRegisterOracle) Route ¶
func (msg *MsgRegisterOracle) Route() string
func (*MsgRegisterOracle) Size ¶
func (m *MsgRegisterOracle) Size() (n int)
func (*MsgRegisterOracle) String ¶
func (m *MsgRegisterOracle) String() string
func (*MsgRegisterOracle) Type ¶
func (msg *MsgRegisterOracle) Type() string
func (*MsgRegisterOracle) Unmarshal ¶
func (m *MsgRegisterOracle) Unmarshal(dAtA []byte) error
func (*MsgRegisterOracle) ValidateBasic ¶
func (msg *MsgRegisterOracle) ValidateBasic() error
func (*MsgRegisterOracle) XXX_DiscardUnknown ¶
func (m *MsgRegisterOracle) XXX_DiscardUnknown()
func (*MsgRegisterOracle) XXX_Marshal ¶
func (m *MsgRegisterOracle) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MsgRegisterOracle) XXX_Merge ¶
func (m *MsgRegisterOracle) XXX_Merge(src proto.Message)
func (*MsgRegisterOracle) XXX_Size ¶
func (m *MsgRegisterOracle) XXX_Size() int
func (*MsgRegisterOracle) XXX_Unmarshal ¶
func (m *MsgRegisterOracle) XXX_Unmarshal(b []byte) error
type MsgRegisterOracleResponse ¶
type MsgRegisterOracleResponse struct { }
MsgRegisterOracleResponse defines the Msg/RegisterOracle response type.
func (*MsgRegisterOracleResponse) Descriptor ¶
func (*MsgRegisterOracleResponse) Descriptor() ([]byte, []int)
func (*MsgRegisterOracleResponse) Marshal ¶
func (m *MsgRegisterOracleResponse) Marshal() (dAtA []byte, err error)
func (*MsgRegisterOracleResponse) MarshalTo ¶
func (m *MsgRegisterOracleResponse) MarshalTo(dAtA []byte) (int, error)
func (*MsgRegisterOracleResponse) MarshalToSizedBuffer ¶
func (m *MsgRegisterOracleResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MsgRegisterOracleResponse) ProtoMessage ¶
func (*MsgRegisterOracleResponse) ProtoMessage()
func (*MsgRegisterOracleResponse) Reset ¶
func (m *MsgRegisterOracleResponse) Reset()
func (*MsgRegisterOracleResponse) Size ¶
func (m *MsgRegisterOracleResponse) Size() (n int)
func (*MsgRegisterOracleResponse) String ¶
func (m *MsgRegisterOracleResponse) String() string
func (*MsgRegisterOracleResponse) Unmarshal ¶
func (m *MsgRegisterOracleResponse) Unmarshal(dAtA []byte) error
func (*MsgRegisterOracleResponse) XXX_DiscardUnknown ¶
func (m *MsgRegisterOracleResponse) XXX_DiscardUnknown()
func (*MsgRegisterOracleResponse) XXX_Marshal ¶
func (m *MsgRegisterOracleResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MsgRegisterOracleResponse) XXX_Merge ¶
func (m *MsgRegisterOracleResponse) XXX_Merge(src proto.Message)
func (*MsgRegisterOracleResponse) XXX_Size ¶
func (m *MsgRegisterOracleResponse) XXX_Size() int
func (*MsgRegisterOracleResponse) XXX_Unmarshal ¶
func (m *MsgRegisterOracleResponse) XXX_Unmarshal(b []byte) error
type MsgServer ¶
type MsgServer interface { // RegisterOracle defines a method for registration of oracle. RegisterOracle(context.Context, *MsgRegisterOracle) (*MsgRegisterOracleResponse, error) // UpdateOracle defines a method for updating of oracle. UpdateOracle(context.Context, *MsgUpdateOracle) (*MsgUpdateOracleResponse, error) }
MsgServer is the server API for Msg service.
type MsgUpdateOracle ¶
type MsgUpdateOracle struct { Oracle string `protobuf:"bytes,1,opt,name=oracle,proto3" json:"oracle,omitempty"` Endpoint string `protobuf:"bytes,2,opt,name=endpoint,proto3" json:"endpoint,omitempty"` }
MsgUpdateOracle defines the Msg/UpdateOracle request type.
func NewMsgUpdateOracle ¶
func NewMsgUpdateOracle(address, endpoint string) *MsgUpdateOracle
func (*MsgUpdateOracle) Descriptor ¶
func (*MsgUpdateOracle) Descriptor() ([]byte, []int)
func (*MsgUpdateOracle) GetEndpoint ¶
func (m *MsgUpdateOracle) GetEndpoint() string
func (*MsgUpdateOracle) GetOracle ¶
func (m *MsgUpdateOracle) GetOracle() string
func (*MsgUpdateOracle) GetSignBytes ¶
func (msg *MsgUpdateOracle) GetSignBytes() []byte
func (*MsgUpdateOracle) GetSigners ¶
func (msg *MsgUpdateOracle) GetSigners() []sdk.AccAddress
func (*MsgUpdateOracle) Marshal ¶
func (m *MsgUpdateOracle) Marshal() (dAtA []byte, err error)
func (*MsgUpdateOracle) MarshalToSizedBuffer ¶
func (m *MsgUpdateOracle) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MsgUpdateOracle) ProtoMessage ¶
func (*MsgUpdateOracle) ProtoMessage()
func (*MsgUpdateOracle) Reset ¶
func (m *MsgUpdateOracle) Reset()
func (*MsgUpdateOracle) Route ¶
func (msg *MsgUpdateOracle) Route() string
func (*MsgUpdateOracle) Size ¶
func (m *MsgUpdateOracle) Size() (n int)
func (*MsgUpdateOracle) String ¶
func (m *MsgUpdateOracle) String() string
func (*MsgUpdateOracle) Type ¶
func (msg *MsgUpdateOracle) Type() string
func (*MsgUpdateOracle) Unmarshal ¶
func (m *MsgUpdateOracle) Unmarshal(dAtA []byte) error
func (*MsgUpdateOracle) ValidateBasic ¶
func (msg *MsgUpdateOracle) ValidateBasic() error
func (*MsgUpdateOracle) XXX_DiscardUnknown ¶
func (m *MsgUpdateOracle) XXX_DiscardUnknown()
func (*MsgUpdateOracle) XXX_Marshal ¶
func (m *MsgUpdateOracle) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MsgUpdateOracle) XXX_Merge ¶
func (m *MsgUpdateOracle) XXX_Merge(src proto.Message)
func (*MsgUpdateOracle) XXX_Size ¶
func (m *MsgUpdateOracle) XXX_Size() int
func (*MsgUpdateOracle) XXX_Unmarshal ¶
func (m *MsgUpdateOracle) XXX_Unmarshal(b []byte) error
type MsgUpdateOracleResponse ¶
type MsgUpdateOracleResponse struct { }
MsgUpdateOracleResponse defines the Msg/UpdateOracle response type.
func (*MsgUpdateOracleResponse) Descriptor ¶
func (*MsgUpdateOracleResponse) Descriptor() ([]byte, []int)
func (*MsgUpdateOracleResponse) Marshal ¶
func (m *MsgUpdateOracleResponse) Marshal() (dAtA []byte, err error)
func (*MsgUpdateOracleResponse) MarshalTo ¶
func (m *MsgUpdateOracleResponse) MarshalTo(dAtA []byte) (int, error)
func (*MsgUpdateOracleResponse) MarshalToSizedBuffer ¶
func (m *MsgUpdateOracleResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MsgUpdateOracleResponse) ProtoMessage ¶
func (*MsgUpdateOracleResponse) ProtoMessage()
func (*MsgUpdateOracleResponse) Reset ¶
func (m *MsgUpdateOracleResponse) Reset()
func (*MsgUpdateOracleResponse) Size ¶
func (m *MsgUpdateOracleResponse) Size() (n int)
func (*MsgUpdateOracleResponse) String ¶
func (m *MsgUpdateOracleResponse) String() string
func (*MsgUpdateOracleResponse) Unmarshal ¶
func (m *MsgUpdateOracleResponse) Unmarshal(dAtA []byte) error
func (*MsgUpdateOracleResponse) XXX_DiscardUnknown ¶
func (m *MsgUpdateOracleResponse) XXX_DiscardUnknown()
func (*MsgUpdateOracleResponse) XXX_Marshal ¶
func (m *MsgUpdateOracleResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MsgUpdateOracleResponse) XXX_Merge ¶
func (m *MsgUpdateOracleResponse) XXX_Merge(src proto.Message)
func (*MsgUpdateOracleResponse) XXX_Size ¶
func (m *MsgUpdateOracleResponse) XXX_Size() int
func (*MsgUpdateOracleResponse) XXX_Unmarshal ¶
func (m *MsgUpdateOracleResponse) XXX_Unmarshal(b []byte) error
type Oracle ¶
type Oracle struct { Endpoint string `protobuf:"bytes,1,opt,name=endpoint,proto3" json:"endpoint,omitempty"` Address string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"` }
Oracle defines a detail of oracle.
func (*Oracle) Descriptor ¶
func (*Oracle) GetAddress ¶
func (*Oracle) GetEndpoint ¶
func (*Oracle) MarshalToSizedBuffer ¶
func (*Oracle) ProtoMessage ¶
func (*Oracle) ProtoMessage()
func (*Oracle) XXX_DiscardUnknown ¶
func (m *Oracle) XXX_DiscardUnknown()
func (*Oracle) XXX_Marshal ¶
func (*Oracle) XXX_Unmarshal ¶
type QueryClient ¶
type QueryClient interface { // Oracle returns a Oracle. Oracle(ctx context.Context, in *QueryOracleRequest, opts ...grpc.CallOption) (*QueryOracleResponse, 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 QueryOracleRequest ¶
type QueryOracleRequest struct {
Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
}
QueryOracleRequest is the request type for the Query/Oracle RPC method.
func (*QueryOracleRequest) Descriptor ¶
func (*QueryOracleRequest) Descriptor() ([]byte, []int)
func (*QueryOracleRequest) GetAddress ¶
func (m *QueryOracleRequest) GetAddress() string
func (*QueryOracleRequest) Marshal ¶
func (m *QueryOracleRequest) Marshal() (dAtA []byte, err error)
func (*QueryOracleRequest) MarshalTo ¶
func (m *QueryOracleRequest) MarshalTo(dAtA []byte) (int, error)
func (*QueryOracleRequest) MarshalToSizedBuffer ¶
func (m *QueryOracleRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryOracleRequest) ProtoMessage ¶
func (*QueryOracleRequest) ProtoMessage()
func (*QueryOracleRequest) Reset ¶
func (m *QueryOracleRequest) Reset()
func (*QueryOracleRequest) Size ¶
func (m *QueryOracleRequest) Size() (n int)
func (*QueryOracleRequest) String ¶
func (m *QueryOracleRequest) String() string
func (*QueryOracleRequest) Unmarshal ¶
func (m *QueryOracleRequest) Unmarshal(dAtA []byte) error
func (*QueryOracleRequest) XXX_DiscardUnknown ¶
func (m *QueryOracleRequest) XXX_DiscardUnknown()
func (*QueryOracleRequest) XXX_Marshal ¶
func (m *QueryOracleRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryOracleRequest) XXX_Merge ¶
func (m *QueryOracleRequest) XXX_Merge(src proto.Message)
func (*QueryOracleRequest) XXX_Size ¶
func (m *QueryOracleRequest) XXX_Size() int
func (*QueryOracleRequest) XXX_Unmarshal ¶
func (m *QueryOracleRequest) XXX_Unmarshal(b []byte) error
type QueryOracleResponse ¶
type QueryOracleResponse struct {
Oracle *Oracle `protobuf:"bytes,1,opt,name=oracle,proto3" json:"oracle,omitempty"`
}
QueryOracleResponse is the response type for the Query/Oracle RPC method.
func (*QueryOracleResponse) Descriptor ¶
func (*QueryOracleResponse) Descriptor() ([]byte, []int)
func (*QueryOracleResponse) GetOracle ¶
func (m *QueryOracleResponse) GetOracle() *Oracle
func (*QueryOracleResponse) Marshal ¶
func (m *QueryOracleResponse) Marshal() (dAtA []byte, err error)
func (*QueryOracleResponse) MarshalTo ¶
func (m *QueryOracleResponse) MarshalTo(dAtA []byte) (int, error)
func (*QueryOracleResponse) MarshalToSizedBuffer ¶
func (m *QueryOracleResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryOracleResponse) ProtoMessage ¶
func (*QueryOracleResponse) ProtoMessage()
func (*QueryOracleResponse) Reset ¶
func (m *QueryOracleResponse) Reset()
func (*QueryOracleResponse) Size ¶
func (m *QueryOracleResponse) Size() (n int)
func (*QueryOracleResponse) String ¶
func (m *QueryOracleResponse) String() string
func (*QueryOracleResponse) Unmarshal ¶
func (m *QueryOracleResponse) Unmarshal(dAtA []byte) error
func (*QueryOracleResponse) XXX_DiscardUnknown ¶
func (m *QueryOracleResponse) XXX_DiscardUnknown()
func (*QueryOracleResponse) XXX_Marshal ¶
func (m *QueryOracleResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryOracleResponse) XXX_Merge ¶
func (m *QueryOracleResponse) XXX_Merge(src proto.Message)
func (*QueryOracleResponse) XXX_Size ¶
func (m *QueryOracleResponse) XXX_Size() int
func (*QueryOracleResponse) XXX_Unmarshal ¶
func (m *QueryOracleResponse) XXX_Unmarshal(b []byte) error
type QueryServer ¶
type QueryServer interface { // Oracle returns a Oracle. Oracle(context.Context, *QueryOracleRequest) (*QueryOracleResponse, 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) RegisterOracle ¶
func (*UnimplementedMsgServer) RegisterOracle(ctx context.Context, req *MsgRegisterOracle) (*MsgRegisterOracleResponse, error)
func (*UnimplementedMsgServer) UpdateOracle ¶
func (*UnimplementedMsgServer) UpdateOracle(ctx context.Context, req *MsgUpdateOracle) (*MsgUpdateOracleResponse, error)
type UnimplementedQueryServer ¶
type UnimplementedQueryServer struct { }
UnimplementedQueryServer can be embedded to have forward compatible implementations.
func (*UnimplementedQueryServer) Oracle ¶
func (*UnimplementedQueryServer) Oracle(ctx context.Context, req *QueryOracleRequest) (*QueryOracleResponse, error)