types

package
v1.3.1 Latest Latest
Warning

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

 Go to latest Published: Feb 9, 2021 License: Apache-2.0 Imports: 29 Imported by: 36

Documentation

Overview

nolint

Package types is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

View Source 
const (
	EventTypeCreateHTLC  = "create_htlc"
	EventTypeClaimHTLC   = "claim_htlc"
	EventTypeRefundHTLC  = "refund_htlc"
	EventTypeHTLCExpired = "htlc_expired"

	AttributeValueCategory = ModuleName

	AttributeKeySender               = "sender"
	AttributeKeyReceiver             = "receiver"
	AttributeKeyReceiverOnOtherChain = "receiver_on_other_chain"
	AttributeKeyAmount               = "amount"
	AttributeKeyHashLock             = "hash_lock"
	AttributeKeyTimeLock             = "time_lock"
	AttributeKeySecret               = "secret"
)

HTLC module event types and attributes

View Source 
const (
	// ModuleName is the name of the HTLC module
	ModuleName = "htlc"

	// StoreKey is the string store representation
	StoreKey string = ModuleName

	// QuerierRoute is the querier route for the HTLC module
	QuerierRoute string = ModuleName

	// RouterKey is the msg router key for the HTLC module
	RouterKey string = ModuleName
)
View Source 
const (
	// TypeMsgCreateHTLC is the type for MsgCreateHTLC
	TypeMsgCreateHTLC = "create_htlc"

	// TypeMsgClaimHTLC is the type for MsgClaimHTLC
	TypeMsgClaimHTLC = "claim_htlc"

	// TypeMsgRefundHTLC is the type for MsgRefundHTLC
	TypeMsgRefundHTLC = "refund_htlc"
)
View Source 
const (
	// SecretLength is the length for the secret in hex string
	SecretLength = 64
	// HashLockLength is the length for the hash lock in hex string
	HashLockLength = 64
	// MaxLengthForAddressOnOtherChain is the maximum length for the address on other chains
	MaxLengthForAddressOnOtherChain = 128
	// MinTimeLock is the minimum time span for HTLC in blocks
	MinTimeLock = 50
	// MaxTimeLock is the maximum time span for HTLC in blocks
	MaxTimeLock = 25480
)
View Source 
const (
	QueryHTLC = "htlc" // query an HTLC
)

Variables

View Source 
var (
	ErrInvalidHashLock = sdkerrors.Register(ModuleName, 2, "invalid hash lock")
	ErrInvalidTimeLock = sdkerrors.Register(ModuleName, 3, "invalid time lock")
	ErrInvalidSecret   = sdkerrors.Register(ModuleName, 4, "invalid secret")
	ErrHTLCExists      = sdkerrors.Register(ModuleName, 5, "htlc already exists")
	ErrUnknownHTLC     = sdkerrors.Register(ModuleName, 6, "unknown htlc")
	ErrHTLCNotOpen     = sdkerrors.Register(ModuleName, 7, "htlc not open")
	ErrHTLCNotExpired  = sdkerrors.Register(ModuleName, 8, "htlc not expired")
)

HTLC module sentinel errors

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 (
	ErrInvalidLengthHtlc        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowHtlc          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupHtlc = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	// Keys for store prefixes
	HTLCKey             = []byte{0x01} // prefix for HTLC
	HTLCExpiredQueueKey = []byte{0x02} // prefix for the HTLC expiration queue
)
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 HTLCState_name = map[int32]string{
	0: "HTLC_STATE_OPEN",
	1: "HTLC_STATE_COMPLETED",
	2: "HTLC_STATE_EXPIRED",
	3: "HTLC_STATE_REFUNDED",
}
View Source 
var HTLCState_value = map[string]int32{
	"HTLC_STATE_OPEN":      0,
	"HTLC_STATE_COMPLETED": 1,
	"HTLC_STATE_EXPIRED":   2,
	"HTLC_STATE_REFUNDED":  3,
}
View Source 
var (
	ModuleCdc = codec.NewAminoCodec(amino)
)

ModuleCdc defines the module codec

Functions

func GetHTLCExpiredQueueKey 

func GetHTLCExpiredQueueKey(expirationHeight uint64, hashLock []byte) []byte

GetHTLCExpiredQueueKey returns the key for the HTLC expiration queue by the specified height and hash lock VALUE: []byte{}

func GetHTLCExpiredQueueSubspace 

func GetHTLCExpiredQueueSubspace(expirationHeight uint64) []byte

GetHTLCExpiredQueueSubspace returns the key prefix for the HTLC expiration queue by the given height

func GetHTLCKey 

func GetHTLCKey(hashLock []byte) []byte

GetHTLCKey returns the key for the HTLC with the specified hash lock VALUE: htlc/HTLC

func GetHashLock 

func GetHashLock(secret tmbytes.HexBytes, timestamp uint64) []byte

GetHashLock calculates the hash lock from the given secret and timestamp

func RegisterInterfaces 

func RegisterInterfaces(registry types.InterfaceRegistry)

func RegisterLegacyAminoCodec 

func RegisterLegacyAminoCodec(cdc *codec.LegacyAmino)

func RegisterMsgServer added in v1.2.0 

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 (such as grpc.SendHeader, etc) to stop working. Consider using RegisterQueryHandlerFromEndpoint instead.

func RegisterQueryServer 

func RegisterQueryServer(s grpc1.Server, srv QueryServer)

func ValidateAmount added in v1.2.1 

func ValidateAmount(amount sdk.Coins) error

ValidateAmount verifies whether the given amount is legal

func ValidateGenesis 

func ValidateGenesis(data GenesisState) error

ValidateGenesis validates the provided HTLC genesis state to ensure the expected invariants holds.

func ValidateHashLock added in v1.2.1 

func ValidateHashLock(hashLock string) error

ValidateHashLock verifies whether the given hash lock is legal

func ValidateReceiverOnOtherChain added in v1.2.1 

func ValidateReceiverOnOtherChain(receiverOnOtherChain string) error

ValidateReceiverOnOtherChain verifies if the receiver on the other chain is legal

func ValidateSecret added in v1.2.1 

func ValidateSecret(secret string) error

ValidateSecret verifies whether the given secret is legal

func ValidateTimeLock added in v1.2.1 

func ValidateTimeLock(timeLock uint64) error

ValidateTimeLock verifies whether the given time lock is legal

Types

type AccountKeeper 

type AccountKeeper interface {
	GetAccount(ctx sdk.Context, addr sdk.AccAddress) authtypes.AccountI
	GetModuleAddress(name string) sdk.AccAddress
	GetModuleAccount(ctx sdk.Context, name string) authtypes.ModuleAccountI
}

AccountKeeper defines the expected account keeper (noalias)

type BankKeeper 

type BankKeeper interface {
	MintCoins(ctx sdk.Context, moduleName string, amt sdk.Coins) error
	BurnCoins(ctx sdk.Context, moduleName string, amt sdk.Coins) error

	GetSupply(ctx sdk.Context) (supply bank.SupplyI)
	GetBalance(ctx sdk.Context, addr sdk.AccAddress, denom string) sdk.Coin

	SendCoinsFromModuleToAccount(ctx sdk.Context, senderModule string, recipientAddr sdk.AccAddress, amt sdk.Coins) error
	SendCoinsFromAccountToModule(ctx sdk.Context, senderAddr sdk.AccAddress, recipientModule string, amt sdk.Coins) error
	SendCoinsFromModuleToModule(ctx sdk.Context, senderModule, recipientModule string, amt sdk.Coins) error

	SpendableCoins(ctx sdk.Context, addr sdk.AccAddress) sdk.Coins
}

BankKeeper defines the expected bank keeper (noalias)

type GenesisState 

type GenesisState struct {
	PendingHtlcs map[string]HTLC `` /* 175-byte string literal not displayed */
}

GenesisState defines the HTLC module's genesis state

func DefaultGenesisState 

func DefaultGenesisState() *GenesisState

DefaultGenesisState gets the raw genesis message for testing

func NewGenesisState 

func NewGenesisState(pendingHtlcs map[string]HTLC) GenesisState

NewGenesisState constructs a new GenesisState instance

func (*GenesisState) Descriptor 

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

func (*GenesisState) GetPendingHtlcs 

func (m *GenesisState) GetPendingHtlcs() map[string]HTLC

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 HTLC 

type HTLC struct {
	Sender               string                                   `protobuf:"bytes,1,opt,name=sender,proto3" json:"sender,omitempty"`
	To                   string                                   `protobuf:"bytes,2,opt,name=to,proto3" json:"to,omitempty"`
	ReceiverOnOtherChain string                                   `` /* 156-byte string literal not displayed */
	Amount               github_com_cosmos_cosmos_sdk_types.Coins `protobuf:"bytes,4,rep,name=amount,proto3,castrepeated=github.com/cosmos/cosmos-sdk/types.Coins" json:"amount"`
	Secret               string                                   `protobuf:"bytes,5,opt,name=secret,proto3" json:"secret,omitempty"`
	Timestamp            uint64                                   `protobuf:"varint,6,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	ExpirationHeight     uint64                                   `` /* 135-byte string literal not displayed */
	State                HTLCState                                `protobuf:"varint,8,opt,name=state,proto3,enum=irismod.htlc.HTLCState" json:"state,omitempty"`
}

HTLC defines the struct of an HTLC

func NewHTLC 

func NewHTLC(
	sender sdk.AccAddress,
	to sdk.AccAddress,
	receiverOnOtherChain string,
	amount sdk.Coins,
	secret tmbytes.HexBytes,
	timestamp uint64,
	expirationHeight uint64,
	state HTLCState,
) HTLC

NewHTLC constructs a new HTLC instance

func (*HTLC) Descriptor 

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

func (*HTLC) Equal 

func (this *HTLC) Equal(that interface{}) bool

func (*HTLC) Marshal 

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

func (*HTLC) MarshalTo 

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

func (*HTLC) MarshalToSizedBuffer 

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

func (*HTLC) ProtoMessage 

func (*HTLC) ProtoMessage()

func (*HTLC) Reset 

func (m *HTLC) Reset()

func (*HTLC) Size 

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

func (*HTLC) String 

func (m *HTLC) String() string

func (*HTLC) Unmarshal 

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

func (HTLC) Validate 

func (h HTLC) Validate() error

Validate validates the HTLC

func (*HTLC) XXX_DiscardUnknown 

func (m *HTLC) XXX_DiscardUnknown()

func (*HTLC) XXX_Marshal 

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

func (*HTLC) XXX_Merge 

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

func (*HTLC) XXX_Size 

func (m *HTLC) XXX_Size() int

func (*HTLC) XXX_Unmarshal 

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

type HTLCState 

type HTLCState int32

HTLCState defines the state of an HTLC 

const (
	// HTLC_STATE_OPEN defines an open state.
	Open HTLCState = 0
	// HTLC_STATE_COMPLETED defines a completed state.
	Completed HTLCState = 1
	// HTLC_STATE_EXPIRED defines an expired state.
	Expired HTLCState = 2
	// HTLC_STATE_REFUNDED defines a refunded state.
	Refunded HTLCState = 3
)

func (HTLCState) EnumDescriptor 

func (HTLCState) EnumDescriptor() ([]byte, []int)

func (HTLCState) String 

func (x HTLCState) String() string

type MsgClaimHTLC 

type MsgClaimHTLC struct {
	Sender   string `protobuf:"bytes,1,opt,name=sender,proto3" json:"sender,omitempty"`
	HashLock string `protobuf:"bytes,2,opt,name=hash_lock,json=hashLock,proto3" json:"hash_lock,omitempty" yaml:"hash_lock"`
	Secret   string `protobuf:"bytes,3,opt,name=secret,proto3" json:"secret,omitempty"`
}

MsgClaimHTLC defines a message to claim an HTLC

func NewMsgClaimHTLC 

func NewMsgClaimHTLC(
	sender string,
	hashLock string,
	secret string,
) MsgClaimHTLC

NewMsgClaimHTLC constructs a new MsgClaimHTLC instance

func (*MsgClaimHTLC) Descriptor 

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

func (*MsgClaimHTLC) Equal 

func (this *MsgClaimHTLC) Equal(that interface{}) bool

func (MsgClaimHTLC) GetSignBytes 

func (msg MsgClaimHTLC) GetSignBytes() []byte

GetSignBytes implements Msg

func (MsgClaimHTLC) GetSigners 

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

GetSigners implements Msg

func (*MsgClaimHTLC) Marshal 

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

func (*MsgClaimHTLC) MarshalTo 

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

func (*MsgClaimHTLC) MarshalToSizedBuffer 

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

func (*MsgClaimHTLC) ProtoMessage 

func (*MsgClaimHTLC) ProtoMessage()

func (*MsgClaimHTLC) Reset 

func (m *MsgClaimHTLC) Reset()

func (MsgClaimHTLC) Route 

func (msg MsgClaimHTLC) Route() string

Route implements Msg

func (*MsgClaimHTLC) Size 

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

func (*MsgClaimHTLC) String 

func (m *MsgClaimHTLC) String() string

func (MsgClaimHTLC) Type 

func (msg MsgClaimHTLC) Type() string

Type implements Msg

func (*MsgClaimHTLC) Unmarshal 

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

func (MsgClaimHTLC) ValidateBasic 

func (msg MsgClaimHTLC) ValidateBasic() error

ValidateBasic implements Msg.

func (*MsgClaimHTLC) XXX_DiscardUnknown 

func (m *MsgClaimHTLC) XXX_DiscardUnknown()

func (*MsgClaimHTLC) XXX_Marshal 

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

func (*MsgClaimHTLC) XXX_Merge 

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

func (*MsgClaimHTLC) XXX_Size 

func (m *MsgClaimHTLC) XXX_Size() int

func (*MsgClaimHTLC) XXX_Unmarshal 

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

type MsgClaimHTLCResponse added in v1.2.0 

type MsgClaimHTLCResponse struct {
}

MsgClaimHTLCResponse defines the Msg/ClaimHTLC response type

func (*MsgClaimHTLCResponse) Descriptor added in v1.2.0 

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

func (*MsgClaimHTLCResponse) Marshal added in v1.2.0 

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

func (*MsgClaimHTLCResponse) MarshalTo added in v1.2.0 

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

func (*MsgClaimHTLCResponse) MarshalToSizedBuffer added in v1.2.0 

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

func (*MsgClaimHTLCResponse) ProtoMessage added in v1.2.0 

func (*MsgClaimHTLCResponse) ProtoMessage()

func (*MsgClaimHTLCResponse) Reset added in v1.2.0 

func (m *MsgClaimHTLCResponse) Reset()

func (*MsgClaimHTLCResponse) Size added in v1.2.0 

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

func (*MsgClaimHTLCResponse) String added in v1.2.0 

func (m *MsgClaimHTLCResponse) String() string

func (*MsgClaimHTLCResponse) Unmarshal added in v1.2.0 

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

func (*MsgClaimHTLCResponse) XXX_DiscardUnknown added in v1.2.0 

func (m *MsgClaimHTLCResponse) XXX_DiscardUnknown()

func (*MsgClaimHTLCResponse) XXX_Marshal added in v1.2.0 

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

func (*MsgClaimHTLCResponse) XXX_Merge added in v1.2.0 

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

func (*MsgClaimHTLCResponse) XXX_Size added in v1.2.0 

func (m *MsgClaimHTLCResponse) XXX_Size() int

func (*MsgClaimHTLCResponse) XXX_Unmarshal added in v1.2.0 

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

type MsgClient added in v1.2.0 

type MsgClient interface {
	// CreateHTLC defines a method for creating a HTLC.
	CreateHTLC(ctx context.Context, in *MsgCreateHTLC, opts ...grpc.CallOption) (*MsgCreateHTLCResponse, error)
	// ClaimHTLC defines a method for claiming a HTLC
	ClaimHTLC(ctx context.Context, in *MsgClaimHTLC, opts ...grpc.CallOption) (*MsgClaimHTLCResponse, error)
	// RefundHTLC defines a method for refunding a HTLC.
	RefundHTLC(ctx context.Context, in *MsgRefundHTLC, opts ...grpc.CallOption) (*MsgRefundHTLCResponse, 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 added in v1.2.0 

func NewMsgClient(cc grpc1.ClientConn) MsgClient

type MsgCreateHTLC 

type MsgCreateHTLC struct {
	Sender               string                                   `protobuf:"bytes,1,opt,name=sender,proto3" json:"sender,omitempty"`
	To                   string                                   `protobuf:"bytes,2,opt,name=to,proto3" json:"to,omitempty"`
	ReceiverOnOtherChain string                                   `` /* 156-byte string literal not displayed */
	Amount               github_com_cosmos_cosmos_sdk_types.Coins `protobuf:"bytes,4,rep,name=amount,proto3,castrepeated=github.com/cosmos/cosmos-sdk/types.Coins" json:"amount"`
	HashLock             string                                   `protobuf:"bytes,5,opt,name=hash_lock,json=hashLock,proto3" json:"hash_lock,omitempty" yaml:"hash_lock"`
	Timestamp            uint64                                   `protobuf:"varint,6,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	TimeLock             uint64                                   `protobuf:"varint,7,opt,name=time_lock,json=timeLock,proto3" json:"time_lock,omitempty" yaml:"time_lock"`
}

MsgCreateHTLC defines a message to create an HTLC

func NewMsgCreateHTLC 

func NewMsgCreateHTLC(
	sender string,
	to string,
	receiverOnOtherChain string,
	amount sdk.Coins,
	hashLock string,
	timestamp uint64,
	timeLock uint64,
) MsgCreateHTLC

NewMsgCreateHTLC creates a new MsgCreateHTLC instance

func (*MsgCreateHTLC) Descriptor 

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

func (*MsgCreateHTLC) Equal 

func (this *MsgCreateHTLC) Equal(that interface{}) bool

func (MsgCreateHTLC) GetSignBytes 

func (msg MsgCreateHTLC) GetSignBytes() []byte

GetSignBytes implements Msg

func (MsgCreateHTLC) GetSigners 

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

GetSigners implements Msg

func (*MsgCreateHTLC) Marshal 

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

func (*MsgCreateHTLC) MarshalTo 

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

func (*MsgCreateHTLC) MarshalToSizedBuffer 

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

func (*MsgCreateHTLC) ProtoMessage 

func (*MsgCreateHTLC) ProtoMessage()

func (*MsgCreateHTLC) Reset 

func (m *MsgCreateHTLC) Reset()

func (MsgCreateHTLC) Route 

func (msg MsgCreateHTLC) Route() string

Route implements Msg

func (*MsgCreateHTLC) Size 

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

func (*MsgCreateHTLC) String 

func (m *MsgCreateHTLC) String() string

func (MsgCreateHTLC) Type 

func (msg MsgCreateHTLC) Type() string

Type implements Msg

func (*MsgCreateHTLC) Unmarshal 

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

func (MsgCreateHTLC) ValidateBasic 

func (msg MsgCreateHTLC) ValidateBasic() error

ValidateBasic implements Msg

func (*MsgCreateHTLC) XXX_DiscardUnknown 

func (m *MsgCreateHTLC) XXX_DiscardUnknown()

func (*MsgCreateHTLC) XXX_Marshal 

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

func (*MsgCreateHTLC) XXX_Merge 

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

func (*MsgCreateHTLC) XXX_Size 

func (m *MsgCreateHTLC) XXX_Size() int

func (*MsgCreateHTLC) XXX_Unmarshal 

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

type MsgCreateHTLCResponse added in v1.2.0 

type MsgCreateHTLCResponse struct {
}

MsgCreateHTLCResponse defines the Msg/CreateHTLC response type

func (*MsgCreateHTLCResponse) Descriptor added in v1.2.0 

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

func (*MsgCreateHTLCResponse) Marshal added in v1.2.0 

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

func (*MsgCreateHTLCResponse) MarshalTo added in v1.2.0 

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

func (*MsgCreateHTLCResponse) MarshalToSizedBuffer added in v1.2.0 

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

func (*MsgCreateHTLCResponse) ProtoMessage added in v1.2.0 

func (*MsgCreateHTLCResponse) ProtoMessage()

func (*MsgCreateHTLCResponse) Reset added in v1.2.0 

func (m *MsgCreateHTLCResponse) Reset()

func (*MsgCreateHTLCResponse) Size added in v1.2.0 

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

func (*MsgCreateHTLCResponse) String added in v1.2.0 

func (m *MsgCreateHTLCResponse) String() string

func (*MsgCreateHTLCResponse) Unmarshal added in v1.2.0 

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

func (*MsgCreateHTLCResponse) XXX_DiscardUnknown added in v1.2.0 

func (m *MsgCreateHTLCResponse) XXX_DiscardUnknown()

func (*MsgCreateHTLCResponse) XXX_Marshal added in v1.2.0 

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

func (*MsgCreateHTLCResponse) XXX_Merge added in v1.2.0 

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

func (*MsgCreateHTLCResponse) XXX_Size added in v1.2.0 

func (m *MsgCreateHTLCResponse) XXX_Size() int

func (*MsgCreateHTLCResponse) XXX_Unmarshal added in v1.2.0 

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

type MsgRefundHTLC 

type MsgRefundHTLC struct {
	Sender   string `protobuf:"bytes,1,opt,name=sender,proto3" json:"sender,omitempty"`
	HashLock string `protobuf:"bytes,2,opt,name=hash_lock,json=hashLock,proto3" json:"hash_lock,omitempty" yaml:"hash_lock"`
}

MsgRefundHTLC defines a message to refund an HTLC

func NewMsgRefundHTLC 

func NewMsgRefundHTLC(
	sender string,
	hashLock string,
) MsgRefundHTLC

NewMsgRefundHTLC constructs a new MsgRefundHTLC instance

func (*MsgRefundHTLC) Descriptor 

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

func (*MsgRefundHTLC) Equal 

func (this *MsgRefundHTLC) Equal(that interface{}) bool

func (MsgRefundHTLC) GetSignBytes 

func (msg MsgRefundHTLC) GetSignBytes() []byte

GetSignBytes implements Msg

func (MsgRefundHTLC) GetSigners 

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

GetSigners implements Msg

func (*MsgRefundHTLC) Marshal 

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

func (*MsgRefundHTLC) MarshalTo 

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

func (*MsgRefundHTLC) MarshalToSizedBuffer 

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

func (*MsgRefundHTLC) ProtoMessage 

func (*MsgRefundHTLC) ProtoMessage()

func (*MsgRefundHTLC) Reset 

func (m *MsgRefundHTLC) Reset()

func (MsgRefundHTLC) Route 

func (msg MsgRefundHTLC) Route() string

Route implements Msg

func (*MsgRefundHTLC) Size 

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

func (*MsgRefundHTLC) String 

func (m *MsgRefundHTLC) String() string

func (MsgRefundHTLC) Type 

func (msg MsgRefundHTLC) Type() string

Type implements Msg

func (*MsgRefundHTLC) Unmarshal 

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

func (MsgRefundHTLC) ValidateBasic 

func (msg MsgRefundHTLC) ValidateBasic() error

ValidateBasic implements Msg

func (*MsgRefundHTLC) XXX_DiscardUnknown 

func (m *MsgRefundHTLC) XXX_DiscardUnknown()

func (*MsgRefundHTLC) XXX_Marshal 

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

func (*MsgRefundHTLC) XXX_Merge 

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

func (*MsgRefundHTLC) XXX_Size 

func (m *MsgRefundHTLC) XXX_Size() int

func (*MsgRefundHTLC) XXX_Unmarshal 

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

type MsgRefundHTLCResponse added in v1.2.0 

type MsgRefundHTLCResponse struct {
}

MsgRefundHTLCResponse defines the Msg/RefundHTLC response type

func (*MsgRefundHTLCResponse) Descriptor added in v1.2.0 

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

func (*MsgRefundHTLCResponse) Marshal added in v1.2.0 

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

func (*MsgRefundHTLCResponse) MarshalTo added in v1.2.0 

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

func (*MsgRefundHTLCResponse) MarshalToSizedBuffer added in v1.2.0 

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

func (*MsgRefundHTLCResponse) ProtoMessage added in v1.2.0 

func (*MsgRefundHTLCResponse) ProtoMessage()

func (*MsgRefundHTLCResponse) Reset added in v1.2.0 

func (m *MsgRefundHTLCResponse) Reset()

func (*MsgRefundHTLCResponse) Size added in v1.2.0 

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

func (*MsgRefundHTLCResponse) String added in v1.2.0 

func (m *MsgRefundHTLCResponse) String() string

func (*MsgRefundHTLCResponse) Unmarshal added in v1.2.0 

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

func (*MsgRefundHTLCResponse) XXX_DiscardUnknown added in v1.2.0 

func (m *MsgRefundHTLCResponse) XXX_DiscardUnknown()

func (*MsgRefundHTLCResponse) XXX_Marshal added in v1.2.0 

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

func (*MsgRefundHTLCResponse) XXX_Merge added in v1.2.0 

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

func (*MsgRefundHTLCResponse) XXX_Size added in v1.2.0 

func (m *MsgRefundHTLCResponse) XXX_Size() int

func (*MsgRefundHTLCResponse) XXX_Unmarshal added in v1.2.0 

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

type MsgServer added in v1.2.0 

type MsgServer interface {
	// CreateHTLC defines a method for creating a HTLC.
	CreateHTLC(context.Context, *MsgCreateHTLC) (*MsgCreateHTLCResponse, error)
	// ClaimHTLC defines a method for claiming a HTLC
	ClaimHTLC(context.Context, *MsgClaimHTLC) (*MsgClaimHTLCResponse, error)
	// RefundHTLC defines a method for refunding a HTLC.
	RefundHTLC(context.Context, *MsgRefundHTLC) (*MsgRefundHTLCResponse, error)
}

MsgServer is the server API for Msg service.

type QueryClient 

type QueryClient interface {
	// HTLC queries the HTLC by the specified hash lock
	HTLC(ctx context.Context, in *QueryHTLCRequest, opts ...grpc.CallOption) (*QueryHTLCResponse, 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 QueryHTLCParams 

type QueryHTLCParams struct {
	HashLock tmbytes.HexBytes
}

QueryHTLCParams defines the params to query an HTLC

type QueryHTLCRequest 

type QueryHTLCRequest struct {
	// address is the address to query balances for
	HashLock string `protobuf:"bytes,1,opt,name=hash_lock,json=hashLock,proto3" json:"hash_lock,omitempty"`
}

QueryHTLCRequest is the request type for the Query/HTLC RPC method

func (*QueryHTLCRequest) Descriptor 

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

func (*QueryHTLCRequest) GetHashLock 

func (m *QueryHTLCRequest) GetHashLock() string

func (*QueryHTLCRequest) Marshal 

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

func (*QueryHTLCRequest) MarshalTo 

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

func (*QueryHTLCRequest) MarshalToSizedBuffer 

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

func (*QueryHTLCRequest) ProtoMessage 

func (*QueryHTLCRequest) ProtoMessage()

func (*QueryHTLCRequest) Reset 

func (m *QueryHTLCRequest) Reset()

func (*QueryHTLCRequest) Size 

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

func (*QueryHTLCRequest) String 

func (m *QueryHTLCRequest) String() string

func (*QueryHTLCRequest) Unmarshal 

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

func (*QueryHTLCRequest) XXX_DiscardUnknown 

func (m *QueryHTLCRequest) XXX_DiscardUnknown()

func (*QueryHTLCRequest) XXX_Marshal 

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

func (*QueryHTLCRequest) XXX_Merge 

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

func (*QueryHTLCRequest) XXX_Size 

func (m *QueryHTLCRequest) XXX_Size() int

func (*QueryHTLCRequest) XXX_Unmarshal 

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

type QueryHTLCResponse 

type QueryHTLCResponse struct {
	Htlc *HTLC `protobuf:"bytes,1,opt,name=htlc,proto3" json:"htlc,omitempty"`
}

QueryBalanceResponse is the response type for the Query/HTLC RPC method

func (*QueryHTLCResponse) Descriptor 

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

func (*QueryHTLCResponse) GetHtlc 

func (m *QueryHTLCResponse) GetHtlc() *HTLC

func (*QueryHTLCResponse) Marshal 

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

func (*QueryHTLCResponse) MarshalTo 

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

func (*QueryHTLCResponse) MarshalToSizedBuffer 

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

func (*QueryHTLCResponse) ProtoMessage 

func (*QueryHTLCResponse) ProtoMessage()

func (*QueryHTLCResponse) Reset 

func (m *QueryHTLCResponse) Reset()

func (*QueryHTLCResponse) Size 

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

func (*QueryHTLCResponse) String 

func (m *QueryHTLCResponse) String() string

func (*QueryHTLCResponse) Unmarshal 

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

func (*QueryHTLCResponse) XXX_DiscardUnknown 

func (m *QueryHTLCResponse) XXX_DiscardUnknown()

func (*QueryHTLCResponse) XXX_Marshal 

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

func (*QueryHTLCResponse) XXX_Merge 

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

func (*QueryHTLCResponse) XXX_Size 

func (m *QueryHTLCResponse) XXX_Size() int

func (*QueryHTLCResponse) XXX_Unmarshal 

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

type QueryServer 

type QueryServer interface {
	// HTLC queries the HTLC by the specified hash lock
	HTLC(context.Context, *QueryHTLCRequest) (*QueryHTLCResponse, error)
}

QueryServer is the server API for Query service.

type UnimplementedMsgServer added in v1.2.0 

type UnimplementedMsgServer struct {
}

UnimplementedMsgServer can be embedded to have forward compatible implementations.

func (*UnimplementedMsgServer) ClaimHTLC added in v1.2.0 

func (*UnimplementedMsgServer) ClaimHTLC(ctx context.Context, req *MsgClaimHTLC) (*MsgClaimHTLCResponse, error)

func (*UnimplementedMsgServer) CreateHTLC added in v1.2.0 

func (*UnimplementedMsgServer) CreateHTLC(ctx context.Context, req *MsgCreateHTLC) (*MsgCreateHTLCResponse, error)

func (*UnimplementedMsgServer) RefundHTLC added in v1.2.0 

func (*UnimplementedMsgServer) RefundHTLC(ctx context.Context, req *MsgRefundHTLC) (*MsgRefundHTLCResponse, error)

type UnimplementedQueryServer 

type UnimplementedQueryServer struct {
}

UnimplementedQueryServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryServer) HTLC 

func (*UnimplementedQueryServer) HTLC(ctx context.Context, req *QueryHTLCRequest) (*QueryHTLCResponse, 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.