types

package
v0.5.0 Latest Latest
Warning

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

 Go to latest Published: Dec 1, 2023 License: Apache-2.0 Imports: 34 Imported by: 22

Documentation

Overview

Package types is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

View Source 
const (
	EventTypePacket     = "multi_token_packet"
	EventTypeMtTransfer = "tibc_mt_transfer"
	EventTypeClassTrace = "class_trace"

	AttributeKeyClass      = "class"
	AttributeKeyId         = "id"
	AttributeKeyData       = "data"
	AttributeKeyAmount     = "amount"
	AttributeKeyReceiver   = "receiver"
	AttributeKeyAck        = "ack"
	AttributeKeyAckSuccess = "success"
	AttributeKeyAckError   = "error"
	AttributeKeyTraceHash  = "trace_hash"
)

TIBC transfer events

View Source 
const (
	// ModuleName defines the TIBC mt_transfer name
	ModuleName = "MT"

	// RouterKey is the message route for the mt-transfer module
	RouterKey = ModuleName

	// PortID is the default port id that mt-transfer module binds to
	PortID = ModuleName

	// StoreKey is the store key string for TIBC mt-transfer
	StoreKey = ModuleName

	// QuerierRoute is the querier route for TIBC mt-transfer
	QuerierRoute = ModuleName

	// ClassPrefix is the prefix used for mt class.
	ClassPrefix = "tibc"
)
View Source 
const (
	TypeMsgMtTransfer = "tibc_mt_transfer"
)

Variables

View Source 
var (
	ModuleCdc = codec.NewProtoCodec(codectypes.NewInterfaceRegistry())
	// AminoCdc is a amino codec created to support amino json compatible msgs.
	AminoCdc = codec.NewAminoCodec(amino)
)
View Source 
var (
	ErrInvalidDenom            = sdkerrors.Register(ModuleName, 2, "invalid denom")
	ErrUnknownNFT              = sdkerrors.Register(ModuleName, 3, "unknown mt")
	ErrScChainEqualToDestChain = sdkerrors.Register(ModuleName, 4, "source chain equals to destination chain")
	ErrTraceNotFound           = sdkerrors.Register(ModuleName, 5, "class trace not found")
	ErrInvalidAmount           = sdkerrors.Register(ModuleName, 6, "the amount must be greater than 0")
)
View Source 
var (
	ErrInvalidLengthMtTransfer        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowMtTransfer          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupMtTransfer = 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 (
	// ClassTraceKey defines the key to store the class trace info in store
	ClassTraceKey = []byte{0x01}
)

Functions

func ParseHexHash 

func ParseHexHash(hexHash string) (tmbytes.HexBytes, error)

ParseHexHash parses a hex hash in string format to bytes and validates its correctness.

func RegisterInterfaces 

func RegisterInterfaces(registry codectypes.InterfaceRegistry)

RegisterInterfaces register the tibc-transfer module interfaces to protobuf Any.

func RegisterLegacyAminoCodec 

func RegisterLegacyAminoCodec(cdc *codec.LegacyAmino)

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 AccountKeeper 

type AccountKeeper interface {
	GetModuleAddress(name string) sdk.AccAddress
}

AccountKeeper defines the expected account keeper

type ClassTrace 

type ClassTrace struct {
	// path defines the chain of sourceChain/destChain
	// identifiers used for tracing the source of the Non fungible token.
	Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	// base class of the relayed non fungible token.
	BaseClass string `protobuf:"bytes,2,opt,name=base_class,json=baseClass,proto3" json:"base_class,omitempty"`
}

ClassTrace contains the base class for Multi Token and the source tracing information path.

func ParseClassTrace 

func ParseClassTrace(rawClass string) ClassTrace

ParseClassTrace parses a string with the ibc prefix (class trace) and the base class into a ClassTrace type.

Examples:

  • "mt/A/B/dog" => ClassTrace{Path: "mt/A/B", BaseClass: "dog"}
  • "dog" => ClassTrace{Path: "", BaseClass: "dog"}

func (*ClassTrace) Descriptor 

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

func (*ClassTrace) GetBaseClass 

func (m *ClassTrace) GetBaseClass() string

func (ClassTrace) GetFullClassPath 

func (ct ClassTrace) GetFullClassPath() string

GetFullClassPath returns the full class according to the ICS20 specification: tracePath + "/" + baseClass If there exists no trace then the base class is returned.

func (*ClassTrace) GetPath 

func (m *ClassTrace) GetPath() string

func (ClassTrace) GetPrefix 

func (ct ClassTrace) GetPrefix() string

GetPrefix returns the receiving class prefix composed by the trace info and a separator.

func (ClassTrace) Hash 

func (ct ClassTrace) Hash() tmbytes.HexBytes

Hash returns the hex bytes of the SHA256 hash of the ClassTrace fields using the following formula:

hash = sha256(tracePath + "/" + baseClass)

func (ClassTrace) IBCClass 

func (ct ClassTrace) IBCClass() string

IBCClass a nft class for an TICS30 fungible token in the format 'tibc-{hash(tracePath + baseClass)}'. If the trace is empty, it will return the base class.

func (*ClassTrace) Marshal 

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

func (*ClassTrace) MarshalTo 

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

func (*ClassTrace) MarshalToSizedBuffer 

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

func (*ClassTrace) ProtoMessage 

func (*ClassTrace) ProtoMessage()

func (*ClassTrace) Reset 

func (m *ClassTrace) Reset()

func (*ClassTrace) Size 

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

func (*ClassTrace) String 

func (m *ClassTrace) String() string

func (*ClassTrace) Unmarshal 

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

func (*ClassTrace) XXX_DiscardUnknown 

func (m *ClassTrace) XXX_DiscardUnknown()

func (*ClassTrace) XXX_Marshal 

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

func (*ClassTrace) XXX_Merge 

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

func (*ClassTrace) XXX_Size 

func (m *ClassTrace) XXX_Size() int

func (*ClassTrace) XXX_Unmarshal 

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

type ClientKeeper 

type ClientKeeper interface {
	GetChainName(ctx sdk.Context) string
}

ClientKeeper defines the expected client keeper

type MsgClient 

type MsgClient interface {
	// MtTransfer defines a rpc handler method for MsgMtTransfer.
	MtTransfer(ctx context.Context, in *MsgMtTransfer, opts ...grpc.CallOption) (*MsgMtTransferResponse, 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 MsgMtTransfer 

type MsgMtTransfer struct {
	// the class to which the mt to be transferred belongs
	Class string `protobuf:"bytes,1,opt,name=class,proto3" json:"class,omitempty"`
	// the mt id
	Id string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	// the mt sender
	Sender string `protobuf:"bytes,3,opt,name=sender,proto3" json:"sender,omitempty"`
	// the mt receiver
	Receiver string `protobuf:"bytes,4,opt,name=receiver,proto3" json:"receiver,omitempty"`
	// target chain of transmission
	DestChain string `protobuf:"bytes,5,opt,name=dest_chain,json=destChain,proto3" json:"dest_chain,omitempty"`
	// relay chain during transmission
	RealayChain string `protobuf:"bytes,6,opt,name=realay_chain,json=realayChain,proto3" json:"realay_chain,omitempty"`
	// the destination contract address to receive the nft
	DestContract string `protobuf:"bytes,7,opt,name=dest_contract,json=destContract,proto3" json:"dest_contract,omitempty"`
	// the amount defined by MT outside the chain
	Amount uint64 `protobuf:"varint,8,opt,name=amount,proto3" json:"amount,omitempty"`
}

func NewMsgMtTransfer 

func NewMsgMtTransfer(class, id, sender, receiver, destChain, realayChain, destContract string, amount uint64) *MsgMtTransfer

NewMsgMtTransfer creates a new NewMsgMtTransfer instance

func (*MsgMtTransfer) Descriptor 

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

func (MsgMtTransfer) GetSigners 

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

GetSigners implements sdk.Msg

func (*MsgMtTransfer) Marshal 

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

func (*MsgMtTransfer) MarshalTo 

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

func (*MsgMtTransfer) MarshalToSizedBuffer 

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

func (*MsgMtTransfer) ProtoMessage 

func (*MsgMtTransfer) ProtoMessage()

func (*MsgMtTransfer) Reset 

func (m *MsgMtTransfer) Reset()

func (*MsgMtTransfer) Size 

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

func (*MsgMtTransfer) String 

func (m *MsgMtTransfer) String() string

func (*MsgMtTransfer) Unmarshal 

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

func (MsgMtTransfer) ValidateBasic 

func (msg MsgMtTransfer) ValidateBasic() error

ValidateBasic Implements Msg.

func (*MsgMtTransfer) XXX_DiscardUnknown 

func (m *MsgMtTransfer) XXX_DiscardUnknown()

func (*MsgMtTransfer) XXX_Marshal 

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

func (*MsgMtTransfer) XXX_Merge 

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

func (*MsgMtTransfer) XXX_Size 

func (m *MsgMtTransfer) XXX_Size() int

func (*MsgMtTransfer) XXX_Unmarshal 

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

type MsgMtTransferResponse 

type MsgMtTransferResponse struct {
}

MsgMtTransferResponse defines the Msg/MtTransfer response type.

func (*MsgMtTransferResponse) Descriptor 

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

func (*MsgMtTransferResponse) Marshal 

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

func (*MsgMtTransferResponse) MarshalTo 

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

func (*MsgMtTransferResponse) MarshalToSizedBuffer 

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

func (*MsgMtTransferResponse) ProtoMessage 

func (*MsgMtTransferResponse) ProtoMessage()

func (*MsgMtTransferResponse) Reset 

func (m *MsgMtTransferResponse) Reset()

func (*MsgMtTransferResponse) Size 

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

func (*MsgMtTransferResponse) String 

func (m *MsgMtTransferResponse) String() string

func (*MsgMtTransferResponse) Unmarshal 

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

func (*MsgMtTransferResponse) XXX_DiscardUnknown 

func (m *MsgMtTransferResponse) XXX_DiscardUnknown()

func (*MsgMtTransferResponse) XXX_Marshal 

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

func (*MsgMtTransferResponse) XXX_Merge 

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

func (*MsgMtTransferResponse) XXX_Size 

func (m *MsgMtTransferResponse) XXX_Size() int

func (*MsgMtTransferResponse) XXX_Unmarshal 

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

type MsgServer 

type MsgServer interface {
	// MtTransfer defines a rpc handler method for MsgMtTransfer.
	MtTransfer(context.Context, *MsgMtTransfer) (*MsgMtTransferResponse, error)
}

MsgServer is the server API for Msg service.

type MtKeeper 

type MtKeeper interface {
	IssueDenom(ctx sdk.Context,
		id, name string, sender sdk.AccAddress, data []byte,
	) types.Denom

	IssueMT(ctx sdk.Context,
		denomID string, mtID string,
		amount uint64,
		data []byte,
		recipient sdk.AccAddress,
	) (types.MT, error)

	MintMT(ctx sdk.Context,
		denomID, mtID string,
		amount uint64,
		recipient sdk.AccAddress,
	) error

	TransferOwner(ctx sdk.Context,
		denomID, mtID string,
		amount uint64,
		srcOwner, dstOwner sdk.AccAddress,
	) error

	BurnMT(ctx sdk.Context,
		denomID, mtID string,
		amount uint64,
		owner sdk.AccAddress) error

	HasMT(ctx sdk.Context, denomID, mtID string) bool
	GetMT(ctx sdk.Context, denomID, mtID string) (mt mtexported.MT, err error)
	GetDenom(ctx sdk.Context, id string) (denom types.Denom, found bool)
}

MtKeeper defines the expected mt keeper

type MultiTokenPacketData 

type MultiTokenPacketData struct {
	// the class to which the Mt to be transferred belongs
	Class string `protobuf:"bytes,1,opt,name=class,proto3" json:"class,omitempty"`
	// the mt id
	Id string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	// the address defined by MT outside the chain
	Data []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	// the mt sender
	Sender string `protobuf:"bytes,4,opt,name=sender,proto3" json:"sender,omitempty"`
	// the mt receiver
	Receiver string `protobuf:"bytes,5,opt,name=receiver,proto3" json:"receiver,omitempty"`
	// identify whether it is far away from the source chain
	AwayFromOrigin bool `protobuf:"varint,6,opt,name=away_from_origin,json=awayFromOrigin,proto3" json:"away_from_origin,omitempty"`
	// the destination contract address to receive the nft
	DestContract string `protobuf:"bytes,7,opt,name=dest_contract,json=destContract,proto3" json:"dest_contract,omitempty"`
	// the amount defined by MT outside the chain
	Amount uint64 `protobuf:"varint,8,opt,name=amount,proto3" json:"amount,omitempty"`
}

func NewMultiTokenPacketData 

func NewMultiTokenPacketData(
	class, id, sender, receiver string,
	awayFromOrigin bool, destContract string,
	amount uint64, data []byte,
) MultiTokenPacketData

NewMultiTokenPacketData contructs a new MultiTokenPacketData instance

func (*MultiTokenPacketData) Descriptor 

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

func (*MultiTokenPacketData) GetAmount 

func (m *MultiTokenPacketData) GetAmount() uint64

func (*MultiTokenPacketData) GetAwayFromOrigin 

func (m *MultiTokenPacketData) GetAwayFromOrigin() bool

func (MultiTokenPacketData) GetBytes 

func (mtpd MultiTokenPacketData) GetBytes() []byte

GetBytes is a helper for serialising

func (*MultiTokenPacketData) GetClass 

func (m *MultiTokenPacketData) GetClass() string

func (*MultiTokenPacketData) GetData 

func (m *MultiTokenPacketData) GetData() []byte

func (*MultiTokenPacketData) GetDestContract 

func (m *MultiTokenPacketData) GetDestContract() string

func (*MultiTokenPacketData) GetId 

func (m *MultiTokenPacketData) GetId() string

func (*MultiTokenPacketData) GetReceiver 

func (m *MultiTokenPacketData) GetReceiver() string

func (*MultiTokenPacketData) GetSender 

func (m *MultiTokenPacketData) GetSender() string

func (*MultiTokenPacketData) Marshal 

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

func (*MultiTokenPacketData) MarshalTo 

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

func (*MultiTokenPacketData) MarshalToSizedBuffer 

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

func (*MultiTokenPacketData) ProtoMessage 

func (*MultiTokenPacketData) ProtoMessage()

func (*MultiTokenPacketData) Reset 

func (m *MultiTokenPacketData) Reset()

func (*MultiTokenPacketData) Size 

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

func (*MultiTokenPacketData) String 

func (m *MultiTokenPacketData) String() string

func (*MultiTokenPacketData) Unmarshal 

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

func (MultiTokenPacketData) ValidateBasic 

func (mtpd MultiTokenPacketData) ValidateBasic() error

ValidateBasic is used for validating the mt transfer. NOTE: The addresses formats are not validated as the sender and recipient can have different formats defined by their corresponding chains that are not known to TIBC.

func (*MultiTokenPacketData) XXX_DiscardUnknown 

func (m *MultiTokenPacketData) XXX_DiscardUnknown()

func (*MultiTokenPacketData) XXX_Marshal 

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

func (*MultiTokenPacketData) XXX_Merge 

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

func (*MultiTokenPacketData) XXX_Size 

func (m *MultiTokenPacketData) XXX_Size() int

func (*MultiTokenPacketData) XXX_Unmarshal 

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

type PacketKeeper 

type PacketKeeper interface {
	GetNextSequenceSend(ctx sdk.Context, sourceChain, destChain string) uint64
	SendPacket(ctx sdk.Context, packet exported.PacketI) error
}

PacketKeeper defines the expected packet keeper

type QueryClassTraceRequest 

type QueryClassTraceRequest struct {
	// hash (in hex format) of the class trace information.
	Hash string `protobuf:"bytes,1,opt,name=hash,proto3" json:"hash,omitempty"`
}

QueryClassTraceRequest is the request type for the Query/ClassTrace RPC method

func (*QueryClassTraceRequest) Descriptor 

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

func (*QueryClassTraceRequest) GetHash 

func (m *QueryClassTraceRequest) GetHash() string

func (*QueryClassTraceRequest) Marshal 

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

func (*QueryClassTraceRequest) MarshalTo 

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

func (*QueryClassTraceRequest) MarshalToSizedBuffer 

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

func (*QueryClassTraceRequest) ProtoMessage 

func (*QueryClassTraceRequest) ProtoMessage()

func (*QueryClassTraceRequest) Reset 

func (m *QueryClassTraceRequest) Reset()

func (*QueryClassTraceRequest) Size 

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

func (*QueryClassTraceRequest) String 

func (m *QueryClassTraceRequest) String() string

func (*QueryClassTraceRequest) Unmarshal 

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

func (*QueryClassTraceRequest) XXX_DiscardUnknown 

func (m *QueryClassTraceRequest) XXX_DiscardUnknown()

func (*QueryClassTraceRequest) XXX_Marshal 

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

func (*QueryClassTraceRequest) XXX_Merge 

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

func (*QueryClassTraceRequest) XXX_Size 

func (m *QueryClassTraceRequest) XXX_Size() int

func (*QueryClassTraceRequest) XXX_Unmarshal 

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

type QueryClassTraceResponse 

type QueryClassTraceResponse struct {
	// class_trace returns the requested class trace information.
	ClassTrace *ClassTrace `protobuf:"bytes,1,opt,name=class_trace,json=classTrace,proto3" json:"class_trace,omitempty"`
}

QueryClassTraceResponse is the response type for the Query/ClassTrace RPC method.

func (*QueryClassTraceResponse) Descriptor 

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

func (*QueryClassTraceResponse) GetClassTrace 

func (m *QueryClassTraceResponse) GetClassTrace() *ClassTrace

func (*QueryClassTraceResponse) Marshal 

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

func (*QueryClassTraceResponse) MarshalTo 

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

func (*QueryClassTraceResponse) MarshalToSizedBuffer 

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

func (*QueryClassTraceResponse) ProtoMessage 

func (*QueryClassTraceResponse) ProtoMessage()

func (*QueryClassTraceResponse) Reset 

func (m *QueryClassTraceResponse) Reset()

func (*QueryClassTraceResponse) Size 

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

func (*QueryClassTraceResponse) String 

func (m *QueryClassTraceResponse) String() string

func (*QueryClassTraceResponse) Unmarshal 

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

func (*QueryClassTraceResponse) XXX_DiscardUnknown 

func (m *QueryClassTraceResponse) XXX_DiscardUnknown()

func (*QueryClassTraceResponse) XXX_Marshal 

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

func (*QueryClassTraceResponse) XXX_Merge 

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

func (*QueryClassTraceResponse) XXX_Size 

func (m *QueryClassTraceResponse) XXX_Size() int

func (*QueryClassTraceResponse) XXX_Unmarshal 

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

type QueryClassTracesRequest 

type QueryClassTracesRequest struct {
	// pagination defines an optional pagination for the request.
	Pagination *query.PageRequest `protobuf:"bytes,1,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryConnectionsRequest is the request type for the Query/ClassTraces RPC method

func (*QueryClassTracesRequest) Descriptor 

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

func (*QueryClassTracesRequest) GetPagination 

func (m *QueryClassTracesRequest) GetPagination() *query.PageRequest

func (*QueryClassTracesRequest) Marshal 

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

func (*QueryClassTracesRequest) MarshalTo 

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

func (*QueryClassTracesRequest) MarshalToSizedBuffer 

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

func (*QueryClassTracesRequest) ProtoMessage 

func (*QueryClassTracesRequest) ProtoMessage()

func (*QueryClassTracesRequest) Reset 

func (m *QueryClassTracesRequest) Reset()

func (*QueryClassTracesRequest) Size 

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

func (*QueryClassTracesRequest) String 

func (m *QueryClassTracesRequest) String() string

func (*QueryClassTracesRequest) Unmarshal 

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

func (*QueryClassTracesRequest) XXX_DiscardUnknown 

func (m *QueryClassTracesRequest) XXX_DiscardUnknown()

func (*QueryClassTracesRequest) XXX_Marshal 

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

func (*QueryClassTracesRequest) XXX_Merge 

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

func (*QueryClassTracesRequest) XXX_Size 

func (m *QueryClassTracesRequest) XXX_Size() int

func (*QueryClassTracesRequest) XXX_Unmarshal 

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

type QueryClassTracesResponse 

type QueryClassTracesResponse struct {
	// class_traces returns all class trace information.
	ClassTraces Traces `protobuf:"bytes,1,rep,name=class_traces,json=classTraces,proto3,castrepeated=Traces" json:"class_traces"`
	// pagination defines the pagination in the response.
	Pagination *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryConnectionsResponse is the response type for the Query/ClassTraces RPC method.

func (*QueryClassTracesResponse) Descriptor 

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

func (*QueryClassTracesResponse) GetClassTraces 

func (m *QueryClassTracesResponse) GetClassTraces() Traces

func (*QueryClassTracesResponse) GetPagination 

func (m *QueryClassTracesResponse) GetPagination() *query.PageResponse

func (*QueryClassTracesResponse) Marshal 

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

func (*QueryClassTracesResponse) MarshalTo 

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

func (*QueryClassTracesResponse) MarshalToSizedBuffer 

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

func (*QueryClassTracesResponse) ProtoMessage 

func (*QueryClassTracesResponse) ProtoMessage()

func (*QueryClassTracesResponse) Reset 

func (m *QueryClassTracesResponse) Reset()

func (*QueryClassTracesResponse) Size 

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

func (*QueryClassTracesResponse) String 

func (m *QueryClassTracesResponse) String() string

func (*QueryClassTracesResponse) Unmarshal 

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

func (*QueryClassTracesResponse) XXX_DiscardUnknown 

func (m *QueryClassTracesResponse) XXX_DiscardUnknown()

func (*QueryClassTracesResponse) XXX_Marshal 

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

func (*QueryClassTracesResponse) XXX_Merge 

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

func (*QueryClassTracesResponse) XXX_Size 

func (m *QueryClassTracesResponse) XXX_Size() int

func (*QueryClassTracesResponse) XXX_Unmarshal 

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

type QueryClient 

type QueryClient interface {
	// ClassTrace queries a class trace information.
	ClassTrace(ctx context.Context, in *QueryClassTraceRequest, opts ...grpc.CallOption) (*QueryClassTraceResponse, error)
	// ClassTraces queries all class traces.
	ClassTraces(ctx context.Context, in *QueryClassTracesRequest, opts ...grpc.CallOption) (*QueryClassTracesResponse, 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 {
	// ClassTrace queries a class trace information.
	ClassTrace(context.Context, *QueryClassTraceRequest) (*QueryClassTraceResponse, error)
	// ClassTraces queries all class traces.
	ClassTraces(context.Context, *QueryClassTracesRequest) (*QueryClassTracesResponse, error)
}

QueryServer is the server API for Query service.

type Traces 

type Traces []ClassTrace

Traces defines a wrapper type for a slice of ClassTrace.

func (Traces) Len 

func (t Traces) Len() int

Len implements sort.Interface for Traces

func (Traces) Less 

func (t Traces) Less(i, j int) bool

Less implements sort.Interface for Traces

func (Traces) Sort 

func (t Traces) Sort() Traces

Sort is a helper function to sort the set of class traces in-place

func (Traces) Swap 

func (t Traces) Swap(i, j int)

Swap implements sort.Interface for Traces

type UnimplementedMsgServer 

type UnimplementedMsgServer struct {
}

UnimplementedMsgServer can be embedded to have forward compatible implementations.

func (*UnimplementedMsgServer) MtTransfer 

func (*UnimplementedMsgServer) MtTransfer(ctx context.Context, req *MsgMtTransfer) (*MsgMtTransferResponse, error)

type UnimplementedQueryServer 

type UnimplementedQueryServer struct {
}

UnimplementedQueryServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryServer) ClassTrace 

func (*UnimplementedQueryServer) ClassTrace(ctx context.Context, req *QueryClassTraceRequest) (*QueryClassTraceResponse, error)

func (*UnimplementedQueryServer) ClassTraces 

func (*UnimplementedQueryServer) ClassTraces(ctx context.Context, req *QueryClassTracesRequest) (*QueryClassTracesResponse, 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.