types

package
v0.5.4 Latest Latest
Warning

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

 Go to latest Published: Nov 7, 2024 License: Apache-2.0 Imports: 27 Imported by: 0

Documentation

Overview

Package types is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

View Source 
const (
	// TypeUnrecognized means coin type is unrecognized
	TypeUnrecognized = iota
	// TypeGeneralMessage is a pure message
	TypeGeneralMessage
	// TypeGeneralMessageWithToken is a general message with token
	TypeGeneralMessageWithToken
	// TypeSendToken is a direct token transfer
	TypeSendToken
)
View Source 
const (
	// ModuleName defines the module name
	ModuleName = "gmp"

	// StoreKey defines the primary module store key
	StoreKey = ModuleName

	// RouterKey is the message route
	RouterKey = ModuleName

	// QuerierRoute is the query router key for the gmp module
	QuerierRoute = ModuleName
)

Variables

View Source 
var (
	ErrInvalidLengthGenesis        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowGenesis          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupGenesis = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthGmp        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowGmp          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupGmp = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthQuery        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowQuery          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupQuery = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthTx        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTx          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupTx = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (

	// ModuleCdc references the global module codec. Note, the codec should
	// ONLY be used in certain instances of tests and for JSON encoding as Amino is
	// still used for that purpose.
	//
	// The actual codec used for serialization should be provided to x/staking and
	// defined at the application level.
	ModuleCdc = codec.NewAminoCodec(amino) //nolint:all
)
View Source 
var Msg_serviceDesc = _Msg_serviceDesc
View Source 
var (
	ParamsKey = []byte("p_gmp")
)

KVStore key prefixes

View Source 
var Query_serviceDesc = _Query_serviceDesc

Functions

func RegisterInterfaces 

func RegisterInterfaces(registry codectypes.InterfaceRegistry)

RegisterInterfaces registers the x/gmp interfaces types with the interface registry

func RegisterMsgServer 

func RegisterMsgServer(s grpc1.Server, srv MsgServer)

func RegisterQueryHandler 

func RegisterQueryHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

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 to stop working. Consider using RegisterQueryHandlerFromEndpoint instead.

func RegisterQueryServer 

func RegisterQueryServer(s grpc1.Server, srv QueryServer)

Types

type GenesisState 

type GenesisState struct {
	Params Params `protobuf:"bytes,1,opt,name=params,proto3" json:"params"`
}

GenesisState represents the genesis state of the gmp module.

func DefaultGenesisState 

func DefaultGenesisState() *GenesisState

func (*GenesisState) Descriptor 

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

func (*GenesisState) GetParams 

func (m *GenesisState) GetParams() Params

func (*GenesisState) Marshal 

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

func (*GenesisState) MarshalTo 

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

type GmpDecoder struct {
	DestinationContractAddress  common.Address
	DestinationContractCalldata []byte
}

GmpDecoder is the payload sent from Axelar to IBC middleware. It needs to be decoded using the ABI.

func NewGmpDecoder 

func NewGmpDecoder(payload []byte) (GmpDecoder, error)

NewGmpDecoder decodes a payload from GMP given a byte array

type GmpEncoder 

type GmpEncoder struct {
	DestinationContractAddress  common.Address
	DestinationContractCalldata []byte
}

GmpEncoder is the struct we use to encode the data we want to send to the GMP.

func NewGMPEncoder 

func NewGMPEncoder(
	destinationContractAddress common.Address,
	destinationContractCalldata []byte,
) GmpEncoder

func (GmpEncoder) GMPEncode 

func (g GmpEncoder) GMPEncode() ([]byte, error)

GMPEncode encodes the GMP data into a byte array.

type GmpFee 

type GmpFee struct {
	// Fee amount
	Amount string `json:"amount"`
	// Recipient of fee; should be fee_recipient.
	Recipient string `json:"recipient"`
}

GMPFee defines the fee field message inside of GMPMessage.

type GmpMessage 

type GmpMessage struct {
	// DestinationChain is the destination chain of the message
	DestinationChain string `json:"destination_chain"`
	// DestinationAddress is the destination address of the message
	DestinationAddress string `json:"destination_address"`
	// Payload is the encoded payload of the message (exchange rates)
	Payload []byte `json:"payload"`
	// Type is an enum that specifies the type of message
	Type int64 `json:"type"`
	// Fee is the fee paid to a relayer on the Axelar network
	Fee *GmpFee `json:"fee"`
}

GmpMessage defines the GMP message that we encode in the IBC memo field and send to Axelar.

Ref: https://github.com/axelarnetwork/evm-cosmos-gmp-sample

type IBCTransferKeeper 

type IBCTransferKeeper interface {
	Transfer(goCtx context.Context, msg *ibctransfertypes.MsgTransfer) (*ibctransfertypes.MsgTransferResponse, error)
}

type MsgBridge 

type MsgBridge struct {
	// relayer is the address that signs the message.
	Relayer string `protobuf:"bytes,1,opt,name=relayer,proto3" json:"relayer,omitempty"`
	// destination_chain defines the chain which this will be relayed to.
	DestinationChain string `protobuf:"bytes,2,opt,name=destination_chain,json=destinationChain,proto3" json:"destination_chain,omitempty"`
	// warden_contract_address defines the warden contract that GMP is calling.
	WardenContractAddress string `` /* 126-byte string literal not displayed */
	// destination_contract_address defines the destination contract that warden is calling.
	DestinationContractAddress string `` /* 141-byte string literal not displayed */
	// destination_contract_calldata defines the command to call.
	DestinationContractCalldata []byte `` /* 144-byte string literal not displayed */
	// token determines the IBC token that the user wants to relay via GMP.
	Token types.Coin `protobuf:"bytes,6,opt,name=token,proto3,castrepeated=github.com/cosmos/cosmos-sdk/types.Coins" json:"token"`
}

MsgBridge defines the Bridge message type.

func NewMsgBridge 

func NewMsgBridge(
	relayer string,
	destinationChain string,
	wardenContractAddress string,
	destinationContractAddress string,
	destinationContractCalldata []byte,
	token sdk.Coin,
) *MsgBridge

func (*MsgBridge) Descriptor 

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

func (*MsgBridge) Marshal 

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

func (*MsgBridge) MarshalTo 

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

func (*MsgBridge) MarshalToSizedBuffer 

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

func (*MsgBridge) ProtoMessage 

func (*MsgBridge) ProtoMessage()

func (*MsgBridge) Reset 

func (m *MsgBridge) Reset()

func (*MsgBridge) Size 

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

func (*MsgBridge) String 

func (m *MsgBridge) String() string

func (MsgBridge) Type 

func (msg MsgBridge) Type() string

Type implements LegacyMsg interface

func (*MsgBridge) Unmarshal 

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

func (MsgBridge) ValidateBasic 

func (msg MsgBridge) ValidateBasic() error

ValidateBasic Implements sdk.Msg

func (*MsgBridge) XXX_DiscardUnknown 

func (m *MsgBridge) XXX_DiscardUnknown()

func (*MsgBridge) XXX_Marshal 

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

func (*MsgBridge) XXX_Merge 

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

func (*MsgBridge) XXX_Size 

func (m *MsgBridge) XXX_Size() int

func (*MsgBridge) XXX_Unmarshal 

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

type MsgBridgeResponse 

type MsgBridgeResponse struct {
}

MsgBridge defines the Bridge response type.

func (*MsgBridgeResponse) Descriptor 

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

func (*MsgBridgeResponse) Marshal 

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

func (*MsgBridgeResponse) MarshalTo 

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

func (*MsgBridgeResponse) MarshalToSizedBuffer 

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

func (*MsgBridgeResponse) ProtoMessage 

func (*MsgBridgeResponse) ProtoMessage()

func (*MsgBridgeResponse) Reset 

func (m *MsgBridgeResponse) Reset()

func (*MsgBridgeResponse) Size 

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

func (*MsgBridgeResponse) String 

func (m *MsgBridgeResponse) String() string

func (*MsgBridgeResponse) Unmarshal 

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

func (*MsgBridgeResponse) XXX_DiscardUnknown 

func (m *MsgBridgeResponse) XXX_DiscardUnknown()

func (*MsgBridgeResponse) XXX_Marshal 

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

func (*MsgBridgeResponse) XXX_Merge 

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

func (*MsgBridgeResponse) XXX_Size 

func (m *MsgBridgeResponse) XXX_Size() int

func (*MsgBridgeResponse) XXX_Unmarshal 

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

type MsgClient 

type MsgClient interface {
	// SetParams sets the parameters for the gmp module.
	SetParams(ctx context.Context, in *MsgSetParams, opts ...grpc.CallOption) (*MsgSetParamsResponse, error)
	// Bridge relays Warden data via GMP.
	Bridge(ctx context.Context, in *MsgBridge, opts ...grpc.CallOption) (*MsgBridgeResponse, 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 MsgServer 

type MsgServer interface {
	// SetParams sets the parameters for the gmp module.
	SetParams(context.Context, *MsgSetParams) (*MsgSetParamsResponse, error)
	// Bridge relays Warden data via GMP.
	Bridge(context.Context, *MsgBridge) (*MsgBridgeResponse, error)
}

MsgServer is the server API for Msg service.

type MsgSetParams 

type MsgSetParams struct {
	// address that controls the module (defaults to x/gov).
	Authority string `protobuf:"bytes,1,opt,name=authority,proto3" json:"authority,omitempty"`
	// params defines the gmp parameters to update.
	Params *Params `protobuf:"bytes,2,opt,name=params,proto3" json:"params,omitempty"`
}

MsgSetParams defines the SetParams message type.

func (*MsgSetParams) Descriptor 

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

func (*MsgSetParams) Marshal 

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

func (*MsgSetParams) MarshalTo 

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

func (*MsgSetParams) MarshalToSizedBuffer 

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

func (*MsgSetParams) ProtoMessage 

func (*MsgSetParams) ProtoMessage()

func (*MsgSetParams) Reset 

func (m *MsgSetParams) Reset()

func (*MsgSetParams) Size 

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

func (*MsgSetParams) String 

func (m *MsgSetParams) String() string

func (MsgSetParams) Type 

func (msg MsgSetParams) Type() string

Type implements LegacyMsg interface

func (*MsgSetParams) Unmarshal 

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

func (MsgSetParams) ValidateBasic 

func (msg MsgSetParams) ValidateBasic() error

ValidateBasic Implements sdk.Msg

func (*MsgSetParams) XXX_DiscardUnknown 

func (m *MsgSetParams) XXX_DiscardUnknown()

func (*MsgSetParams) XXX_Marshal 

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

func (*MsgSetParams) XXX_Merge 

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

func (*MsgSetParams) XXX_Size 

func (m *MsgSetParams) XXX_Size() int

func (*MsgSetParams) XXX_Unmarshal 

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

type MsgSetParamsResponse 

type MsgSetParamsResponse struct {
}

MsgSetParamsResponse defines the SetParams response type.

func (*MsgSetParamsResponse) Descriptor 

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

func (*MsgSetParamsResponse) Marshal 

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

func (*MsgSetParamsResponse) MarshalTo 

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

func (*MsgSetParamsResponse) MarshalToSizedBuffer 

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

func (*MsgSetParamsResponse) ProtoMessage 

func (*MsgSetParamsResponse) ProtoMessage()

func (*MsgSetParamsResponse) Reset 

func (m *MsgSetParamsResponse) Reset()

func (*MsgSetParamsResponse) Size 

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

func (*MsgSetParamsResponse) String 

func (m *MsgSetParamsResponse) String() string

func (*MsgSetParamsResponse) Unmarshal 

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

func (*MsgSetParamsResponse) XXX_DiscardUnknown 

func (m *MsgSetParamsResponse) XXX_DiscardUnknown()

func (*MsgSetParamsResponse) XXX_Marshal 

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

func (*MsgSetParamsResponse) XXX_Merge 

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

func (*MsgSetParamsResponse) XXX_Size 

func (m *MsgSetParamsResponse) XXX_Size() int

func (*MsgSetParamsResponse) XXX_Unmarshal 

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

type Params 

type Params struct {
	// The axelar address that we'll send IBC transactions to.
	GmpAddress string `protobuf:"bytes,1,opt,name=gmp_address,json=gmpAddress,proto3" json:"gmp_address,omitempty"`
	// The channel over which we communicate with axelar.
	GmpChannel string `protobuf:"bytes,2,opt,name=gmp_channel,json=gmpChannel,proto3" json:"gmp_channel,omitempty"`
	// The amount of time we'll wait for a response from axelar before timing out.
	GmpTimeout int64 `protobuf:"varint,3,opt,name=gmp_timeout,json=gmpTimeout,proto3" json:"gmp_timeout,omitempty"`
	// The axelar address of the fee recipient.
	FeeRecipient string `protobuf:"bytes,4,opt,name=fee_recipient,json=feeRecipient,proto3" json:"fee_recipient,omitempty"`
}

Params defines the parameters for the gmp module.

func DefaultParams 

func DefaultParams() Params

func (*Params) Descriptor 

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

func (*Params) Marshal 

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

func (*Params) MarshalTo 

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

func (*Params) MarshalToSizedBuffer 

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

func (*Params) ProtoMessage 

func (*Params) ProtoMessage()

func (*Params) Reset 

func (m *Params) Reset()

func (*Params) Size 

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

func (*Params) String 

func (m *Params) String() string

func (*Params) Unmarshal 

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

func (Params) Validate 

func (p Params) Validate() error

func (*Params) XXX_DiscardUnknown 

func (m *Params) XXX_DiscardUnknown()

func (*Params) XXX_Marshal 

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

func (*Params) XXX_Merge 

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

func (*Params) XXX_Size 

func (m *Params) XXX_Size() int

func (*Params) XXX_Unmarshal 

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

type ParamsRequest 

type ParamsRequest struct {
}

ParamsRequest is the request type for the Query/Params RPC method.

func (*ParamsRequest) Descriptor 

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

func (*ParamsRequest) Marshal 

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

func (*ParamsRequest) MarshalTo 

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

func (*ParamsRequest) MarshalToSizedBuffer 

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

func (*ParamsRequest) ProtoMessage 

func (*ParamsRequest) ProtoMessage()

func (*ParamsRequest) Reset 

func (m *ParamsRequest) Reset()

func (*ParamsRequest) Size 

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

func (*ParamsRequest) String 

func (m *ParamsRequest) String() string

func (*ParamsRequest) Unmarshal 

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

func (*ParamsRequest) XXX_DiscardUnknown 

func (m *ParamsRequest) XXX_DiscardUnknown()

func (*ParamsRequest) XXX_Marshal 

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

func (*ParamsRequest) XXX_Merge 

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

func (*ParamsRequest) XXX_Size 

func (m *ParamsRequest) XXX_Size() int

func (*ParamsRequest) XXX_Unmarshal 

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

type ParamsResponse 

type ParamsResponse struct {
	// params defines the parameters of the module.
	Params Params `protobuf:"bytes,1,opt,name=params,proto3" json:"params"`
}

ParamsResponse is the response type for the Query/Params RPC method.

func (*ParamsResponse) Descriptor 

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

func (*ParamsResponse) GetParams 

func (m *ParamsResponse) GetParams() Params

func (*ParamsResponse) Marshal 

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

func (*ParamsResponse) MarshalTo 

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

func (*ParamsResponse) MarshalToSizedBuffer 

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

func (*ParamsResponse) ProtoMessage 

func (*ParamsResponse) ProtoMessage()

func (*ParamsResponse) Reset 

func (m *ParamsResponse) Reset()

func (*ParamsResponse) Size 

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

func (*ParamsResponse) String 

func (m *ParamsResponse) String() string

func (*ParamsResponse) Unmarshal 

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

func (*ParamsResponse) XXX_DiscardUnknown 

func (m *ParamsResponse) XXX_DiscardUnknown()

func (*ParamsResponse) XXX_Marshal 

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

func (*ParamsResponse) XXX_Merge 

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

func (*ParamsResponse) XXX_Size 

func (m *ParamsResponse) XXX_Size() int

func (*ParamsResponse) XXX_Unmarshal 

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

type QueryClient 

type QueryClient interface {
	// Params queries all parameters.
	Params(ctx context.Context, in *ParamsRequest, opts ...grpc.CallOption) (*ParamsResponse, 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 QueryServer 

type QueryServer interface {
	// Params queries all parameters.
	Params(context.Context, *ParamsRequest) (*ParamsResponse, 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) Bridge 

func (*UnimplementedMsgServer) Bridge(ctx context.Context, req *MsgBridge) (*MsgBridgeResponse, error)

func (*UnimplementedMsgServer) SetParams 

func (*UnimplementedMsgServer) SetParams(ctx context.Context, req *MsgSetParams) (*MsgSetParamsResponse, error)

type UnimplementedQueryServer 

type UnimplementedQueryServer struct {
}

UnimplementedQueryServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryServer) Params 

func (*UnimplementedQueryServer) Params(ctx context.Context, req *ParamsRequest) (*ParamsResponse, error)

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.