types

package
v3.0.0-rc0 Latest Latest
Warning

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

 Go to latest Published: Dec 6, 2024 License: GPL-3.0 Imports: 37 Imported by: 0

Documentation

Overview

Package types is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

View Source 
const (
	EventTypeUpdateParams             = "update_params"
	EventTypeCreateTunnel             = "create_tunnel"
	EventTypeUpdateSignalsAndInterval = "update_signals_and_interval"
	EventTypeActivateTunnel           = "activate_tunnel"
	EventTypeDeactivateTunnel         = "deactivate_tunnel"
	EventTypeTriggerTunnel            = "trigger_tunnel"
	EventTypeProducePacketFail        = "produce_packet_fail"
	EventTypeProducePacketSuccess     = "produce_packet_success"
	EventTypeDepositToTunnel          = "deposit_to_tunnel"
	EventTypeWithdrawFromTunnel       = "withdraw_from_tunnel"

	AttributeKeyParams           = "params"
	AttributeKeyTunnelID         = "tunnel_id"
	AttributeKeySequence         = "sequence"
	AttributeKeyInterval         = "interval"
	AttributeKeyRoute            = "route"
	AttributeKeyEncoder          = "encoder"
	AttributeKeyInitialDeposit   = "initial_deposit"
	AttributeKeyFeePayer         = "fee_payer"
	AttributeKeySignalID         = "signal_id"
	AttributeKeySoftDeviationBPS = "soft_deviation_bps"
	AttributeKeyHardDeviationBPS = "hard_deviation_bps"
	AttributeKeyIsActive         = "is_active"
	AttributeKeyCreatedAt        = "created_at"
	AttributeKeyCreator          = "creator"
	AttributeKeyDepositor        = "depositor"
	AttributeKeyWithdrawer       = "withdrawer"
	AttributeKeyAmount           = "amount"
	AttributeKeyReason           = "reason"
)

events

View Source 
const (
	// ModuleName defines the module name
	ModuleName = "tunnel"

	// Version defines the current version the IBC module supports
	Version = "tunnel-1"

	// TunnelAccountsKey is used to store the key for the account
	TunnelAccountsKey = "tunnel-accounts"

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

	// RouterKey defines the module's message routing key
	RouterKey = ModuleName

	// QuerierRoute is the querier route for the tunnel module
	QuerierRoute = ModuleName
)
View Source 
const SignatureOrderTypeTunnel = "tunnel"

signature order types

Variables

View Source 
var (
	ErrInvalidGenesis            = errorsmod.Register(ModuleName, 2, "invalid genesis")
	ErrMaxSignalsExceeded        = errorsmod.Register(ModuleName, 3, "max signals exceeded")
	ErrIntervalOutOfRange        = errorsmod.Register(ModuleName, 4, "interval out of range")
	ErrDeviationOutOfRange       = errorsmod.Register(ModuleName, 5, "deviation out of range")
	ErrTunnelNotFound            = errorsmod.Register(ModuleName, 6, "tunnel not found")
	ErrLatestPricesNotFound      = errorsmod.Register(ModuleName, 7, "latest prices not found")
	ErrPacketNotFound            = errorsmod.Register(ModuleName, 8, "packet not found")
	ErrNoPacketReceipt           = errorsmod.Register(ModuleName, 9, "no packet receipt")
	ErrInvalidTunnelCreator      = errorsmod.Register(ModuleName, 10, "invalid creator of the tunnel")
	ErrAccountAlreadyExist       = errorsmod.Register(ModuleName, 11, "account already exist")
	ErrInvalidRoute              = errorsmod.Register(ModuleName, 12, "invalid tunnel route")
	ErrInactiveTunnel            = errorsmod.Register(ModuleName, 13, "inactive tunnel")
	ErrAlreadyActive             = errorsmod.Register(ModuleName, 14, "already active")
	ErrAlreadyInactive           = errorsmod.Register(ModuleName, 15, "already inactive")
	ErrInvalidDepositDenom       = errorsmod.Register(ModuleName, 16, "invalid deposit denom")
	ErrDepositNotFound           = errorsmod.Register(ModuleName, 17, "deposit not found")
	ErrInsufficientDeposit       = errorsmod.Register(ModuleName, 18, "insufficient deposit")
	ErrInsufficientFund          = errorsmod.Register(ModuleName, 19, "insufficient fund")
	ErrDeviationNotFound         = errorsmod.Register(ModuleName, 20, "deviation not found")
	ErrInvalidVersion            = errorsmod.Register(ModuleName, 21, "invalid version")
	ErrChannelCapabilityNotFound = errorsmod.Register(ModuleName, 22, "channel capability not found")
	ErrMaxTunnelChannels         = errorsmod.Register(ModuleName, 23, "max tunnel channels exceeded")
	ErrInvalidEncoder            = errorsmod.Register(ModuleName, 24, "invalid encoder")
	ErrSendPacketPanic           = errorsmod.Register(ModuleName, 25, "panic in sending packet")
	ErrInvalidChannelID          = errorsmod.Register(ModuleName, 26, "invalid channel id")
	ErrInvalidPortID             = errorsmod.Register(ModuleName, 27, "invalid port id")
)

x/tunnel 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 (
	// global store keys
	TunnelCountStoreKey = []byte{0x00}
	TotalFeeStoreKey    = []byte{0x01}

	// store prefixes
	ActiveTunnelIDStoreKeyPrefix = []byte{0x10}
	TunnelStoreKeyPrefix         = []byte{0x11}
	PacketStoreKeyPrefix         = []byte{0x12}
	LatestPricesStoreKeyPrefix   = []byte{0x13}
	DepositStoreKeyPrefix        = []byte{0x14}

	// params store keys
	ParamsKey = []byte{0x90}
)
View Source 
var (
	// Each value below is the default value for each parameter when generating the default
	// genesis file. See comments in types.proto for explanation for each parameter.
	DefaultMinInterval     = uint64(60)
	DefaultMaxInterval     = uint64(3600)
	DefaultMinDeviationBPS = uint64(50)
	DefaultMaxDeviationBPS = uint64(3000)
	DefaultMinDeposit      = sdk.NewCoins(sdk.NewInt64Coin("uband", 1_000_000_000))
	DefaultMaxSignals      = uint64(25)
	DefaultBasePacketFee   = sdk.NewCoins(sdk.NewInt64Coin("uband", 10_000))
)
View Source 
var (
	ErrInvalidLengthParams        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowParams          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupParams = 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 (
	ErrInvalidLengthRoute        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowRoute          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupRoute = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthTunnel        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTunnel          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupTunnel = 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 = codec.NewProtoCodec(codectypes.NewInterfaceRegistry())

ModuleCdc references the global x/tunnel module codec. Note, the codec should ONLY be used in certain instances of tests and for JSON encoding.

The actual codec used for serialization should be provided to x/tunnel and defined at the application level.

View Source 
var TunnelStatusFilter_name = map[int32]string{
	0: "TUNNEL_STATUS_FILTER_UNSPECIFIED",
	1: "TUNNEL_STATUS_FILTER_ACTIVE",
	2: "TUNNEL_STATUS_FILTER_INACTIVE",
}
View Source 
var TunnelStatusFilter_value = map[string]int32{
	"TUNNEL_STATUS_FILTER_UNSPECIFIED": 0,
	"TUNNEL_STATUS_FILTER_ACTIVE":      1,
	"TUNNEL_STATUS_FILTER_INACTIVE":    2,
}

Functions

func ActiveTunnelIDStoreKey 

func ActiveTunnelIDStoreKey(tunnelID uint64) []byte

ActiveTunnelIDStoreKey returns the key to retrieve a specific active tunnel ID from the store.

func DepositStoreKey 

func DepositStoreKey(tunnelID uint64, depositor sdk.AccAddress) []byte

DepositStoreKey returns the key to retrieve a deposit of a tunnel from the store.

func DepositsStoreKey 

func DepositsStoreKey(tunnelID uint64) []byte

DepositsStoreKey returns the key to retrieve all deposits of a tunnel from the store.

func EncodeTSS 

func EncodeTSS(
	sequence uint64,
	prices []feedstypes.Price,
	createdAt int64,
	encoder feedstypes.Encoder,
) ([]byte, error)

EncodeTSS encodes the packet to tss message

func LatestPricesStoreKey 

func LatestPricesStoreKey(tunnelID uint64) []byte

LatestPricesStoreKey returns the key to retrieve the latest prices from the store.

func RegisterInterfaces 

func RegisterInterfaces(registry codectypes.InterfaceRegistry)

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

func RegisterLegacyAminoCodec 

func RegisterLegacyAminoCodec(cdc *codec.LegacyAmino)

RegisterLegacyAminoCodec registers the necessary x/tunnel interfaces and concrete types on the provided LegacyAmino codec. These types are used for Amino JSON serialization.

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)

func TunnelPacketStoreKey 

func TunnelPacketStoreKey(tunnelID uint64, packetID uint64) []byte

TunnelPacketStoreKey returns the key to retrieve a packet of a tunnel from the store.

func TunnelPacketsStoreKey 

func TunnelPacketsStoreKey(tunnelID uint64) []byte

TunnelPacketsStoreKey returns the key to retrieve all packets of a tunnel from the store.

func TunnelStoreKey 

func TunnelStoreKey(tunnelID uint64) []byte

TunnelStoreKey returns the key to retrieve a specific tunnel from the store.

func ValidateGenesis 

func ValidateGenesis(data GenesisState) error

ValidateGenesis validates the provided genesis state.

func ValidateInterval 

func ValidateInterval(interval, maxInterval, minInterval uint64) error

ValidateInterval validates the interval of the tunnel.

func ValidateSignalDeviations 

func ValidateSignalDeviations(
	signalDeviations []SignalDeviation,
	maxSignals uint64,
	maxDeviationBPS uint64,
	minDeviationBPS uint64,
) error

ValidateSignalDeviations validates the signal deviations with the given params.

Types

type AccountKeeper 

type AccountKeeper interface {
	GetModuleAddress(name string) sdk.AccAddress
	GetModuleAccount(ctx context.Context, name string) sdk.ModuleAccountI
	SetModuleAccount(ctx context.Context, moduleAccount sdk.ModuleAccountI)

	GetAccount(ctx context.Context, addr sdk.AccAddress) sdk.AccountI
	NewAccount(ctx context.Context, account sdk.AccountI) sdk.AccountI
	SetAccount(ctx context.Context, account sdk.AccountI)
}

AccountKeeper defines the expected account keeper (noalias)

type BandtssKeeper 

type BandtssKeeper interface {
	CreateTunnelSigningRequest(
		ctx sdk.Context,
		tunnelID uint64,
		destinationChainID string,
		destinationContractAddr string,
		content tsstypes.Content,
		sender sdk.AccAddress,
		feeLimit sdk.Coins,
	) (bandtsstypes.SigningID, error)
	GetSigningFee(ctx sdk.Context) (sdk.Coins, error)
}

type BankKeeper 

type BankKeeper interface {
	GetAllBalances(ctx context.Context, addr sdk.AccAddress) sdk.Coins
	SpendableCoins(ctx context.Context, addr sdk.AccAddress) sdk.Coins

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

type ChannelKeeper 

type ChannelKeeper interface {
	GetChannel(ctx sdk.Context, srcPort, srcChan string) (channel channeltypes.Channel, found bool)
}

ChannelKeeper defines the expected IBC channel keeper

type Deposit 

type Deposit struct {
	// tunnel_id defines the unique id of the tunnel.
	TunnelID uint64 `protobuf:"varint,1,opt,name=tunnel_id,json=tunnelId,proto3" json:"tunnel_id,omitempty"`
	// depositor defines the deposit addresses from the proposals.
	Depositor string `protobuf:"bytes,2,opt,name=depositor,proto3" json:"depositor,omitempty"`
	// amount to be deposited by depositor.
	Amount github_com_cosmos_cosmos_sdk_types.Coins `protobuf:"bytes,3,rep,name=amount,proto3,castrepeated=github.com/cosmos/cosmos-sdk/types.Coins" json:"amount"`
}

Deposit defines an amount deposited by an account address to the tunnel.

func NewDeposit 

func NewDeposit(tunnelID uint64, depositor string, amount sdk.Coins) Deposit

NewDeposit creates a new Deposit instance

func (*Deposit) Descriptor 

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

func (*Deposit) Equal 

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

func (*Deposit) GetAmount 

func (m *Deposit) GetAmount() github_com_cosmos_cosmos_sdk_types.Coins

func (*Deposit) GetDepositor 

func (m *Deposit) GetDepositor() string

func (*Deposit) GetTunnelID 

func (m *Deposit) GetTunnelID() uint64

func (*Deposit) Marshal 

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

func (*Deposit) MarshalTo 

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

func (*Deposit) MarshalToSizedBuffer 

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

func (*Deposit) ProtoMessage 

func (*Deposit) ProtoMessage()

func (*Deposit) Reset 

func (m *Deposit) Reset()

func (*Deposit) Size 

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

func (*Deposit) String 

func (m *Deposit) String() string

func (*Deposit) Unmarshal 

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

func (*Deposit) XXX_DiscardUnknown 

func (m *Deposit) XXX_DiscardUnknown()

func (*Deposit) XXX_Marshal 

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

func (*Deposit) XXX_Merge 

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

func (*Deposit) XXX_Size 

func (m *Deposit) XXX_Size() int

func (*Deposit) XXX_Unmarshal 

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

type FeedsKeeper 

type FeedsKeeper interface {
	GetAllPrices(ctx sdk.Context) (prices []feedstypes.Price)
	GetPrices(ctx sdk.Context, signalIDs []string) (prices []feedstypes.Price)
}

type GenesisState 

type GenesisState struct {
	// params is all parameters of the module.
	Params Params `protobuf:"bytes,1,opt,name=params,proto3" json:"params"`
	// tunnel_count is the number of tunnels.
	TunnelCount uint64 `protobuf:"varint,2,opt,name=tunnel_count,json=tunnelCount,proto3" json:"tunnel_count,omitempty"`
	// tunnels is the list of tunnels.
	Tunnels []Tunnel `protobuf:"bytes,3,rep,name=tunnels,proto3" json:"tunnels"`
	// deposits is the list of deposits.
	Deposits []Deposit `protobuf:"bytes,4,rep,name=deposits,proto3" json:"deposits"`
	// total_fees is the type for the total fees collected by the tunnel
	TotalFees TotalFees `protobuf:"bytes,5,opt,name=total_fees,json=totalFees,proto3" json:"total_fees"`
}

GenesisState represents the initial state of the blockchain.

func DefaultGenesisState 

func DefaultGenesisState() *GenesisState

DefaultGenesisState gets the raw genesis raw message for testing

func NewGenesisState 

func NewGenesisState(
	params Params,
	tunnelCount uint64,
	tunnels []Tunnel,
	totalFees TotalFees,
) *GenesisState

NewGenesisState creates a new GenesisState instance

func (*GenesisState) Descriptor 

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

func (*GenesisState) GetDeposits 

func (m *GenesisState) GetDeposits() []Deposit

func (*GenesisState) GetParams 

func (m *GenesisState) GetParams() Params

func (*GenesisState) GetTotalFees 

func (m *GenesisState) GetTotalFees() TotalFees

func (*GenesisState) GetTunnelCount 

func (m *GenesisState) GetTunnelCount() uint64

func (*GenesisState) GetTunnels 

func (m *GenesisState) GetTunnels() []Tunnel

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 IBCPacketReceipt 

type IBCPacketReceipt struct {
	// sequence is representing the sequence of the IBC packet.
	Sequence uint64 `protobuf:"varint,1,opt,name=sequence,proto3" json:"sequence,omitempty"`
}

IBCPacketReceipt represents a receipt for a IBC packet and implements the PacketReceiptI interface.

func NewIBCPacketReceipt 

func NewIBCPacketReceipt(sequence uint64) *IBCPacketReceipt

NewIBCPacketReceipt creates a new IBCPacketReceipt instance.

func (*IBCPacketReceipt) Descriptor 

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

func (*IBCPacketReceipt) Equal 

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

func (*IBCPacketReceipt) GetSequence 

func (m *IBCPacketReceipt) GetSequence() uint64

func (*IBCPacketReceipt) Marshal 

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

func (*IBCPacketReceipt) MarshalTo 

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

func (*IBCPacketReceipt) MarshalToSizedBuffer 

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

func (*IBCPacketReceipt) ProtoMessage 

func (*IBCPacketReceipt) ProtoMessage()

func (*IBCPacketReceipt) Reset 

func (m *IBCPacketReceipt) Reset()

func (*IBCPacketReceipt) Size 

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

func (*IBCPacketReceipt) String 

func (m *IBCPacketReceipt) String() string

func (*IBCPacketReceipt) Unmarshal 

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

func (*IBCPacketReceipt) XXX_DiscardUnknown 

func (m *IBCPacketReceipt) XXX_DiscardUnknown()

func (*IBCPacketReceipt) XXX_Marshal 

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

func (*IBCPacketReceipt) XXX_Merge 

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

func (*IBCPacketReceipt) XXX_Size 

func (m *IBCPacketReceipt) XXX_Size() int

func (*IBCPacketReceipt) XXX_Unmarshal 

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

type IBCRoute 

type IBCRoute struct {
	// channel_id is the IBC channel ID
	ChannelID string `protobuf:"bytes,1,opt,name=channel_id,json=channelId,proto3" json:"channel_id,omitempty"`
}

IBCRoute is the type for an IBC route

func NewIBCRoute 

func NewIBCRoute(channelID string) *IBCRoute

NewIBCRoute creates a new IBCRoute instance.

func (*IBCRoute) Descriptor 

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

func (*IBCRoute) Equal 

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

func (*IBCRoute) GetChannelID 

func (m *IBCRoute) GetChannelID() string

func (*IBCRoute) Marshal 

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

func (*IBCRoute) MarshalTo 

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

func (*IBCRoute) MarshalToSizedBuffer 

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

func (*IBCRoute) ProtoMessage 

func (*IBCRoute) ProtoMessage()

func (*IBCRoute) Reset 

func (m *IBCRoute) Reset()

func (*IBCRoute) Size 

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

func (*IBCRoute) String 

func (m *IBCRoute) String() string

func (*IBCRoute) Unmarshal 

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

func (*IBCRoute) ValidateBasic 

func (r *IBCRoute) ValidateBasic() error

ValidateBasic validates the IBCRoute

func (*IBCRoute) XXX_DiscardUnknown 

func (m *IBCRoute) XXX_DiscardUnknown()

func (*IBCRoute) XXX_Marshal 

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

func (*IBCRoute) XXX_Merge 

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

func (*IBCRoute) XXX_Size 

func (m *IBCRoute) XXX_Size() int

func (*IBCRoute) XXX_Unmarshal 

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

type ICS4Wrapper 

type ICS4Wrapper interface {
	SendPacket(
		ctx sdk.Context,
		chanCap *capabilitytypes.Capability,
		sourcePort string,
		sourceChannel string,
		timeoutHeight ibcclienttypes.Height,
		timeoutTimestamp uint64,
		data []byte,
	) (sequence uint64, err error)
}

type LatestPrices 

type LatestPrices struct {
	// tunnel_id is the tunnel ID
	TunnelID uint64 `protobuf:"varint,1,opt,name=tunnel_id,json=tunnelId,proto3" json:"tunnel_id,omitempty"`
	// prices is the list of prices information from feeds module.
	Prices []types2.Price `protobuf:"bytes,2,rep,name=prices,proto3" json:"prices"`
	// last_interval is the last interval when the signal prices are produced by interval trigger
	LastInterval int64 `protobuf:"varint,3,opt,name=last_interval,json=lastInterval,proto3" json:"last_interval,omitempty"`
}

LatestPrices is the type for prices that tunnel produces

func NewLatestPrices 

func NewLatestPrices(
	tunnelID uint64,
	prices []feedstypes.Price,
	lastInterval int64,
) LatestPrices

NewLatestPrices creates a new LatestPrices instance.

func (*LatestPrices) Descriptor 

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

func (*LatestPrices) Equal 

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

func (*LatestPrices) GetLastInterval 

func (m *LatestPrices) GetLastInterval() int64

func (*LatestPrices) GetPrices 

func (m *LatestPrices) GetPrices() []types2.Price

func (*LatestPrices) GetTunnelID 

func (m *LatestPrices) GetTunnelID() uint64

func (*LatestPrices) Marshal 

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

func (*LatestPrices) MarshalTo 

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

func (*LatestPrices) MarshalToSizedBuffer 

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

func (*LatestPrices) ProtoMessage 

func (*LatestPrices) ProtoMessage()

func (*LatestPrices) Reset 

func (m *LatestPrices) Reset()

func (*LatestPrices) Size 

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

func (*LatestPrices) String 

func (m *LatestPrices) String() string

func (*LatestPrices) Unmarshal 

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

func (*LatestPrices) UpdatePrices 

func (l *LatestPrices) UpdatePrices(newPrices []feedstypes.Price)

UpdatePrices updates prices in the latest prices.

func (*LatestPrices) XXX_DiscardUnknown 

func (m *LatestPrices) XXX_DiscardUnknown()

func (*LatestPrices) XXX_Marshal 

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

func (*LatestPrices) XXX_Merge 

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

func (*LatestPrices) XXX_Size 

func (m *LatestPrices) XXX_Size() int

func (*LatestPrices) XXX_Unmarshal 

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

type MsgActivate 

type MsgActivate struct {
	// tunnel_id is the ID of the tunnel to activate.
	TunnelID uint64 `protobuf:"varint,1,opt,name=tunnel_id,json=tunnelId,proto3" json:"tunnel_id,omitempty"`
	// creator is the address of the creator.
	Creator string `protobuf:"bytes,2,opt,name=creator,proto3" json:"creator,omitempty"`
}

Activate is the transaction message to activate a tunnel.

func NewMsgActivate 

func NewMsgActivate(
	tunnelID uint64,
	creator string,
) *MsgActivate

NewMsgActivate creates a new MsgActivate instance.

func (*MsgActivate) Descriptor 

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

func (*MsgActivate) GetCreator 

func (m *MsgActivate) GetCreator() string

func (*MsgActivate) GetTunnelID 

func (m *MsgActivate) GetTunnelID() uint64

func (*MsgActivate) Marshal 

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

func (*MsgActivate) MarshalTo 

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

func (*MsgActivate) MarshalToSizedBuffer 

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

func (*MsgActivate) ProtoMessage 

func (*MsgActivate) ProtoMessage()

func (*MsgActivate) Reset 

func (m *MsgActivate) Reset()

func (*MsgActivate) Size 

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

func (*MsgActivate) String 

func (m *MsgActivate) String() string

func (*MsgActivate) Unmarshal 

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

func (MsgActivate) ValidateBasic 

func (m MsgActivate) ValidateBasic() error

ValidateBasic does a sanity check on the provided data

func (*MsgActivate) XXX_DiscardUnknown 

func (m *MsgActivate) XXX_DiscardUnknown()

func (*MsgActivate) XXX_Marshal 

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

func (*MsgActivate) XXX_Merge 

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

func (*MsgActivate) XXX_Size 

func (m *MsgActivate) XXX_Size() int

func (*MsgActivate) XXX_Unmarshal 

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

type MsgActivateResponse 

type MsgActivateResponse struct {
}

MsgActivateResponse is the response type for the Msg/Activate RPC method.

func (*MsgActivateResponse) Descriptor 

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

func (*MsgActivateResponse) Marshal 

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

func (*MsgActivateResponse) MarshalTo 

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

func (*MsgActivateResponse) MarshalToSizedBuffer 

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

func (*MsgActivateResponse) ProtoMessage 

func (*MsgActivateResponse) ProtoMessage()

func (*MsgActivateResponse) Reset 

func (m *MsgActivateResponse) Reset()

func (*MsgActivateResponse) Size 

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

func (*MsgActivateResponse) String 

func (m *MsgActivateResponse) String() string

func (*MsgActivateResponse) Unmarshal 

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

func (*MsgActivateResponse) XXX_DiscardUnknown 

func (m *MsgActivateResponse) XXX_DiscardUnknown()

func (*MsgActivateResponse) XXX_Marshal 

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

func (*MsgActivateResponse) XXX_Merge 

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

func (*MsgActivateResponse) XXX_Size 

func (m *MsgActivateResponse) XXX_Size() int

func (*MsgActivateResponse) XXX_Unmarshal 

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

type MsgClient 

type MsgClient interface {
	// CreateTunnel is a RPC method to create a new tunnel.
	CreateTunnel(ctx context.Context, in *MsgCreateTunnel, opts ...grpc.CallOption) (*MsgCreateTunnelResponse, error)
	// UpdateRoute is a RPC method to update a route information of the tunnel.
	UpdateRoute(ctx context.Context, in *MsgUpdateRoute, opts ...grpc.CallOption) (*MsgUpdateRouteResponse, error)
	// UpdateSignalsAndInterval is a RPC method to update a signals and interval of the tunnel.
	UpdateSignalsAndInterval(ctx context.Context, in *MsgUpdateSignalsAndInterval, opts ...grpc.CallOption) (*MsgUpdateSignalsAndIntervalResponse, error)
	// Activate is a RPC method to activate a tunnel.
	Activate(ctx context.Context, in *MsgActivate, opts ...grpc.CallOption) (*MsgActivateResponse, error)
	// Deactivate is a RPC method to deactivate a tunnel.
	Deactivate(ctx context.Context, in *MsgDeactivate, opts ...grpc.CallOption) (*MsgDeactivateResponse, error)
	// TriggerTunnel is a RPC method to manually trigger a tunnel.
	TriggerTunnel(ctx context.Context, in *MsgTriggerTunnel, opts ...grpc.CallOption) (*MsgTriggerTunnelResponse, error)
	// DepositToTunnel is a RPC method to deposit to an existing tunnel.
	DepositToTunnel(ctx context.Context, in *MsgDepositToTunnel, opts ...grpc.CallOption) (*MsgDepositToTunnelResponse, error)
	// WithdrawFromTunnel is a RPC method to withdraw a deposit from an existing tunnel.
	WithdrawFromTunnel(ctx context.Context, in *MsgWithdrawFromTunnel, opts ...grpc.CallOption) (*MsgWithdrawFromTunnelResponse, error)
	// UpdateParams is a RPC method to update parameters
	UpdateParams(ctx context.Context, in *MsgUpdateParams, opts ...grpc.CallOption) (*MsgUpdateParamsResponse, 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 MsgCreateTunnel 

type MsgCreateTunnel struct {
	// signal_deviations is the list of signal deviations.
	SignalDeviations []SignalDeviation `protobuf:"bytes,1,rep,name=signal_deviations,json=signalDeviations,proto3" json:"signal_deviations"`
	// interval is the interval for delivering the signal prices in seconds.
	Interval uint64 `protobuf:"varint,2,opt,name=interval,proto3" json:"interval,omitempty"`
	// route is the route for delivering the signal prices
	Route *types.Any `protobuf:"bytes,3,opt,name=route,proto3" json:"route,omitempty"`
	// initial_deposit is the deposit value that must be paid at tunnel creation.
	InitialDeposit github_com_cosmos_cosmos_sdk_types.Coins `` /* 147-byte string literal not displayed */
	// creator is the address of the creator.
	Creator string `protobuf:"bytes,5,opt,name=creator,proto3" json:"creator,omitempty"`
}

MsgCreateTunnel is the transaction message to create a new tunnel.

func NewMsgCreateIBCTunnel 

func NewMsgCreateIBCTunnel(
	signalDeviations []SignalDeviation,
	interval uint64,
	deposit sdk.Coins,
	creator string,
) (*MsgCreateTunnel, error)

NewMsgCreateIBCTunnel creates a new MsgCreateTunnel instance with IBC route type.

func NewMsgCreateTSSTunnel 

func NewMsgCreateTSSTunnel(
	signalDeviations []SignalDeviation,
	interval uint64,
	destinationChainID string,
	destinationContractAddress string,
	encoder feedstypes.Encoder,
	initialDeposit sdk.Coins,
	creator string,
) (*MsgCreateTunnel, error)

NewMsgCreateTSSTunnel creates a new MsgCreateTunnel instance for TSS tunnel.

func NewMsgCreateTunnel 

func NewMsgCreateTunnel(
	signalDeviations []SignalDeviation,
	interval uint64,
	route RouteI,
	initialDeposit sdk.Coins,
	creator string,
) (*MsgCreateTunnel, error)

NewMsgCreateTunnel creates a new MsgCreateTunnel instance.

func (*MsgCreateTunnel) Descriptor 

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

func (*MsgCreateTunnel) GetCreator 

func (m *MsgCreateTunnel) GetCreator() string

func (*MsgCreateTunnel) GetInitialDeposit 

func (m *MsgCreateTunnel) GetInitialDeposit() github_com_cosmos_cosmos_sdk_types.Coins

func (*MsgCreateTunnel) GetInterval 

func (m *MsgCreateTunnel) GetInterval() uint64

func (*MsgCreateTunnel) GetRoute 

func (m *MsgCreateTunnel) GetRoute() *types.Any

func (MsgCreateTunnel) GetRouteValue 

func (m MsgCreateTunnel) GetRouteValue() (RouteI, error)

GetRouteValue returns the route of the tunnel.

func (*MsgCreateTunnel) GetSignalDeviations 

func (m *MsgCreateTunnel) GetSignalDeviations() []SignalDeviation

func (*MsgCreateTunnel) Marshal 

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

func (*MsgCreateTunnel) MarshalTo 

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

func (*MsgCreateTunnel) MarshalToSizedBuffer 

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

func (*MsgCreateTunnel) ProtoMessage 

func (*MsgCreateTunnel) ProtoMessage()

func (*MsgCreateTunnel) Reset 

func (m *MsgCreateTunnel) Reset()

func (*MsgCreateTunnel) Size 

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

func (*MsgCreateTunnel) String 

func (m *MsgCreateTunnel) String() string

func (*MsgCreateTunnel) Unmarshal 

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

func (MsgCreateTunnel) UnpackInterfaces 

func (m MsgCreateTunnel) UnpackInterfaces(unpacker types.AnyUnpacker) error

UnpackInterfaces implements UnpackInterfacesMessage.UnpackInterfaces

func (MsgCreateTunnel) ValidateBasic 

func (m MsgCreateTunnel) ValidateBasic() error

ValidateBasic does a sanity check on the provided data

func (*MsgCreateTunnel) XXX_DiscardUnknown 

func (m *MsgCreateTunnel) XXX_DiscardUnknown()

func (*MsgCreateTunnel) XXX_Marshal 

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

func (*MsgCreateTunnel) XXX_Merge 

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

func (*MsgCreateTunnel) XXX_Size 

func (m *MsgCreateTunnel) XXX_Size() int

func (*MsgCreateTunnel) XXX_Unmarshal 

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

type MsgCreateTunnelResponse 

type MsgCreateTunnelResponse struct {
	TunnelID uint64 `protobuf:"varint,1,opt,name=tunnel_id,json=tunnelId,proto3" json:"tunnel_id,omitempty"`
}

MsgCreateTunnelResponse is the response type for the Msg/CreateTunnel RPC method.

func (*MsgCreateTunnelResponse) Descriptor 

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

func (*MsgCreateTunnelResponse) GetTunnelID 

func (m *MsgCreateTunnelResponse) GetTunnelID() uint64

func (*MsgCreateTunnelResponse) Marshal 

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

func (*MsgCreateTunnelResponse) MarshalTo 

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

func (*MsgCreateTunnelResponse) MarshalToSizedBuffer 

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

func (*MsgCreateTunnelResponse) ProtoMessage 

func (*MsgCreateTunnelResponse) ProtoMessage()

func (*MsgCreateTunnelResponse) Reset 

func (m *MsgCreateTunnelResponse) Reset()

func (*MsgCreateTunnelResponse) Size 

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

func (*MsgCreateTunnelResponse) String 

func (m *MsgCreateTunnelResponse) String() string

func (*MsgCreateTunnelResponse) Unmarshal 

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

func (*MsgCreateTunnelResponse) XXX_DiscardUnknown 

func (m *MsgCreateTunnelResponse) XXX_DiscardUnknown()

func (*MsgCreateTunnelResponse) XXX_Marshal 

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

func (*MsgCreateTunnelResponse) XXX_Merge 

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

func (*MsgCreateTunnelResponse) XXX_Size 

func (m *MsgCreateTunnelResponse) XXX_Size() int

func (*MsgCreateTunnelResponse) XXX_Unmarshal 

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

type MsgDeactivate 

type MsgDeactivate struct {
	// tunnel_id is the ID of the tunnel to deactivate.
	TunnelID uint64 `protobuf:"varint,1,opt,name=tunnel_id,json=tunnelId,proto3" json:"tunnel_id,omitempty"`
	// creator is the address of the creator.
	Creator string `protobuf:"bytes,2,opt,name=creator,proto3" json:"creator,omitempty"`
}

MsgDeactivate is the transaction message to deactivate a tunnel.

func NewMsgDeactivate 

func NewMsgDeactivate(
	tunnelID uint64,
	creator string,
) *MsgDeactivate

NewMsgDeactivate creates a new MsgDeactivate instance.

func (*MsgDeactivate) Descriptor 

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

func (*MsgDeactivate) GetCreator 

func (m *MsgDeactivate) GetCreator() string

func (*MsgDeactivate) GetTunnelID 

func (m *MsgDeactivate) GetTunnelID() uint64

func (*MsgDeactivate) Marshal 

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

func (*MsgDeactivate) MarshalTo 

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

func (*MsgDeactivate) MarshalToSizedBuffer 

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

func (*MsgDeactivate) ProtoMessage 

func (*MsgDeactivate) ProtoMessage()

func (*MsgDeactivate) Reset 

func (m *MsgDeactivate) Reset()

func (*MsgDeactivate) Size 

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

func (*MsgDeactivate) String 

func (m *MsgDeactivate) String() string

func (*MsgDeactivate) Unmarshal 

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

func (MsgDeactivate) ValidateBasic 

func (m MsgDeactivate) ValidateBasic() error

ValidateBasic does a sanity check on the provided data

func (*MsgDeactivate) XXX_DiscardUnknown 

func (m *MsgDeactivate) XXX_DiscardUnknown()

func (*MsgDeactivate) XXX_Marshal 

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

func (*MsgDeactivate) XXX_Merge 

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

func (*MsgDeactivate) XXX_Size 

func (m *MsgDeactivate) XXX_Size() int

func (*MsgDeactivate) XXX_Unmarshal 

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

type MsgDeactivateResponse 

type MsgDeactivateResponse struct {
}

MsgDeactivateTunnelResponse is the response type for the Msg/Deactivate RPC method.

func (*MsgDeactivateResponse) Descriptor 

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

func (*MsgDeactivateResponse) Marshal 

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

func (*MsgDeactivateResponse) MarshalTo 

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

func (*MsgDeactivateResponse) MarshalToSizedBuffer 

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

func (*MsgDeactivateResponse) ProtoMessage 

func (*MsgDeactivateResponse) ProtoMessage()

func (*MsgDeactivateResponse) Reset 

func (m *MsgDeactivateResponse) Reset()

func (*MsgDeactivateResponse) Size 

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

func (*MsgDeactivateResponse) String 

func (m *MsgDeactivateResponse) String() string

func (*MsgDeactivateResponse) Unmarshal 

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

func (*MsgDeactivateResponse) XXX_DiscardUnknown 

func (m *MsgDeactivateResponse) XXX_DiscardUnknown()

func (*MsgDeactivateResponse) XXX_Marshal 

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

func (*MsgDeactivateResponse) XXX_Merge 

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

func (*MsgDeactivateResponse) XXX_Size 

func (m *MsgDeactivateResponse) XXX_Size() int

func (*MsgDeactivateResponse) XXX_Unmarshal 

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

type MsgDepositToTunnel 

type MsgDepositToTunnel struct {
	// tunnel_id defines the unique id of the tunnel.
	TunnelID uint64 `protobuf:"varint,1,opt,name=tunnel_id,json=tunnelId,proto3" json:"tunnel_id,omitempty"`
	// amount to be deposited by depositor.
	Amount github_com_cosmos_cosmos_sdk_types.Coins `protobuf:"bytes,2,rep,name=amount,proto3,castrepeated=github.com/cosmos/cosmos-sdk/types.Coins" json:"amount"`
	// depositor defines the deposit addresses from the tunnel.
	Depositor string `protobuf:"bytes,3,opt,name=depositor,proto3" json:"depositor,omitempty"`
}

MsgDepositToTunnel defines a message to deposit to an existing tunnel.

func NewMsgDepositToTunnel 

func NewMsgDepositToTunnel(
	tunnelID uint64,
	amount sdk.Coins,
	depositor string,
) *MsgDepositToTunnel

NewMsgDepositToTunnel creates a new MsgDepositToTunnel instance.

func (*MsgDepositToTunnel) Descriptor 

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

func (*MsgDepositToTunnel) GetAmount 

func (m *MsgDepositToTunnel) GetAmount() github_com_cosmos_cosmos_sdk_types.Coins

func (*MsgDepositToTunnel) GetDepositor 

func (m *MsgDepositToTunnel) GetDepositor() string

func (*MsgDepositToTunnel) GetTunnelID 

func (m *MsgDepositToTunnel) GetTunnelID() uint64

func (*MsgDepositToTunnel) Marshal 

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

func (*MsgDepositToTunnel) MarshalTo 

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

func (*MsgDepositToTunnel) MarshalToSizedBuffer 

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

func (*MsgDepositToTunnel) ProtoMessage 

func (*MsgDepositToTunnel) ProtoMessage()

func (*MsgDepositToTunnel) Reset 

func (m *MsgDepositToTunnel) Reset()

func (*MsgDepositToTunnel) Size 

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

func (*MsgDepositToTunnel) String 

func (m *MsgDepositToTunnel) String() string

func (*MsgDepositToTunnel) Unmarshal 

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

func (MsgDepositToTunnel) ValidateBasic 

func (m MsgDepositToTunnel) ValidateBasic() error

ValidateBasic does a sanity check on the provided data

func (*MsgDepositToTunnel) XXX_DiscardUnknown 

func (m *MsgDepositToTunnel) XXX_DiscardUnknown()

func (*MsgDepositToTunnel) XXX_Marshal 

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

func (*MsgDepositToTunnel) XXX_Merge 

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

func (*MsgDepositToTunnel) XXX_Size 

func (m *MsgDepositToTunnel) XXX_Size() int

func (*MsgDepositToTunnel) XXX_Unmarshal 

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

type MsgDepositToTunnelResponse 

type MsgDepositToTunnelResponse struct {
}

MsgDepositToTunnelResponse defines the Msg/DepositToTunnel response type.

func (*MsgDepositToTunnelResponse) Descriptor 

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

func (*MsgDepositToTunnelResponse) Marshal 

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

func (*MsgDepositToTunnelResponse) MarshalTo 

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

func (*MsgDepositToTunnelResponse) MarshalToSizedBuffer 

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

func (*MsgDepositToTunnelResponse) ProtoMessage 

func (*MsgDepositToTunnelResponse) ProtoMessage()

func (*MsgDepositToTunnelResponse) Reset 

func (m *MsgDepositToTunnelResponse) Reset()

func (*MsgDepositToTunnelResponse) Size 

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

func (*MsgDepositToTunnelResponse) String 

func (m *MsgDepositToTunnelResponse) String() string

func (*MsgDepositToTunnelResponse) Unmarshal 

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

func (*MsgDepositToTunnelResponse) XXX_DiscardUnknown 

func (m *MsgDepositToTunnelResponse) XXX_DiscardUnknown()

func (*MsgDepositToTunnelResponse) XXX_Marshal 

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

func (*MsgDepositToTunnelResponse) XXX_Merge 

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

func (*MsgDepositToTunnelResponse) XXX_Size 

func (m *MsgDepositToTunnelResponse) XXX_Size() int

func (*MsgDepositToTunnelResponse) XXX_Unmarshal 

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

type MsgServer 

type MsgServer interface {
	// CreateTunnel is a RPC method to create a new tunnel.
	CreateTunnel(context.Context, *MsgCreateTunnel) (*MsgCreateTunnelResponse, error)
	// UpdateRoute is a RPC method to update a route information of the tunnel.
	UpdateRoute(context.Context, *MsgUpdateRoute) (*MsgUpdateRouteResponse, error)
	// UpdateSignalsAndInterval is a RPC method to update a signals and interval of the tunnel.
	UpdateSignalsAndInterval(context.Context, *MsgUpdateSignalsAndInterval) (*MsgUpdateSignalsAndIntervalResponse, error)
	// Activate is a RPC method to activate a tunnel.
	Activate(context.Context, *MsgActivate) (*MsgActivateResponse, error)
	// Deactivate is a RPC method to deactivate a tunnel.
	Deactivate(context.Context, *MsgDeactivate) (*MsgDeactivateResponse, error)
	// TriggerTunnel is a RPC method to manually trigger a tunnel.
	TriggerTunnel(context.Context, *MsgTriggerTunnel) (*MsgTriggerTunnelResponse, error)
	// DepositToTunnel is a RPC method to deposit to an existing tunnel.
	DepositToTunnel(context.Context, *MsgDepositToTunnel) (*MsgDepositToTunnelResponse, error)
	// WithdrawFromTunnel is a RPC method to withdraw a deposit from an existing tunnel.
	WithdrawFromTunnel(context.Context, *MsgWithdrawFromTunnel) (*MsgWithdrawFromTunnelResponse, error)
	// UpdateParams is a RPC method to update parameters
	UpdateParams(context.Context, *MsgUpdateParams) (*MsgUpdateParamsResponse, error)
}

MsgServer is the server API for Msg service.

type MsgTriggerTunnel 

type MsgTriggerTunnel struct {
	// tunnel_id is the ID of the tunnel to manually trigger.
	TunnelID uint64 `protobuf:"varint,1,opt,name=tunnel_id,json=tunnelId,proto3" json:"tunnel_id,omitempty"`
	// creator is the address of the creator.
	Creator string `protobuf:"bytes,2,opt,name=creator,proto3" json:"creator,omitempty"`
}

MsgTriggerTunnel is the transaction message to manually trigger a tunnel.

func NewMsgTriggerTunnel 

func NewMsgTriggerTunnel(
	tunnelID uint64,
	creator string,
) *MsgTriggerTunnel

NewMsgTriggerTunnel creates a new MsgTriggerTunnel instance.

func (*MsgTriggerTunnel) Descriptor 

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

func (*MsgTriggerTunnel) GetCreator 

func (m *MsgTriggerTunnel) GetCreator() string

func (*MsgTriggerTunnel) GetTunnelID 

func (m *MsgTriggerTunnel) GetTunnelID() uint64

func (*MsgTriggerTunnel) Marshal 

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

func (*MsgTriggerTunnel) MarshalTo 

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

func (*MsgTriggerTunnel) MarshalToSizedBuffer 

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

func (*MsgTriggerTunnel) ProtoMessage 

func (*MsgTriggerTunnel) ProtoMessage()

func (*MsgTriggerTunnel) Reset 

func (m *MsgTriggerTunnel) Reset()

func (*MsgTriggerTunnel) Size 

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

func (*MsgTriggerTunnel) String 

func (m *MsgTriggerTunnel) String() string

func (*MsgTriggerTunnel) Unmarshal 

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

func (MsgTriggerTunnel) ValidateBasic 

func (m MsgTriggerTunnel) ValidateBasic() error

ValidateBasic does a sanity check on the provided data

func (*MsgTriggerTunnel) XXX_DiscardUnknown 

func (m *MsgTriggerTunnel) XXX_DiscardUnknown()

func (*MsgTriggerTunnel) XXX_Marshal 

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

func (*MsgTriggerTunnel) XXX_Merge 

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

func (*MsgTriggerTunnel) XXX_Size 

func (m *MsgTriggerTunnel) XXX_Size() int

func (*MsgTriggerTunnel) XXX_Unmarshal 

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

type MsgTriggerTunnelResponse 

type MsgTriggerTunnelResponse struct {
}

MsgTriggerTunnelResponse is the response type for the Msg/TriggerTunnel RPC method.

func (*MsgTriggerTunnelResponse) Descriptor 

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

func (*MsgTriggerTunnelResponse) Marshal 

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

func (*MsgTriggerTunnelResponse) MarshalTo 

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

func (*MsgTriggerTunnelResponse) MarshalToSizedBuffer 

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

func (*MsgTriggerTunnelResponse) ProtoMessage 

func (*MsgTriggerTunnelResponse) ProtoMessage()

func (*MsgTriggerTunnelResponse) Reset 

func (m *MsgTriggerTunnelResponse) Reset()

func (*MsgTriggerTunnelResponse) Size 

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

func (*MsgTriggerTunnelResponse) String 

func (m *MsgTriggerTunnelResponse) String() string

func (*MsgTriggerTunnelResponse) Unmarshal 

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

func (*MsgTriggerTunnelResponse) XXX_DiscardUnknown 

func (m *MsgTriggerTunnelResponse) XXX_DiscardUnknown()

func (*MsgTriggerTunnelResponse) XXX_Marshal 

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

func (*MsgTriggerTunnelResponse) XXX_Merge 

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

func (*MsgTriggerTunnelResponse) XXX_Size 

func (m *MsgTriggerTunnelResponse) XXX_Size() int

func (*MsgTriggerTunnelResponse) XXX_Unmarshal 

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

type MsgUpdateParams 

type MsgUpdateParams struct {
	// authority is the address of the governance account.
	Authority string `protobuf:"bytes,1,opt,name=authority,proto3" json:"authority,omitempty"`
	// params is the x/tunnel parameters to update.
	Params Params `protobuf:"bytes,2,opt,name=params,proto3" json:"params"`
}

MsgUpdateParams is the transaction message to update parameters.

func NewMsgUpdateParams 

func NewMsgUpdateParams(
	authority string,
	params Params,
) *MsgUpdateParams

NewMsgUpdateParams creates a new MsgUpdateParams instance.

func (*MsgUpdateParams) Descriptor 

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

func (*MsgUpdateParams) GetAuthority 

func (m *MsgUpdateParams) GetAuthority() string

func (*MsgUpdateParams) GetParams 

func (m *MsgUpdateParams) GetParams() Params

func (*MsgUpdateParams) Marshal 

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

func (*MsgUpdateParams) MarshalTo 

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

func (*MsgUpdateParams) MarshalToSizedBuffer 

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

func (*MsgUpdateParams) ProtoMessage 

func (*MsgUpdateParams) ProtoMessage()

func (*MsgUpdateParams) Reset 

func (m *MsgUpdateParams) Reset()

func (*MsgUpdateParams) Size 

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

func (*MsgUpdateParams) String 

func (m *MsgUpdateParams) String() string

func (MsgUpdateParams) Type 

func (m MsgUpdateParams) Type() string

Type Implements Msg.

func (*MsgUpdateParams) Unmarshal 

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

func (*MsgUpdateParams) ValidateBasic 

func (m *MsgUpdateParams) ValidateBasic() error

ValidateBasic does a check on the provided data.

func (*MsgUpdateParams) XXX_DiscardUnknown 

func (m *MsgUpdateParams) XXX_DiscardUnknown()

func (*MsgUpdateParams) XXX_Marshal 

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

func (*MsgUpdateParams) XXX_Merge 

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

func (*MsgUpdateParams) XXX_Size 

func (m *MsgUpdateParams) XXX_Size() int

func (*MsgUpdateParams) XXX_Unmarshal 

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

type MsgUpdateParamsResponse 

type MsgUpdateParamsResponse struct {
}

MsgUpdateParamsResponse is the response type for the Msg/UpdateParams RPC method.

func (*MsgUpdateParamsResponse) Descriptor 

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

func (*MsgUpdateParamsResponse) Marshal 

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

func (*MsgUpdateParamsResponse) MarshalTo 

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

func (*MsgUpdateParamsResponse) MarshalToSizedBuffer 

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

func (*MsgUpdateParamsResponse) ProtoMessage 

func (*MsgUpdateParamsResponse) ProtoMessage()

func (*MsgUpdateParamsResponse) Reset 

func (m *MsgUpdateParamsResponse) Reset()

func (*MsgUpdateParamsResponse) Size 

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

func (*MsgUpdateParamsResponse) String 

func (m *MsgUpdateParamsResponse) String() string

func (*MsgUpdateParamsResponse) Unmarshal 

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

func (*MsgUpdateParamsResponse) XXX_DiscardUnknown 

func (m *MsgUpdateParamsResponse) XXX_DiscardUnknown()

func (*MsgUpdateParamsResponse) XXX_Marshal 

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

func (*MsgUpdateParamsResponse) XXX_Merge 

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

func (*MsgUpdateParamsResponse) XXX_Size 

func (m *MsgUpdateParamsResponse) XXX_Size() int

func (*MsgUpdateParamsResponse) XXX_Unmarshal 

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

type MsgUpdateRoute 

type MsgUpdateRoute struct {
	// tunnel_id is the ID of the tunnel to edit.
	TunnelID uint64 `protobuf:"varint,1,opt,name=tunnel_id,json=tunnelId,proto3" json:"tunnel_id,omitempty"`
	// route is the route for delivering the signal prices
	Route *types.Any `protobuf:"bytes,2,opt,name=route,proto3" json:"route,omitempty"`
	// creator is the address of the creator.
	Creator string `protobuf:"bytes,3,opt,name=creator,proto3" json:"creator,omitempty"`
}

MsgUpdateRoute is the transaction message to update a route information of the tunnel.

func NewMsgUpdateIBCRoute 

func NewMsgUpdateIBCRoute(
	tunnelID uint64,
	channelID string,
	creator string,
) (*MsgUpdateRoute, error)

NewMsgUpdateIBCRoute creates a new MsgUpdateRoute instance.

func NewMsgUpdateRoute 

func NewMsgUpdateRoute(
	tunnelID uint64,
	route RouteI,
	creator string,
) (*MsgUpdateRoute, error)

NewMsgUpdateRoute creates a new MsgUpdateRoute instance.

func (*MsgUpdateRoute) Descriptor 

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

func (*MsgUpdateRoute) GetCreator 

func (m *MsgUpdateRoute) GetCreator() string

func (*MsgUpdateRoute) GetRoute 

func (m *MsgUpdateRoute) GetRoute() *types.Any

func (MsgUpdateRoute) GetRouteValue 

func (m MsgUpdateRoute) GetRouteValue() (RouteI, error)

GetRouteValue returns the route of the message.

func (*MsgUpdateRoute) GetTunnelID 

func (m *MsgUpdateRoute) GetTunnelID() uint64

func (*MsgUpdateRoute) Marshal 

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

func (*MsgUpdateRoute) MarshalTo 

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

func (*MsgUpdateRoute) MarshalToSizedBuffer 

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

func (*MsgUpdateRoute) ProtoMessage 

func (*MsgUpdateRoute) ProtoMessage()

func (*MsgUpdateRoute) Reset 

func (m *MsgUpdateRoute) Reset()

func (*MsgUpdateRoute) Size 

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

func (*MsgUpdateRoute) String 

func (m *MsgUpdateRoute) String() string

func (*MsgUpdateRoute) Unmarshal 

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

func (MsgUpdateRoute) UnpackInterfaces 

func (m MsgUpdateRoute) UnpackInterfaces(unpacker types.AnyUnpacker) error

UnpackInterfaces implements UnpackInterfacesMessage.UnpackInterfaces

func (MsgUpdateRoute) ValidateBasic 

func (m MsgUpdateRoute) ValidateBasic() error

ValidateBasic does a sanity check on the provided data

func (*MsgUpdateRoute) XXX_DiscardUnknown 

func (m *MsgUpdateRoute) XXX_DiscardUnknown()

func (*MsgUpdateRoute) XXX_Marshal 

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

func (*MsgUpdateRoute) XXX_Merge 

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

func (*MsgUpdateRoute) XXX_Size 

func (m *MsgUpdateRoute) XXX_Size() int

func (*MsgUpdateRoute) XXX_Unmarshal 

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

type MsgUpdateRouteResponse 

type MsgUpdateRouteResponse struct {
}

MsgUpdateRouteResponse is the response type for the Msg/UpdateRoute RPC method.

func (*MsgUpdateRouteResponse) Descriptor 

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

func (*MsgUpdateRouteResponse) Marshal 

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

func (*MsgUpdateRouteResponse) MarshalTo 

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

func (*MsgUpdateRouteResponse) MarshalToSizedBuffer 

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

func (*MsgUpdateRouteResponse) ProtoMessage 

func (*MsgUpdateRouteResponse) ProtoMessage()

func (*MsgUpdateRouteResponse) Reset 

func (m *MsgUpdateRouteResponse) Reset()

func (*MsgUpdateRouteResponse) Size 

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

func (*MsgUpdateRouteResponse) String 

func (m *MsgUpdateRouteResponse) String() string

func (*MsgUpdateRouteResponse) Unmarshal 

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

func (*MsgUpdateRouteResponse) XXX_DiscardUnknown 

func (m *MsgUpdateRouteResponse) XXX_DiscardUnknown()

func (*MsgUpdateRouteResponse) XXX_Marshal 

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

func (*MsgUpdateRouteResponse) XXX_Merge 

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

func (*MsgUpdateRouteResponse) XXX_Size 

func (m *MsgUpdateRouteResponse) XXX_Size() int

func (*MsgUpdateRouteResponse) XXX_Unmarshal 

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

type MsgUpdateSignalsAndInterval 

type MsgUpdateSignalsAndInterval struct {
	// tunnel_id is the ID of the tunnel to edit.
	TunnelID uint64 `protobuf:"varint,1,opt,name=tunnel_id,json=tunnelId,proto3" json:"tunnel_id,omitempty"`
	// signal_deviations is the list of signal deviations.
	SignalDeviations []SignalDeviation `protobuf:"bytes,2,rep,name=signal_deviations,json=signalDeviations,proto3" json:"signal_deviations"`
	// interval is the interval for delivering the signal prices.
	Interval uint64 `protobuf:"varint,3,opt,name=interval,proto3" json:"interval,omitempty"`
	// creator is the address of the creator.
	Creator string `protobuf:"bytes,4,opt,name=creator,proto3" json:"creator,omitempty"`
}

MsgUpdateSignalsAndInterval is the transaction message to update signals and interval of the tunnel.

func NewMsgUpdateSignalsAndInterval 

func NewMsgUpdateSignalsAndInterval(
	tunnelID uint64,
	signalDeviations []SignalDeviation,
	interval uint64,
	creator string,
) *MsgUpdateSignalsAndInterval

NewMsgUpdateSignalsAndInterval creates a new MsgUpdateSignalsAndInterval instance.

func (*MsgUpdateSignalsAndInterval) Descriptor 

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

func (*MsgUpdateSignalsAndInterval) GetCreator 

func (m *MsgUpdateSignalsAndInterval) GetCreator() string

func (*MsgUpdateSignalsAndInterval) GetInterval 

func (m *MsgUpdateSignalsAndInterval) GetInterval() uint64

func (*MsgUpdateSignalsAndInterval) GetSignalDeviations 

func (m *MsgUpdateSignalsAndInterval) GetSignalDeviations() []SignalDeviation

func (*MsgUpdateSignalsAndInterval) GetTunnelID 

func (m *MsgUpdateSignalsAndInterval) GetTunnelID() uint64

func (*MsgUpdateSignalsAndInterval) Marshal 

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

func (*MsgUpdateSignalsAndInterval) MarshalTo 

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

func (*MsgUpdateSignalsAndInterval) MarshalToSizedBuffer 

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

func (*MsgUpdateSignalsAndInterval) ProtoMessage 

func (*MsgUpdateSignalsAndInterval) ProtoMessage()

func (*MsgUpdateSignalsAndInterval) Reset 

func (m *MsgUpdateSignalsAndInterval) Reset()

func (*MsgUpdateSignalsAndInterval) Size 

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

func (*MsgUpdateSignalsAndInterval) String 

func (m *MsgUpdateSignalsAndInterval) String() string

func (*MsgUpdateSignalsAndInterval) Unmarshal 

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

func (MsgUpdateSignalsAndInterval) ValidateBasic 

func (m MsgUpdateSignalsAndInterval) ValidateBasic() error

ValidateBasic does a sanity check on the provided data

func (*MsgUpdateSignalsAndInterval) XXX_DiscardUnknown 

func (m *MsgUpdateSignalsAndInterval) XXX_DiscardUnknown()

func (*MsgUpdateSignalsAndInterval) XXX_Marshal 

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

func (*MsgUpdateSignalsAndInterval) XXX_Merge 

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

func (*MsgUpdateSignalsAndInterval) XXX_Size 

func (m *MsgUpdateSignalsAndInterval) XXX_Size() int

func (*MsgUpdateSignalsAndInterval) XXX_Unmarshal 

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

type MsgUpdateSignalsAndIntervalResponse 

type MsgUpdateSignalsAndIntervalResponse struct {
}

MsgUpdateSignalsAndIntervalResponse is the response type for the Msg/UpdateSignalsAndInterval RPC method.

func (*MsgUpdateSignalsAndIntervalResponse) Descriptor 

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

func (*MsgUpdateSignalsAndIntervalResponse) Marshal 

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

func (*MsgUpdateSignalsAndIntervalResponse) MarshalTo 

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

func (*MsgUpdateSignalsAndIntervalResponse) MarshalToSizedBuffer 

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

func (*MsgUpdateSignalsAndIntervalResponse) ProtoMessage 

func (*MsgUpdateSignalsAndIntervalResponse) ProtoMessage()

func (*MsgUpdateSignalsAndIntervalResponse) Reset 

func (m *MsgUpdateSignalsAndIntervalResponse) Reset()

func (*MsgUpdateSignalsAndIntervalResponse) Size 

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

func (*MsgUpdateSignalsAndIntervalResponse) String 

func (m *MsgUpdateSignalsAndIntervalResponse) String() string

func (*MsgUpdateSignalsAndIntervalResponse) Unmarshal 

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

func (*MsgUpdateSignalsAndIntervalResponse) XXX_DiscardUnknown 

func (m *MsgUpdateSignalsAndIntervalResponse) XXX_DiscardUnknown()

func (*MsgUpdateSignalsAndIntervalResponse) XXX_Marshal 

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

func (*MsgUpdateSignalsAndIntervalResponse) XXX_Merge 

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

func (*MsgUpdateSignalsAndIntervalResponse) XXX_Size 

func (m *MsgUpdateSignalsAndIntervalResponse) XXX_Size() int

func (*MsgUpdateSignalsAndIntervalResponse) XXX_Unmarshal 

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

type MsgWithdrawFromTunnel 

type MsgWithdrawFromTunnel struct {
	// tunnel_id defines the unique id of the tunnel.
	TunnelID uint64 `protobuf:"varint,1,opt,name=tunnel_id,json=tunnelId,proto3" json:"tunnel_id,omitempty"`
	// amount to be withdrawn by withdrawer.
	Amount github_com_cosmos_cosmos_sdk_types.Coins `protobuf:"bytes,2,rep,name=amount,proto3,castrepeated=github.com/cosmos/cosmos-sdk/types.Coins" json:"amount"`
	// withdrawer defines the withdraw addresses from the tunnel.
	Withdrawer string `protobuf:"bytes,3,opt,name=withdrawer,proto3" json:"withdrawer,omitempty"`
}

MsgWithdrawFromTunnel is the transaction message to withdraw a deposit from an existing tunnel.

func NewMsgWithdrawFromTunnel 

func NewMsgWithdrawFromTunnel(
	tunnelID uint64,
	amount sdk.Coins,
	withdrawer string,
) *MsgWithdrawFromTunnel

NewMsgWithdrawFromTunnel creates a new MsgWithdrawFromTunnel instance.

func (*MsgWithdrawFromTunnel) Descriptor 

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

func (*MsgWithdrawFromTunnel) GetAmount 

func (m *MsgWithdrawFromTunnel) GetAmount() github_com_cosmos_cosmos_sdk_types.Coins

func (*MsgWithdrawFromTunnel) GetTunnelID 

func (m *MsgWithdrawFromTunnel) GetTunnelID() uint64

func (*MsgWithdrawFromTunnel) GetWithdrawer 

func (m *MsgWithdrawFromTunnel) GetWithdrawer() string

func (*MsgWithdrawFromTunnel) Marshal 

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

func (*MsgWithdrawFromTunnel) MarshalTo 

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

func (*MsgWithdrawFromTunnel) MarshalToSizedBuffer 

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

func (*MsgWithdrawFromTunnel) ProtoMessage 

func (*MsgWithdrawFromTunnel) ProtoMessage()

func (*MsgWithdrawFromTunnel) Reset 

func (m *MsgWithdrawFromTunnel) Reset()

func (*MsgWithdrawFromTunnel) Size 

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

func (*MsgWithdrawFromTunnel) String 

func (m *MsgWithdrawFromTunnel) String() string

func (*MsgWithdrawFromTunnel) Unmarshal 

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

func (MsgWithdrawFromTunnel) ValidateBasic 

func (m MsgWithdrawFromTunnel) ValidateBasic() error

ValidateBasic does a sanity check on the provided data

func (*MsgWithdrawFromTunnel) XXX_DiscardUnknown 

func (m *MsgWithdrawFromTunnel) XXX_DiscardUnknown()

func (*MsgWithdrawFromTunnel) XXX_Marshal 

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

func (*MsgWithdrawFromTunnel) XXX_Merge 

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

func (*MsgWithdrawFromTunnel) XXX_Size 

func (m *MsgWithdrawFromTunnel) XXX_Size() int

func (*MsgWithdrawFromTunnel) XXX_Unmarshal 

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

type MsgWithdrawFromTunnelResponse 

type MsgWithdrawFromTunnelResponse struct {
}

MsgWithdrawFromTunnelResponse defines the Msg/WithdrawFromTunnel response type.

func (*MsgWithdrawFromTunnelResponse) Descriptor 

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

func (*MsgWithdrawFromTunnelResponse) Marshal 

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

func (*MsgWithdrawFromTunnelResponse) MarshalTo 

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

func (*MsgWithdrawFromTunnelResponse) MarshalToSizedBuffer 

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

func (*MsgWithdrawFromTunnelResponse) ProtoMessage 

func (*MsgWithdrawFromTunnelResponse) ProtoMessage()

func (*MsgWithdrawFromTunnelResponse) Reset 

func (m *MsgWithdrawFromTunnelResponse) Reset()

func (*MsgWithdrawFromTunnelResponse) Size 

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

func (*MsgWithdrawFromTunnelResponse) String 

func (m *MsgWithdrawFromTunnelResponse) String() string

func (*MsgWithdrawFromTunnelResponse) Unmarshal 

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

func (*MsgWithdrawFromTunnelResponse) XXX_DiscardUnknown 

func (m *MsgWithdrawFromTunnelResponse) XXX_DiscardUnknown()

func (*MsgWithdrawFromTunnelResponse) XXX_Marshal 

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

func (*MsgWithdrawFromTunnelResponse) XXX_Merge 

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

func (*MsgWithdrawFromTunnelResponse) XXX_Size 

func (m *MsgWithdrawFromTunnelResponse) XXX_Size() int

func (*MsgWithdrawFromTunnelResponse) XXX_Unmarshal 

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

type Packet 

type Packet struct {
	// tunnel_id is the tunnel ID
	TunnelID uint64 `protobuf:"varint,1,opt,name=tunnel_id,json=tunnelId,proto3" json:"tunnel_id,omitempty"`
	// sequence is representing the sequence of the tunnel packet.
	Sequence uint64 `protobuf:"varint,2,opt,name=sequence,proto3" json:"sequence,omitempty"`
	// prices is the list of prices information from feeds module.
	Prices []types2.Price `protobuf:"bytes,3,rep,name=prices,proto3" json:"prices"`
	// receipt represents the confirmation of the packet delivery to the destination via the specified route.
	Receipt *types.Any `protobuf:"bytes,4,opt,name=receipt,proto3" json:"receipt,omitempty"`
	// base_fee is the base fee of the packet
	BaseFee github_com_cosmos_cosmos_sdk_types.Coins `` /* 126-byte string literal not displayed */
	// route_fee is the route fee of the packet
	RouteFee github_com_cosmos_cosmos_sdk_types.Coins `` /* 129-byte string literal not displayed */
	// created_at is the timestamp when the packet is created
	CreatedAt int64 `protobuf:"varint,7,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
}

Packet is the packet that tunnel produces

func NewPacket 

func NewPacket(
	tunnelID uint64,
	sequence uint64,
	prices []feedstypes.Price,
	baseFee sdk.Coins,
	routeFee sdk.Coins,
	createdAt int64,
) Packet

func (*Packet) Descriptor 

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

func (*Packet) Equal 

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

func (*Packet) GetBaseFee 

func (m *Packet) GetBaseFee() github_com_cosmos_cosmos_sdk_types.Coins

func (*Packet) GetCreatedAt 

func (m *Packet) GetCreatedAt() int64

func (*Packet) GetPrices 

func (m *Packet) GetPrices() []types2.Price

func (*Packet) GetReceipt 

func (m *Packet) GetReceipt() *types.Any

func (Packet) GetReceiptValue 

func (p Packet) GetReceiptValue() (PacketReceiptI, error)

GetReceiptValue returns the packet's receipt.

func (*Packet) GetRouteFee 

func (m *Packet) GetRouteFee() github_com_cosmos_cosmos_sdk_types.Coins

func (*Packet) GetSequence 

func (m *Packet) GetSequence() uint64

func (*Packet) GetTunnelID 

func (m *Packet) GetTunnelID() uint64

func (*Packet) Marshal 

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

func (*Packet) MarshalTo 

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

func (*Packet) MarshalToSizedBuffer 

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

func (*Packet) ProtoMessage 

func (*Packet) ProtoMessage()

func (*Packet) Reset 

func (m *Packet) Reset()

func (*Packet) SetReceipt 

func (p *Packet) SetReceipt(receipt PacketReceiptI) error

SetReceipt sets the packet's receipt.

func (*Packet) Size 

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

func (*Packet) String 

func (m *Packet) String() string

func (*Packet) Unmarshal 

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

func (Packet) UnpackInterfaces 

func (p Packet) UnpackInterfaces(unpacker types.AnyUnpacker) error

UnpackInterfaces implements UnpackInterfacesMessage.UnpackInterfaces

func (*Packet) XXX_DiscardUnknown 

func (m *Packet) XXX_DiscardUnknown()

func (*Packet) XXX_Marshal 

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

func (*Packet) XXX_Merge 

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

func (*Packet) XXX_Size 

func (m *Packet) XXX_Size() int

func (*Packet) XXX_Unmarshal 

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

type PacketReceiptI 

type PacketReceiptI interface {
	proto.Message
}

PacketReceiptI defines an interface for confirming the delivery of a packet to its destination via the specified route.

type Params 

type Params struct {
	// min_deposit is the minimum deposit required to create a tunnel.
	MinDeposit github_com_cosmos_cosmos_sdk_types.Coins `` /* 135-byte string literal not displayed */
	// min_interval is the minimum interval in seconds.
	MinInterval uint64 `protobuf:"varint,2,opt,name=min_interval,json=minInterval,proto3" json:"min_interval,omitempty"`
	// max_interval is the maximum interval in seconds.
	MaxInterval uint64 `protobuf:"varint,3,opt,name=max_interval,json=maxInterval,proto3" json:"max_interval,omitempty"`
	// min_deviation_bps is the minimum deviation in basis points.
	MinDeviationBPS uint64 `protobuf:"varint,4,opt,name=min_deviation_bps,json=minDeviationBps,proto3" json:"min_deviation_bps,omitempty"`
	// max_deviation_bps is the maximum deviation in basis points.
	MaxDeviationBPS uint64 `protobuf:"varint,5,opt,name=max_deviation_bps,json=maxDeviationBps,proto3" json:"max_deviation_bps,omitempty"`
	// max_signals defines the maximum number of signals allowed per tunnel.
	MaxSignals uint64 `protobuf:"varint,6,opt,name=max_signals,json=maxSignals,proto3" json:"max_signals,omitempty"`
	// base_packet_fee is the base fee for each packet.
	BasePacketFee github_com_cosmos_cosmos_sdk_types.Coins `` /* 146-byte string literal not displayed */
}

Params is the data structure that keeps the parameters of the module.

func DefaultParams 

func DefaultParams() Params

DefaultParams returns a default set of parameters

func NewParams 

func NewParams(
	minDeposit sdk.Coins,
	minInterval uint64,
	maxInterval uint64,
	minDeviationBPS uint64,
	maxDeviationBPS uint64,
	maxSignals uint64,
	basePacketFee sdk.Coins,
) Params

NewParams creates a new Params instance

func (*Params) Descriptor 

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

func (*Params) Equal 

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

func (*Params) GetBasePacketFee 

func (m *Params) GetBasePacketFee() github_com_cosmos_cosmos_sdk_types.Coins

func (*Params) GetMaxDeviationBPS 

func (m *Params) GetMaxDeviationBPS() uint64

func (*Params) GetMaxInterval 

func (m *Params) GetMaxInterval() uint64

func (*Params) GetMaxSignals 

func (m *Params) GetMaxSignals() uint64

func (*Params) GetMinDeposit 

func (m *Params) GetMinDeposit() github_com_cosmos_cosmos_sdk_types.Coins

func (*Params) GetMinDeviationBPS 

func (m *Params) GetMinDeviationBPS() uint64

func (*Params) GetMinInterval 

func (m *Params) GetMinInterval() uint64

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

Validate validates the set of params

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 PortKeeper 

type PortKeeper interface {
	BindPort(ctx sdk.Context, portID string) *capabilitytypes.Capability
}

type QueryClient 

type QueryClient interface {
	// Tunnels is a RPC method that returns all tunnels.
	Tunnels(ctx context.Context, in *QueryTunnelsRequest, opts ...grpc.CallOption) (*QueryTunnelsResponse, error)
	// Tunnel is a RPC method that returns a tunnel by its ID.
	Tunnel(ctx context.Context, in *QueryTunnelRequest, opts ...grpc.CallOption) (*QueryTunnelResponse, error)
	// Deposits queries all deposits of a single tunnel.
	Deposits(ctx context.Context, in *QueryDepositsRequest, opts ...grpc.CallOption) (*QueryDepositsResponse, error)
	// Deposit queries single deposit information based tunnelID, depositAddr.
	Deposit(ctx context.Context, in *QueryDepositRequest, opts ...grpc.CallOption) (*QueryDepositResponse, error)
	// Packets is a RPC method that returns all packets of a tunnel.
	Packets(ctx context.Context, in *QueryPacketsRequest, opts ...grpc.CallOption) (*QueryPacketsResponse, error)
	// Packet is a RPC method that returns a packet by its tunnel ID and sequence.
	Packet(ctx context.Context, in *QueryPacketRequest, opts ...grpc.CallOption) (*QueryPacketResponse, error)
	// TotalFees is a RPC method that returns the total fees collected by the tunnel
	TotalFees(ctx context.Context, in *QueryTotalFeesRequest, opts ...grpc.CallOption) (*QueryTotalFeesResponse, error)
	// Params is a RPC method that returns all parameters of the module.
	Params(ctx context.Context, in *QueryParamsRequest, opts ...grpc.CallOption) (*QueryParamsResponse, 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 QueryDepositRequest 

type QueryDepositRequest struct {
	// tunnel_id is the ID of the tunnel to query.
	TunnelId uint64 `protobuf:"varint,1,opt,name=tunnel_id,json=tunnelId,proto3" json:"tunnel_id,omitempty"`
	// depositor is the address of the depositor to query.
	Depositor string `protobuf:"bytes,2,opt,name=depositor,proto3" json:"depositor,omitempty"`
}

QueryDepositRequest is the request type for the Query/Deposit RPC method.

func (*QueryDepositRequest) Descriptor 

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

func (*QueryDepositRequest) GetDepositor 

func (m *QueryDepositRequest) GetDepositor() string

func (*QueryDepositRequest) GetTunnelId 

func (m *QueryDepositRequest) GetTunnelId() uint64

func (*QueryDepositRequest) Marshal 

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

func (*QueryDepositRequest) MarshalTo 

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

func (*QueryDepositRequest) MarshalToSizedBuffer 

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

func (*QueryDepositRequest) ProtoMessage 

func (*QueryDepositRequest) ProtoMessage()

func (*QueryDepositRequest) Reset 

func (m *QueryDepositRequest) Reset()

func (*QueryDepositRequest) Size 

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

func (*QueryDepositRequest) String 

func (m *QueryDepositRequest) String() string

func (*QueryDepositRequest) Unmarshal 

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

func (*QueryDepositRequest) XXX_DiscardUnknown 

func (m *QueryDepositRequest) XXX_DiscardUnknown()

func (*QueryDepositRequest) XXX_Marshal 

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

func (*QueryDepositRequest) XXX_Merge 

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

func (*QueryDepositRequest) XXX_Size 

func (m *QueryDepositRequest) XXX_Size() int

func (*QueryDepositRequest) XXX_Unmarshal 

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

type QueryDepositResponse 

type QueryDepositResponse struct {
	// deposit is the deposit with the given tunnel ID and depositor address.
	Deposit Deposit `protobuf:"bytes,1,opt,name=deposit,proto3" json:"deposit"`
}

QueryDepositResponse is the response type for the Query/Deposit RPC method.

func (*QueryDepositResponse) Descriptor 

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

func (*QueryDepositResponse) GetDeposit 

func (m *QueryDepositResponse) GetDeposit() Deposit

func (*QueryDepositResponse) Marshal 

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

func (*QueryDepositResponse) MarshalTo 

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

func (*QueryDepositResponse) MarshalToSizedBuffer 

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

func (*QueryDepositResponse) ProtoMessage 

func (*QueryDepositResponse) ProtoMessage()

func (*QueryDepositResponse) Reset 

func (m *QueryDepositResponse) Reset()

func (*QueryDepositResponse) Size 

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

func (*QueryDepositResponse) String 

func (m *QueryDepositResponse) String() string

func (*QueryDepositResponse) Unmarshal 

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

func (*QueryDepositResponse) XXX_DiscardUnknown 

func (m *QueryDepositResponse) XXX_DiscardUnknown()

func (*QueryDepositResponse) XXX_Marshal 

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

func (*QueryDepositResponse) XXX_Merge 

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

func (*QueryDepositResponse) XXX_Size 

func (m *QueryDepositResponse) XXX_Size() int

func (*QueryDepositResponse) XXX_Unmarshal 

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

type QueryDepositsRequest 

type QueryDepositsRequest struct {
	// tunnel_id is the ID of the tunnel to query deposits.
	TunnelId uint64 `protobuf:"varint,1,opt,name=tunnel_id,json=tunnelId,proto3" json:"tunnel_id,omitempty"`
	// pagination defines an optional pagination for the request.
	Pagination *query.PageRequest `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryDepositsRequest is the request type for the Query/Deposits RPC method.

func (*QueryDepositsRequest) Descriptor 

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

func (*QueryDepositsRequest) GetPagination 

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

func (*QueryDepositsRequest) GetTunnelId 

func (m *QueryDepositsRequest) GetTunnelId() uint64

func (*QueryDepositsRequest) Marshal 

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

func (*QueryDepositsRequest) MarshalTo 

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

func (*QueryDepositsRequest) MarshalToSizedBuffer 

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

func (*QueryDepositsRequest) ProtoMessage 

func (*QueryDepositsRequest) ProtoMessage()

func (*QueryDepositsRequest) Reset 

func (m *QueryDepositsRequest) Reset()

func (*QueryDepositsRequest) Size 

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

func (*QueryDepositsRequest) String 

func (m *QueryDepositsRequest) String() string

func (*QueryDepositsRequest) Unmarshal 

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

func (*QueryDepositsRequest) XXX_DiscardUnknown 

func (m *QueryDepositsRequest) XXX_DiscardUnknown()

func (*QueryDepositsRequest) XXX_Marshal 

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

func (*QueryDepositsRequest) XXX_Merge 

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

func (*QueryDepositsRequest) XXX_Size 

func (m *QueryDepositsRequest) XXX_Size() int

func (*QueryDepositsRequest) XXX_Unmarshal 

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

type QueryDepositsResponse 

type QueryDepositsResponse struct {
	// deposits is a list of deposits.
	Deposits []*Deposit `protobuf:"bytes,1,rep,name=deposits,proto3" json:"deposits,omitempty"`
	// pagination defines an optional pagination for the response.
	Pagination *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryDepositsResponse is the response type for the Query/Deposits RPC method.

func (*QueryDepositsResponse) Descriptor 

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

func (*QueryDepositsResponse) GetDeposits 

func (m *QueryDepositsResponse) GetDeposits() []*Deposit

func (*QueryDepositsResponse) GetPagination 

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

func (*QueryDepositsResponse) Marshal 

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

func (*QueryDepositsResponse) MarshalTo 

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

func (*QueryDepositsResponse) MarshalToSizedBuffer 

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

func (*QueryDepositsResponse) ProtoMessage 

func (*QueryDepositsResponse) ProtoMessage()

func (*QueryDepositsResponse) Reset 

func (m *QueryDepositsResponse) Reset()

func (*QueryDepositsResponse) Size 

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

func (*QueryDepositsResponse) String 

func (m *QueryDepositsResponse) String() string

func (*QueryDepositsResponse) Unmarshal 

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

func (*QueryDepositsResponse) XXX_DiscardUnknown 

func (m *QueryDepositsResponse) XXX_DiscardUnknown()

func (*QueryDepositsResponse) XXX_Marshal 

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

func (*QueryDepositsResponse) XXX_Merge 

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

func (*QueryDepositsResponse) XXX_Size 

func (m *QueryDepositsResponse) XXX_Size() int

func (*QueryDepositsResponse) XXX_Unmarshal 

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

type QueryPacketRequest 

type QueryPacketRequest struct {
	// tunnel_id is the ID of the tunnel to query packets.
	TunnelId uint64 `protobuf:"varint,1,opt,name=tunnel_id,json=tunnelId,proto3" json:"tunnel_id,omitempty"`
	// sequence is the sequence of the packet to query.
	Sequence uint64 `protobuf:"varint,2,opt,name=sequence,proto3" json:"sequence,omitempty"`
}

QueryPacketRequest is the request type for the Query/Packet RPC method.

func (*QueryPacketRequest) Descriptor 

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

func (*QueryPacketRequest) GetSequence 

func (m *QueryPacketRequest) GetSequence() uint64

func (*QueryPacketRequest) GetTunnelId 

func (m *QueryPacketRequest) GetTunnelId() uint64

func (*QueryPacketRequest) Marshal 

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

func (*QueryPacketRequest) MarshalTo 

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

func (*QueryPacketRequest) MarshalToSizedBuffer 

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

func (*QueryPacketRequest) ProtoMessage 

func (*QueryPacketRequest) ProtoMessage()

func (*QueryPacketRequest) Reset 

func (m *QueryPacketRequest) Reset()

func (*QueryPacketRequest) Size 

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

func (*QueryPacketRequest) String 

func (m *QueryPacketRequest) String() string

func (*QueryPacketRequest) Unmarshal 

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

func (*QueryPacketRequest) XXX_DiscardUnknown 

func (m *QueryPacketRequest) XXX_DiscardUnknown()

func (*QueryPacketRequest) XXX_Marshal 

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

func (*QueryPacketRequest) XXX_Merge 

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

func (*QueryPacketRequest) XXX_Size 

func (m *QueryPacketRequest) XXX_Size() int

func (*QueryPacketRequest) XXX_Unmarshal 

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

type QueryPacketResponse 

type QueryPacketResponse struct {
	// packet is the packet with the given tunnel ID and sequence.
	Packet *Packet `protobuf:"bytes,1,opt,name=packet,proto3" json:"packet,omitempty"`
}

QueryPacketResponse is the response type for the Query/Packet RPC method.

func (*QueryPacketResponse) Descriptor 

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

func (*QueryPacketResponse) GetPacket 

func (m *QueryPacketResponse) GetPacket() *Packet

func (*QueryPacketResponse) Marshal 

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

func (*QueryPacketResponse) MarshalTo 

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

func (*QueryPacketResponse) MarshalToSizedBuffer 

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

func (*QueryPacketResponse) ProtoMessage 

func (*QueryPacketResponse) ProtoMessage()

func (*QueryPacketResponse) Reset 

func (m *QueryPacketResponse) Reset()

func (*QueryPacketResponse) Size 

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

func (*QueryPacketResponse) String 

func (m *QueryPacketResponse) String() string

func (*QueryPacketResponse) Unmarshal 

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

func (*QueryPacketResponse) XXX_DiscardUnknown 

func (m *QueryPacketResponse) XXX_DiscardUnknown()

func (*QueryPacketResponse) XXX_Marshal 

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

func (*QueryPacketResponse) XXX_Merge 

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

func (*QueryPacketResponse) XXX_Size 

func (m *QueryPacketResponse) XXX_Size() int

func (*QueryPacketResponse) XXX_Unmarshal 

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

type QueryPacketsRequest 

type QueryPacketsRequest struct {
	// tunnel_id is the ID of the tunnel to query packets.
	TunnelId uint64 `protobuf:"varint,1,opt,name=tunnel_id,json=tunnelId,proto3" json:"tunnel_id,omitempty"`
	// pagination defines an optional pagination for the request.
	Pagination *query.PageRequest `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryPacketsRequest is the request type for the Query/Packets RPC method.

func (*QueryPacketsRequest) Descriptor 

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

func (*QueryPacketsRequest) GetPagination 

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

func (*QueryPacketsRequest) GetTunnelId 

func (m *QueryPacketsRequest) GetTunnelId() uint64

func (*QueryPacketsRequest) Marshal 

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

func (*QueryPacketsRequest) MarshalTo 

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

func (*QueryPacketsRequest) MarshalToSizedBuffer 

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

func (*QueryPacketsRequest) ProtoMessage 

func (*QueryPacketsRequest) ProtoMessage()

func (*QueryPacketsRequest) Reset 

func (m *QueryPacketsRequest) Reset()

func (*QueryPacketsRequest) Size 

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

func (*QueryPacketsRequest) String 

func (m *QueryPacketsRequest) String() string

func (*QueryPacketsRequest) Unmarshal 

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

func (*QueryPacketsRequest) XXX_DiscardUnknown 

func (m *QueryPacketsRequest) XXX_DiscardUnknown()

func (*QueryPacketsRequest) XXX_Marshal 

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

func (*QueryPacketsRequest) XXX_Merge 

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

func (*QueryPacketsRequest) XXX_Size 

func (m *QueryPacketsRequest) XXX_Size() int

func (*QueryPacketsRequest) XXX_Unmarshal 

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

type QueryPacketsResponse 

type QueryPacketsResponse struct {
	// packets is a list of packets.
	Packets []*Packet `protobuf:"bytes,1,rep,name=packets,proto3" json:"packets,omitempty"`
	// pagination defines an optional pagination for the response.
	Pagination *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryPacketsResponse is the response type for the Query/Packets RPC method.

func (*QueryPacketsResponse) Descriptor 

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

func (*QueryPacketsResponse) GetPackets 

func (m *QueryPacketsResponse) GetPackets() []*Packet

func (*QueryPacketsResponse) GetPagination 

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

func (*QueryPacketsResponse) Marshal 

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

func (*QueryPacketsResponse) MarshalTo 

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

func (*QueryPacketsResponse) MarshalToSizedBuffer 

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

func (*QueryPacketsResponse) ProtoMessage 

func (*QueryPacketsResponse) ProtoMessage()

func (*QueryPacketsResponse) Reset 

func (m *QueryPacketsResponse) Reset()

func (*QueryPacketsResponse) Size 

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

func (*QueryPacketsResponse) String 

func (m *QueryPacketsResponse) String() string

func (*QueryPacketsResponse) Unmarshal 

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

func (*QueryPacketsResponse) XXX_DiscardUnknown 

func (m *QueryPacketsResponse) XXX_DiscardUnknown()

func (*QueryPacketsResponse) XXX_Marshal 

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

func (*QueryPacketsResponse) XXX_Merge 

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

func (*QueryPacketsResponse) XXX_Size 

func (m *QueryPacketsResponse) XXX_Size() int

func (*QueryPacketsResponse) XXX_Unmarshal 

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

type QueryParamsRequest 

type QueryParamsRequest struct {
}

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

func (*QueryParamsRequest) Descriptor 

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

func (*QueryParamsRequest) Marshal 

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

func (*QueryParamsRequest) MarshalTo 

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

func (*QueryParamsRequest) MarshalToSizedBuffer 

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

func (*QueryParamsRequest) ProtoMessage 

func (*QueryParamsRequest) ProtoMessage()

func (*QueryParamsRequest) Reset 

func (m *QueryParamsRequest) Reset()

func (*QueryParamsRequest) Size 

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

func (*QueryParamsRequest) String 

func (m *QueryParamsRequest) String() string

func (*QueryParamsRequest) Unmarshal 

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

func (*QueryParamsRequest) XXX_DiscardUnknown 

func (m *QueryParamsRequest) XXX_DiscardUnknown()

func (*QueryParamsRequest) XXX_Marshal 

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

func (*QueryParamsRequest) XXX_Merge 

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

func (*QueryParamsRequest) XXX_Size 

func (m *QueryParamsRequest) XXX_Size() int

func (*QueryParamsRequest) XXX_Unmarshal 

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

type QueryParamsResponse 

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

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

func (*QueryParamsResponse) Descriptor 

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

func (*QueryParamsResponse) GetParams 

func (m *QueryParamsResponse) GetParams() Params

func (*QueryParamsResponse) Marshal 

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

func (*QueryParamsResponse) MarshalTo 

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

func (*QueryParamsResponse) MarshalToSizedBuffer 

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

func (*QueryParamsResponse) ProtoMessage 

func (*QueryParamsResponse) ProtoMessage()

func (*QueryParamsResponse) Reset 

func (m *QueryParamsResponse) Reset()

func (*QueryParamsResponse) Size 

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

func (*QueryParamsResponse) String 

func (m *QueryParamsResponse) String() string

func (*QueryParamsResponse) Unmarshal 

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

func (*QueryParamsResponse) XXX_DiscardUnknown 

func (m *QueryParamsResponse) XXX_DiscardUnknown()

func (*QueryParamsResponse) XXX_Marshal 

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

func (*QueryParamsResponse) XXX_Merge 

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

func (*QueryParamsResponse) XXX_Size 

func (m *QueryParamsResponse) XXX_Size() int

func (*QueryParamsResponse) XXX_Unmarshal 

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

type QueryServer 

type QueryServer interface {
	// Tunnels is a RPC method that returns all tunnels.
	Tunnels(context.Context, *QueryTunnelsRequest) (*QueryTunnelsResponse, error)
	// Tunnel is a RPC method that returns a tunnel by its ID.
	Tunnel(context.Context, *QueryTunnelRequest) (*QueryTunnelResponse, error)
	// Deposits queries all deposits of a single tunnel.
	Deposits(context.Context, *QueryDepositsRequest) (*QueryDepositsResponse, error)
	// Deposit queries single deposit information based tunnelID, depositAddr.
	Deposit(context.Context, *QueryDepositRequest) (*QueryDepositResponse, error)
	// Packets is a RPC method that returns all packets of a tunnel.
	Packets(context.Context, *QueryPacketsRequest) (*QueryPacketsResponse, error)
	// Packet is a RPC method that returns a packet by its tunnel ID and sequence.
	Packet(context.Context, *QueryPacketRequest) (*QueryPacketResponse, error)
	// TotalFees is a RPC method that returns the total fees collected by the tunnel
	TotalFees(context.Context, *QueryTotalFeesRequest) (*QueryTotalFeesResponse, error)
	// Params is a RPC method that returns all parameters of the module.
	Params(context.Context, *QueryParamsRequest) (*QueryParamsResponse, error)
}

QueryServer is the server API for Query service.

type QueryTotalFeesRequest 

type QueryTotalFeesRequest struct {
}

QueryTotalFeesRequest is the request type for the Query/TotalFees RPC method.

func (*QueryTotalFeesRequest) Descriptor 

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

func (*QueryTotalFeesRequest) Marshal 

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

func (*QueryTotalFeesRequest) MarshalTo 

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

func (*QueryTotalFeesRequest) MarshalToSizedBuffer 

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

func (*QueryTotalFeesRequest) ProtoMessage 

func (*QueryTotalFeesRequest) ProtoMessage()

func (*QueryTotalFeesRequest) Reset 

func (m *QueryTotalFeesRequest) Reset()

func (*QueryTotalFeesRequest) Size 

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

func (*QueryTotalFeesRequest) String 

func (m *QueryTotalFeesRequest) String() string

func (*QueryTotalFeesRequest) Unmarshal 

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

func (*QueryTotalFeesRequest) XXX_DiscardUnknown 

func (m *QueryTotalFeesRequest) XXX_DiscardUnknown()

func (*QueryTotalFeesRequest) XXX_Marshal 

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

func (*QueryTotalFeesRequest) XXX_Merge 

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

func (*QueryTotalFeesRequest) XXX_Size 

func (m *QueryTotalFeesRequest) XXX_Size() int

func (*QueryTotalFeesRequest) XXX_Unmarshal 

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

type QueryTotalFeesResponse 

type QueryTotalFeesResponse struct {
	// total_fees is the total fees collected by the tunnel.
	TotalFees TotalFees `protobuf:"bytes,1,opt,name=total_fees,json=totalFees,proto3" json:"total_fees"`
}

QueryTotalFeesResponse is the response type for the Query/TotalFees RPC method.

func (*QueryTotalFeesResponse) Descriptor 

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

func (*QueryTotalFeesResponse) GetTotalFees 

func (m *QueryTotalFeesResponse) GetTotalFees() TotalFees

func (*QueryTotalFeesResponse) Marshal 

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

func (*QueryTotalFeesResponse) MarshalTo 

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

func (*QueryTotalFeesResponse) MarshalToSizedBuffer 

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

func (*QueryTotalFeesResponse) ProtoMessage 

func (*QueryTotalFeesResponse) ProtoMessage()

func (*QueryTotalFeesResponse) Reset 

func (m *QueryTotalFeesResponse) Reset()

func (*QueryTotalFeesResponse) Size 

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

func (*QueryTotalFeesResponse) String 

func (m *QueryTotalFeesResponse) String() string

func (*QueryTotalFeesResponse) Unmarshal 

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

func (*QueryTotalFeesResponse) XXX_DiscardUnknown 

func (m *QueryTotalFeesResponse) XXX_DiscardUnknown()

func (*QueryTotalFeesResponse) XXX_Marshal 

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

func (*QueryTotalFeesResponse) XXX_Merge 

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

func (*QueryTotalFeesResponse) XXX_Size 

func (m *QueryTotalFeesResponse) XXX_Size() int

func (*QueryTotalFeesResponse) XXX_Unmarshal 

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

type QueryTunnelRequest 

type QueryTunnelRequest struct {
	// tunnel_id is the ID of the tunnel to query.
	TunnelId uint64 `protobuf:"varint,1,opt,name=tunnel_id,json=tunnelId,proto3" json:"tunnel_id,omitempty"`
}

QueryTunnelRequest is the request type for the Query/Tunnel RPC method.

func (*QueryTunnelRequest) Descriptor 

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

func (*QueryTunnelRequest) GetTunnelId 

func (m *QueryTunnelRequest) GetTunnelId() uint64

func (*QueryTunnelRequest) Marshal 

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

func (*QueryTunnelRequest) MarshalTo 

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

func (*QueryTunnelRequest) MarshalToSizedBuffer 

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

func (*QueryTunnelRequest) ProtoMessage 

func (*QueryTunnelRequest) ProtoMessage()

func (*QueryTunnelRequest) Reset 

func (m *QueryTunnelRequest) Reset()

func (*QueryTunnelRequest) Size 

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

func (*QueryTunnelRequest) String 

func (m *QueryTunnelRequest) String() string

func (*QueryTunnelRequest) Unmarshal 

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

func (*QueryTunnelRequest) XXX_DiscardUnknown 

func (m *QueryTunnelRequest) XXX_DiscardUnknown()

func (*QueryTunnelRequest) XXX_Marshal 

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

func (*QueryTunnelRequest) XXX_Merge 

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

func (*QueryTunnelRequest) XXX_Size 

func (m *QueryTunnelRequest) XXX_Size() int

func (*QueryTunnelRequest) XXX_Unmarshal 

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

type QueryTunnelResponse 

type QueryTunnelResponse struct {
	// tunnel is the tunnel with the given ID.
	Tunnel Tunnel `protobuf:"bytes,1,opt,name=tunnel,proto3" json:"tunnel"`
}

QueryTunnelResponse is the response type for the Query/Tunnel RPC method.

func (*QueryTunnelResponse) Descriptor 

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

func (*QueryTunnelResponse) GetTunnel 

func (m *QueryTunnelResponse) GetTunnel() Tunnel

func (*QueryTunnelResponse) Marshal 

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

func (*QueryTunnelResponse) MarshalTo 

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

func (*QueryTunnelResponse) MarshalToSizedBuffer 

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

func (*QueryTunnelResponse) ProtoMessage 

func (*QueryTunnelResponse) ProtoMessage()

func (*QueryTunnelResponse) Reset 

func (m *QueryTunnelResponse) Reset()

func (*QueryTunnelResponse) Size 

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

func (*QueryTunnelResponse) String 

func (m *QueryTunnelResponse) String() string

func (*QueryTunnelResponse) Unmarshal 

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

func (*QueryTunnelResponse) XXX_DiscardUnknown 

func (m *QueryTunnelResponse) XXX_DiscardUnknown()

func (*QueryTunnelResponse) XXX_Marshal 

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

func (*QueryTunnelResponse) XXX_Merge 

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

func (*QueryTunnelResponse) XXX_Size 

func (m *QueryTunnelResponse) XXX_Size() int

func (*QueryTunnelResponse) XXX_Unmarshal 

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

type QueryTunnelsRequest 

type QueryTunnelsRequest struct {
	// status_filter is a flag to filter tunnels by status.
	StatusFilter TunnelStatusFilter `` /* 142-byte string literal not displayed */
	// pagination defines an optional pagination for the request.
	Pagination *query.PageRequest `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryTunnelsRequest is the request type for the Query/Tunnels RPC method.

func (*QueryTunnelsRequest) Descriptor 

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

func (*QueryTunnelsRequest) GetPagination 

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

func (*QueryTunnelsRequest) GetStatusFilter 

func (m *QueryTunnelsRequest) GetStatusFilter() TunnelStatusFilter

func (*QueryTunnelsRequest) Marshal 

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

func (*QueryTunnelsRequest) MarshalTo 

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

func (*QueryTunnelsRequest) MarshalToSizedBuffer 

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

func (*QueryTunnelsRequest) ProtoMessage 

func (*QueryTunnelsRequest) ProtoMessage()

func (*QueryTunnelsRequest) Reset 

func (m *QueryTunnelsRequest) Reset()

func (*QueryTunnelsRequest) Size 

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

func (*QueryTunnelsRequest) String 

func (m *QueryTunnelsRequest) String() string

func (*QueryTunnelsRequest) Unmarshal 

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

func (*QueryTunnelsRequest) XXX_DiscardUnknown 

func (m *QueryTunnelsRequest) XXX_DiscardUnknown()

func (*QueryTunnelsRequest) XXX_Marshal 

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

func (*QueryTunnelsRequest) XXX_Merge 

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

func (*QueryTunnelsRequest) XXX_Size 

func (m *QueryTunnelsRequest) XXX_Size() int

func (*QueryTunnelsRequest) XXX_Unmarshal 

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

type QueryTunnelsResponse 

type QueryTunnelsResponse struct {
	// Tunnels is a list of tunnels.
	Tunnels []*Tunnel `protobuf:"bytes,1,rep,name=tunnels,proto3" json:"tunnels,omitempty"`
	// pagination defines an optional pagination for the response.
	Pagination *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryTunnelsResponse is the response type for the Query/Tunnels RPC method.

func (*QueryTunnelsResponse) Descriptor 

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

func (*QueryTunnelsResponse) GetPagination 

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

func (*QueryTunnelsResponse) GetTunnels 

func (m *QueryTunnelsResponse) GetTunnels() []*Tunnel

func (*QueryTunnelsResponse) Marshal 

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

func (*QueryTunnelsResponse) MarshalTo 

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

func (*QueryTunnelsResponse) MarshalToSizedBuffer 

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

func (*QueryTunnelsResponse) ProtoMessage 

func (*QueryTunnelsResponse) ProtoMessage()

func (*QueryTunnelsResponse) Reset 

func (m *QueryTunnelsResponse) Reset()

func (*QueryTunnelsResponse) Size 

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

func (*QueryTunnelsResponse) String 

func (m *QueryTunnelsResponse) String() string

func (*QueryTunnelsResponse) Unmarshal 

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

func (*QueryTunnelsResponse) XXX_DiscardUnknown 

func (m *QueryTunnelsResponse) XXX_DiscardUnknown()

func (*QueryTunnelsResponse) XXX_Marshal 

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

func (*QueryTunnelsResponse) XXX_Merge 

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

func (*QueryTunnelsResponse) XXX_Size 

func (m *QueryTunnelsResponse) XXX_Size() int

func (*QueryTunnelsResponse) XXX_Unmarshal 

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

type RouteI 

type RouteI interface {
	proto.Message

	ValidateBasic() error
}

RouteI defines a routing path to deliver data to the destination.

type ScopedKeeper 

type ScopedKeeper interface {
	GetCapability(ctx sdk.Context, name string) (*capabilitytypes.Capability, bool)
	AuthenticateCapability(ctx sdk.Context, cap *capabilitytypes.Capability, name string) bool
	ClaimCapability(ctx sdk.Context, cap *capabilitytypes.Capability, name string) error
}

type SignalDeviation 

type SignalDeviation struct {
	// signal_id is the signal ID
	SignalID string `protobuf:"bytes,1,opt,name=signal_id,json=signalId,proto3" json:"signal_id,omitempty"`
	// soft_deviation_bps is the soft deviation in basis points
	SoftDeviationBPS uint64 `protobuf:"varint,2,opt,name=soft_deviation_bps,json=softDeviationBps,proto3" json:"soft_deviation_bps,omitempty"`
	// hard_deviation_bps is the hard deviation in basis points
	HardDeviationBPS uint64 `protobuf:"varint,3,opt,name=hard_deviation_bps,json=hardDeviationBps,proto3" json:"hard_deviation_bps,omitempty"`
}

SignalDeviation is the type for a signal with soft and hard deviation

func NewSignalDeviation 

func NewSignalDeviation(
	signalID string,
	softDeviationBPS uint64,
	hardDeviationBPS uint64,
) SignalDeviation

NewSignalDeviation creates a new SignalDeviation instance.

func (*SignalDeviation) Descriptor 

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

func (*SignalDeviation) Equal 

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

func (*SignalDeviation) GetHardDeviationBPS 

func (m *SignalDeviation) GetHardDeviationBPS() uint64

func (*SignalDeviation) GetSignalID 

func (m *SignalDeviation) GetSignalID() string

func (*SignalDeviation) GetSoftDeviationBPS 

func (m *SignalDeviation) GetSoftDeviationBPS() uint64

func (*SignalDeviation) Marshal 

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

func (*SignalDeviation) MarshalTo 

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

func (*SignalDeviation) MarshalToSizedBuffer 

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

func (*SignalDeviation) ProtoMessage 

func (*SignalDeviation) ProtoMessage()

func (*SignalDeviation) Reset 

func (m *SignalDeviation) Reset()

func (*SignalDeviation) Size 

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

func (*SignalDeviation) String 

func (m *SignalDeviation) String() string

func (*SignalDeviation) Unmarshal 

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

func (*SignalDeviation) XXX_DiscardUnknown 

func (m *SignalDeviation) XXX_DiscardUnknown()

func (*SignalDeviation) XXX_Marshal 

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

func (*SignalDeviation) XXX_Merge 

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

func (*SignalDeviation) XXX_Size 

func (m *SignalDeviation) XXX_Size() int

func (*SignalDeviation) XXX_Unmarshal 

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

type TSSPacket 

type TSSPacket struct {
	Sequence    uint64
	RelayPrices []feedstypes.RelayPrice
	CreatedAt   int64
}

TSSPacket represents the Packet that will be used for encoding a tss message.

func NewTSSPacket 

func NewTSSPacket(
	sequence uint64,
	relayPrices []feedstypes.RelayPrice,
	createdAt int64,
) TSSPacket

NewTSSPacket returns a new TssPacket object

type TSSPacketReceipt 

type TSSPacketReceipt struct {
	// signing_id is the signing ID
	SigningID github_com_bandprotocol_chain_v3_x_bandtss_types.SigningID `` /* 157-byte string literal not displayed */
}

TSSPacketReceipt represents a receipt for a TSS packet and implements the PacketReceiptI interface.

func NewTSSPacketReceipt 

func NewTSSPacketReceipt(signingID bandtsstypes.SigningID) *TSSPacketReceipt

NewTSSPacketReceipt creates a new TSSPacketReceipt instance.

func (*TSSPacketReceipt) Descriptor 

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

func (*TSSPacketReceipt) Equal 

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

func (*TSSPacketReceipt) GetSigningID 

func (m *TSSPacketReceipt) GetSigningID() github_com_bandprotocol_chain_v3_x_bandtss_types.SigningID

func (*TSSPacketReceipt) Marshal 

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

func (*TSSPacketReceipt) MarshalTo 

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

func (*TSSPacketReceipt) MarshalToSizedBuffer 

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

func (*TSSPacketReceipt) ProtoMessage 

func (*TSSPacketReceipt) ProtoMessage()

func (*TSSPacketReceipt) Reset 

func (m *TSSPacketReceipt) Reset()

func (*TSSPacketReceipt) Size 

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

func (*TSSPacketReceipt) String 

func (m *TSSPacketReceipt) String() string

func (*TSSPacketReceipt) Unmarshal 

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

func (*TSSPacketReceipt) XXX_DiscardUnknown 

func (m *TSSPacketReceipt) XXX_DiscardUnknown()

func (*TSSPacketReceipt) XXX_Marshal 

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

func (*TSSPacketReceipt) XXX_Merge 

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

func (*TSSPacketReceipt) XXX_Size 

func (m *TSSPacketReceipt) XXX_Size() int

func (*TSSPacketReceipt) XXX_Unmarshal 

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

type TSSRoute 

type TSSRoute struct {
	// destination_chain_id is the destination chain ID
	DestinationChainID string `protobuf:"bytes,1,opt,name=destination_chain_id,json=destinationChainId,proto3" json:"destination_chain_id,omitempty"`
	// destination_contract_address is the destination contract address
	DestinationContractAddress string `` /* 141-byte string literal not displayed */
	// encoder is the mode of encoding packet data.
	Encoder types.Encoder `protobuf:"varint,3,opt,name=encoder,proto3,enum=band.feeds.v1beta1.Encoder" json:"encoder,omitempty"`
}

TSSRoute represents a route for TSS packets and implements the RouteI interface.

func NewTSSRoute 

func NewTSSRoute(
	destinationChainID string,
	destinationContractAddress string,
	encoder feedstypes.Encoder,
) TSSRoute

NewTSSRoute return a new TSSRoute instance.

func (*TSSRoute) Descriptor 

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

func (*TSSRoute) Equal 

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

func (*TSSRoute) GetDestinationChainID 

func (m *TSSRoute) GetDestinationChainID() string

func (*TSSRoute) GetDestinationContractAddress 

func (m *TSSRoute) GetDestinationContractAddress() string

func (*TSSRoute) GetEncoder 

func (m *TSSRoute) GetEncoder() types.Encoder

func (*TSSRoute) Marshal 

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

func (*TSSRoute) MarshalTo 

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

func (*TSSRoute) MarshalToSizedBuffer 

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

func (*TSSRoute) ProtoMessage 

func (*TSSRoute) ProtoMessage()

func (*TSSRoute) Reset 

func (m *TSSRoute) Reset()

func (*TSSRoute) Size 

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

func (*TSSRoute) String 

func (m *TSSRoute) String() string

func (*TSSRoute) Unmarshal 

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

func (*TSSRoute) ValidateBasic 

func (r *TSSRoute) ValidateBasic() error

ValidateBasic performs basic validation of the TSSRoute fields.

func (*TSSRoute) XXX_DiscardUnknown 

func (m *TSSRoute) XXX_DiscardUnknown()

func (*TSSRoute) XXX_Marshal 

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

func (*TSSRoute) XXX_Merge 

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

func (*TSSRoute) XXX_Size 

func (m *TSSRoute) XXX_Size() int

func (*TSSRoute) XXX_Unmarshal 

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

type TotalFees 

type TotalFees struct {
	// total_base_packet_fee is the total base packet fee collected by the tunnel
	TotalBasePacketFee github_com_cosmos_cosmos_sdk_types.Coins `` /* 163-byte string literal not displayed */
}

TotalFees is the type for the total fees collected by the tunnel

func (*TotalFees) Descriptor 

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

func (*TotalFees) Equal 

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

func (*TotalFees) GetTotalBasePacketFee 

func (m *TotalFees) GetTotalBasePacketFee() github_com_cosmos_cosmos_sdk_types.Coins

func (*TotalFees) Marshal 

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

func (*TotalFees) MarshalTo 

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

func (*TotalFees) MarshalToSizedBuffer 

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

func (*TotalFees) ProtoMessage 

func (*TotalFees) ProtoMessage()

func (*TotalFees) Reset 

func (m *TotalFees) Reset()

func (*TotalFees) Size 

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

func (*TotalFees) String 

func (m *TotalFees) String() string

func (TotalFees) Total 

func (tf TotalFees) Total() sdk.Coins

Total returns the total fees

func (*TotalFees) Unmarshal 

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

func (TotalFees) Validate 

func (tf TotalFees) Validate() error

Validate validates the total fees

func (*TotalFees) XXX_DiscardUnknown 

func (m *TotalFees) XXX_DiscardUnknown()

func (*TotalFees) XXX_Marshal 

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

func (*TotalFees) XXX_Merge 

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

func (*TotalFees) XXX_Size 

func (m *TotalFees) XXX_Size() int

func (*TotalFees) XXX_Unmarshal 

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

type Tunnel 

type Tunnel struct {
	// id is the tunnel ID
	ID uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// sequence is representing the sequence of the tunnel packet.
	Sequence uint64 `protobuf:"varint,2,opt,name=sequence,proto3" json:"sequence,omitempty"`
	// route is the route for delivering the signal prices
	Route *types.Any `protobuf:"bytes,3,opt,name=route,proto3" json:"route,omitempty"`
	// fee_payer is the address of the fee payer
	FeePayer string `protobuf:"bytes,4,opt,name=fee_payer,json=feePayer,proto3" json:"fee_payer,omitempty"`
	// signal_deviations is the list of signal deviations
	SignalDeviations []SignalDeviation `protobuf:"bytes,5,rep,name=signal_deviations,json=signalDeviations,proto3" json:"signal_deviations"`
	// interval is the interval for delivering the signal prices
	Interval uint64 `protobuf:"varint,6,opt,name=interval,proto3" json:"interval,omitempty"`
	// total_deposit is the total deposit on the tunnel.
	TotalDeposit github_com_cosmos_cosmos_sdk_types.Coins `` /* 141-byte string literal not displayed */
	// is_active is the flag to indicate if the tunnel is active
	IsActive bool `protobuf:"varint,8,opt,name=is_active,json=isActive,proto3" json:"is_active,omitempty"`
	// created_at is the timestamp when the tunnel is created
	CreatedAt int64 `protobuf:"varint,9,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// creator is the address of the creator
	Creator string `protobuf:"bytes,10,opt,name=creator,proto3" json:"creator,omitempty"`
}

Tunnel contains the information of the tunnel that is created by the user

func NewTunnel 

func NewTunnel(
	id uint64,
	sequence uint64,
	route RouteI,
	feePayer string,
	signalDeviations []SignalDeviation,
	interval uint64,
	totalDeposit []sdk.Coin,
	isActive bool,
	createdAt int64,
	creator string,
) (Tunnel, error)

NewTunnel creates a new Tunnel instance.

func (*Tunnel) Descriptor 

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

func (*Tunnel) Equal 

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

func (*Tunnel) GetCreatedAt 

func (m *Tunnel) GetCreatedAt() int64

func (*Tunnel) GetCreator 

func (m *Tunnel) GetCreator() string

func (*Tunnel) GetFeePayer 

func (m *Tunnel) GetFeePayer() string

func (*Tunnel) GetID 

func (m *Tunnel) GetID() uint64

func (*Tunnel) GetInterval 

func (m *Tunnel) GetInterval() uint64

func (*Tunnel) GetIsActive 

func (m *Tunnel) GetIsActive() bool

func (*Tunnel) GetRoute 

func (m *Tunnel) GetRoute() *types.Any

func (Tunnel) GetRouteValue 

func (t Tunnel) GetRouteValue() (RouteI, error)

GetRouteValue returns the route value of the tunnel.

func (*Tunnel) GetSequence 

func (m *Tunnel) GetSequence() uint64

func (Tunnel) GetSignalDeviationMap 

func (t Tunnel) GetSignalDeviationMap() map[string]SignalDeviation

GetSignalDeviationMap returns the signal deviation map of the tunnel.

func (*Tunnel) GetSignalDeviations 

func (m *Tunnel) GetSignalDeviations() []SignalDeviation

func (Tunnel) GetSignalIDs 

func (t Tunnel) GetSignalIDs() []string

GetSignalIDs returns the signal IDs of the tunnel.

func (*Tunnel) GetTotalDeposit 

func (m *Tunnel) GetTotalDeposit() github_com_cosmos_cosmos_sdk_types.Coins

func (*Tunnel) Marshal 

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

func (*Tunnel) MarshalTo 

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

func (*Tunnel) MarshalToSizedBuffer 

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

func (*Tunnel) ProtoMessage 

func (*Tunnel) ProtoMessage()

func (*Tunnel) Reset 

func (m *Tunnel) Reset()

func (*Tunnel) SetRoute 

func (t *Tunnel) SetRoute(route RouteI) error

SetRoute sets the route of the tunnel.

func (*Tunnel) Size 

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

func (*Tunnel) String 

func (m *Tunnel) String() string

func (*Tunnel) Unmarshal 

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

func (Tunnel) UnpackInterfaces 

func (t Tunnel) UnpackInterfaces(unpacker types.AnyUnpacker) error

UnpackInterfaces implements UnpackInterfacesMessage.UnpackInterfaces

func (*Tunnel) XXX_DiscardUnknown 

func (m *Tunnel) XXX_DiscardUnknown()

func (*Tunnel) XXX_Marshal 

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

func (*Tunnel) XXX_Merge 

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

func (*Tunnel) XXX_Size 

func (m *Tunnel) XXX_Size() int

func (*Tunnel) XXX_Unmarshal 

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

type TunnelPricesPacketData 

type TunnelPricesPacketData struct {
	// tunnel_id is the tunnel ID
	TunnelID uint64 `protobuf:"varint,1,opt,name=tunnel_id,json=tunnelId,proto3" json:"tunnel_id,omitempty"`
	// sequence is representing the sequence of the tunnel packet.
	Sequence uint64 `protobuf:"varint,2,opt,name=sequence,proto3" json:"sequence,omitempty"`
	// prices is the list of prices information from feeds module.
	Prices []types.Price `protobuf:"bytes,3,rep,name=prices,proto3" json:"prices"`
	// created_at is the timestamp when the packet is created
	CreatedAt int64 `protobuf:"varint,4,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
}

TunnelPricesPacketData represents the IBC packet payload for the tunnel packet.

func NewTunnelPricesPacketData 

func NewTunnelPricesPacketData(
	tunnelID uint64,
	sequence uint64,
	prices []feedstypes.Price,
	createdAt int64,
) TunnelPricesPacketData

NewTunnelPricesPacketData creates a new TunnelPricesPacketData instance.

func (*TunnelPricesPacketData) Descriptor 

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

func (*TunnelPricesPacketData) Equal 

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

func (TunnelPricesPacketData) GetBytes 

func (p TunnelPricesPacketData) GetBytes() []byte

GetBytes is a helper for serialising

func (*TunnelPricesPacketData) GetCreatedAt 

func (m *TunnelPricesPacketData) GetCreatedAt() int64

func (*TunnelPricesPacketData) GetPrices 

func (m *TunnelPricesPacketData) GetPrices() []types.Price

func (*TunnelPricesPacketData) GetSequence 

func (m *TunnelPricesPacketData) GetSequence() uint64

func (*TunnelPricesPacketData) GetTunnelID 

func (m *TunnelPricesPacketData) GetTunnelID() uint64

func (*TunnelPricesPacketData) Marshal 

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

func (*TunnelPricesPacketData) MarshalTo 

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

func (*TunnelPricesPacketData) MarshalToSizedBuffer 

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

func (*TunnelPricesPacketData) ProtoMessage 

func (*TunnelPricesPacketData) ProtoMessage()

func (*TunnelPricesPacketData) Reset 

func (m *TunnelPricesPacketData) Reset()

func (*TunnelPricesPacketData) Size 

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

func (*TunnelPricesPacketData) String 

func (m *TunnelPricesPacketData) String() string

func (*TunnelPricesPacketData) Unmarshal 

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

func (*TunnelPricesPacketData) XXX_DiscardUnknown 

func (m *TunnelPricesPacketData) XXX_DiscardUnknown()

func (*TunnelPricesPacketData) XXX_Marshal 

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

func (*TunnelPricesPacketData) XXX_Merge 

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

func (*TunnelPricesPacketData) XXX_Size 

func (m *TunnelPricesPacketData) XXX_Size() int

func (*TunnelPricesPacketData) XXX_Unmarshal 

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

type TunnelSignatureOrder 

type TunnelSignatureOrder struct {
	// sequence is the sequence of the packet
	Sequence uint64 `protobuf:"varint,1,opt,name=sequence,proto3" json:"sequence,omitempty"`
	// prices is the list of prices information from feeds module.
	Prices []types2.Price `protobuf:"bytes,2,rep,name=prices,proto3" json:"prices"`
	// created_at is the timestamp when the packet is created
	CreatedAt int64 `protobuf:"varint,3,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// encoder is the mode of encoding data.
	Encoder types2.Encoder `protobuf:"varint,4,opt,name=encoder,proto3,enum=band.feeds.v1beta1.Encoder" json:"encoder,omitempty"`
}

TunnelSignatureOrder defines a general signature order for sending signature to tss group.

func NewTunnelSignatureOrder 

func NewTunnelSignatureOrder(
	sequence uint64,
	prices []feedstypes.Price,
	createdAt int64,
	encoder feedstypes.Encoder,
) *TunnelSignatureOrder

NewTunnelSignatureOrder returns a new TunnelSignatureOrder object

func (*TunnelSignatureOrder) Descriptor 

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

func (*TunnelSignatureOrder) Equal 

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

func (*TunnelSignatureOrder) IsInternal 

func (ts *TunnelSignatureOrder) IsInternal() bool

IsInternal returns true for TunnelSignatureOrder (internal module-based request signature).

func (*TunnelSignatureOrder) Marshal 

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

func (*TunnelSignatureOrder) MarshalTo 

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

func (*TunnelSignatureOrder) MarshalToSizedBuffer 

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

func (*TunnelSignatureOrder) OrderRoute 

func (ts *TunnelSignatureOrder) OrderRoute() string

OrderRoute returns the order router key

func (*TunnelSignatureOrder) OrderType 

func (ts *TunnelSignatureOrder) OrderType() string

OrderType returns type of signature order that should be "tunnel"

func (*TunnelSignatureOrder) ProtoMessage 

func (*TunnelSignatureOrder) ProtoMessage()

func (*TunnelSignatureOrder) Reset 

func (m *TunnelSignatureOrder) Reset()

func (*TunnelSignatureOrder) Size 

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

func (*TunnelSignatureOrder) String 

func (m *TunnelSignatureOrder) String() string

func (*TunnelSignatureOrder) Unmarshal 

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

func (*TunnelSignatureOrder) ValidateBasic 

func (ts *TunnelSignatureOrder) ValidateBasic() error

ValidateBasic validates the request's title and description of the request signature

func (*TunnelSignatureOrder) XXX_DiscardUnknown 

func (m *TunnelSignatureOrder) XXX_DiscardUnknown()

func (*TunnelSignatureOrder) XXX_Marshal 

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

func (*TunnelSignatureOrder) XXX_Merge 

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

func (*TunnelSignatureOrder) XXX_Size 

func (m *TunnelSignatureOrder) XXX_Size() int

func (*TunnelSignatureOrder) XXX_Unmarshal 

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

type TunnelStatusFilter 

type TunnelStatusFilter int32

TunnelStatusFilter defines a filter for tunnel status. 

const (
	// TUNNEL_STATUS_FILTER_UNSPECIFIED defines an unspecified status.
	TUNNEL_STATUS_FILTER_UNSPECIFIED TunnelStatusFilter = 0
	// TUNNEL_STATUS_FILTER_ACTIVE defines an active tunnel.
	TUNNEL_STATUS_FILTER_ACTIVE TunnelStatusFilter = 1
	// TUNNEL_STATUS_FILTER_INACTIVE defines an inactive tunnel.
	TUNNEL_STATUS_FILTER_INACTIVE TunnelStatusFilter = 2
)

func (TunnelStatusFilter) EnumDescriptor 

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

func (TunnelStatusFilter) String 

func (x TunnelStatusFilter) String() string

type UnimplementedMsgServer 

type UnimplementedMsgServer struct {
}

UnimplementedMsgServer can be embedded to have forward compatible implementations.

func (*UnimplementedMsgServer) Activate 

func (*UnimplementedMsgServer) Activate(ctx context.Context, req *MsgActivate) (*MsgActivateResponse, error)

func (*UnimplementedMsgServer) CreateTunnel 

func (*UnimplementedMsgServer) CreateTunnel(ctx context.Context, req *MsgCreateTunnel) (*MsgCreateTunnelResponse, error)

func (*UnimplementedMsgServer) Deactivate 

func (*UnimplementedMsgServer) Deactivate(ctx context.Context, req *MsgDeactivate) (*MsgDeactivateResponse, error)

func (*UnimplementedMsgServer) DepositToTunnel 

func (*UnimplementedMsgServer) DepositToTunnel(ctx context.Context, req *MsgDepositToTunnel) (*MsgDepositToTunnelResponse, error)

func (*UnimplementedMsgServer) TriggerTunnel 

func (*UnimplementedMsgServer) TriggerTunnel(ctx context.Context, req *MsgTriggerTunnel) (*MsgTriggerTunnelResponse, error)

func (*UnimplementedMsgServer) UpdateParams 

func (*UnimplementedMsgServer) UpdateParams(ctx context.Context, req *MsgUpdateParams) (*MsgUpdateParamsResponse, error)

func (*UnimplementedMsgServer) UpdateRoute 

func (*UnimplementedMsgServer) UpdateRoute(ctx context.Context, req *MsgUpdateRoute) (*MsgUpdateRouteResponse, error)

func (*UnimplementedMsgServer) UpdateSignalsAndInterval 

func (*UnimplementedMsgServer) UpdateSignalsAndInterval(ctx context.Context, req *MsgUpdateSignalsAndInterval) (*MsgUpdateSignalsAndIntervalResponse, error)

func (*UnimplementedMsgServer) WithdrawFromTunnel 

func (*UnimplementedMsgServer) WithdrawFromTunnel(ctx context.Context, req *MsgWithdrawFromTunnel) (*MsgWithdrawFromTunnelResponse, error)

type UnimplementedQueryServer 

type UnimplementedQueryServer struct {
}

UnimplementedQueryServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryServer) Deposit 

func (*UnimplementedQueryServer) Deposit(ctx context.Context, req *QueryDepositRequest) (*QueryDepositResponse, error)

func (*UnimplementedQueryServer) Deposits 

func (*UnimplementedQueryServer) Deposits(ctx context.Context, req *QueryDepositsRequest) (*QueryDepositsResponse, error)

func (*UnimplementedQueryServer) Packet 

func (*UnimplementedQueryServer) Packet(ctx context.Context, req *QueryPacketRequest) (*QueryPacketResponse, error)

func (*UnimplementedQueryServer) Packets 

func (*UnimplementedQueryServer) Packets(ctx context.Context, req *QueryPacketsRequest) (*QueryPacketsResponse, error)

func (*UnimplementedQueryServer) Params 

func (*UnimplementedQueryServer) Params(ctx context.Context, req *QueryParamsRequest) (*QueryParamsResponse, error)

func (*UnimplementedQueryServer) TotalFees 

func (*UnimplementedQueryServer) TotalFees(ctx context.Context, req *QueryTotalFeesRequest) (*QueryTotalFeesResponse, error)

func (*UnimplementedQueryServer) Tunnel 

func (*UnimplementedQueryServer) Tunnel(ctx context.Context, req *QueryTunnelRequest) (*QueryTunnelResponse, error)

func (*UnimplementedQueryServer) Tunnels 

func (*UnimplementedQueryServer) Tunnels(ctx context.Context, req *QueryTunnelsRequest) (*QueryTunnelsResponse, 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.