types

package
v24.0.1 Latest Latest
Warning

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

 Go to latest Published: Apr 9, 2024 License: Apache-2.0 Imports: 33 Imported by: 0

Documentation

Overview

Package types is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

View Source 
const (
	DefaultBitcoinChainName     = "bitcoin"
	DefaultBitcoinDenomName     = "btc"
	DefaultBitcoinConfirmations = 6
	DefaultBitcoinExponent      = 10 // TODO: decide
	DefaultVotesNeeded          = 1

	DefaultOsmosisChainName = "osmosis"
)
View Source 
const (
	// ModuleName defines the module name
	ModuleName = "bridge"

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

	// RouterKey is the message route for slashing
	RouterKey = ModuleName

	// QuerierRoute defines the module's query routing key
	QuerierRoute = ModuleName
)

Variables

View Source 
var (
	ErrInvalidLengthBridge        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowBridge          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupBridge = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidAsset          = errorsmod.Register(ModuleName, 2, "invalid asset")
	ErrInvalidAssets         = errorsmod.Register(ModuleName, 3, "invalid assets")
	ErrInvalidAssetStatus    = errorsmod.Register(ModuleName, 4, "invalid asset status")
	ErrInvalidParams         = errorsmod.Register(ModuleName, 5, "invalid params")
	ErrInvalidDenom          = errorsmod.Register(ModuleName, 6, "invalid denom")
	ErrInvalidSourceChain    = errorsmod.Register(ModuleName, 7, "invalid source chain")
	ErrInvalidSigners        = errorsmod.Register(ModuleName, 8, "invalid signers")
	ErrCantChangeAssetStatus = errorsmod.Register(ModuleName, 9, "can't change asset status")
	ErrCantCreateAsset       = errorsmod.Register(ModuleName, 10, "can't create asset")
	ErrTokenfactory          = errorsmod.Register(ModuleName, 11, "tokenfactory error")
	ErrInvalidAssetID        = errorsmod.Register(ModuleName, 12, "invalid asset id")
	ErrInvalidFee            = errorsmod.Register(ModuleName, 13, "invalid fee")
	ErrInvalidExternalID     = errorsmod.Register(ModuleName, 14, "invalid external id")
)

x/bridge module sentinel errors

View Source 
var (
	ErrInvalidLengthEvents        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowEvents          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupEvents = fmt.Errorf("proto: unexpected end of group")
)
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 (
	InboundTransfersKey   = []byte{0x01}
	FinalizedTransfersKey = []byte{0x02}
	LastHeightsKey        = []byte{0x03}

	KeySeparator = "|"
)
View Source 
var (
	KeySigners     = []byte("Signers")
	KeyAssets      = []byte("Assets")
	KeyVotesNeeded = []byte("VotesNeeded")
	KeyFee         = []byte("Fee")
)
View Source 
var (
	ErrInvalidLengthQuery        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowQuery          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupQuery = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthTx        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTx          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupTx = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var AssetStatus_name = map[int32]string{
	0: "ASSET_STATUS_UNSPECIFIED",
	1: "ASSET_STATUS_OK",
	2: "ASSET_STATUS_BLOCKED_INBOUND",
	3: "ASSET_STATUS_BLOCKED_OUTBOUND",
	4: "ASSET_STATUS_BLOCKED_BOTH",
}
View Source 
var AssetStatus_value = map[string]int32{
	"ASSET_STATUS_UNSPECIFIED":      0,
	"ASSET_STATUS_OK":               1,
	"ASSET_STATUS_BLOCKED_INBOUND":  2,
	"ASSET_STATUS_BLOCKED_OUTBOUND": 3,
	"ASSET_STATUS_BLOCKED_BOTH":     4,
}
View Source 
var (
	ModuleCdc = codec.NewAminoCodec(amino)
)

Functions

func FinalizedTransferKey 

func FinalizedTransferKey(externalID string) []byte

FinalizedTransferKey returns the store prefix key where all the data associated with a specific InboundTransfer is stored

func InboundTransferKey 

func InboundTransferKey(externalID string, externalHeight uint64) []byte

InboundTransferKey returns the store prefix key where all the data associated with a specific InboundTransfer is stored

func LastHeightKey 

func LastHeightKey(assetID AssetID) []byte

LastHeightKey returns the store prefix key where all the data associated with a specific InboundTransfer is stored

func Map 

func Map[E, V any](s []E, f func(E) V) []V

Map returns a slice that contains the result of applying function f to every element of the slice s. TODO: Placed here temporarily. Delete after releasing the new osmoutils version.

func ParamKeyTable 

func ParamKeyTable() paramtypes.KeyTable

ParamKeyTable for the x/bridge module.

func RegisterInterfaces 

func RegisterInterfaces(registry cdctypes.InterfaceRegistry)

func RegisterLegacyAminoCodec 

func RegisterLegacyAminoCodec(cdc *codec.LegacyAmino)

func RegisterMsgServer 

func RegisterMsgServer(s grpc1.Server, srv MsgServer)

func RegisterQueryHandler 

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

RegisterQueryHandler registers the http handlers for service Query to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterQueryHandlerClient 

func RegisterQueryHandlerClient(ctx context.Context, mux *runtime.ServeMux, client QueryClient) error

RegisterQueryHandlerClient registers the http handlers for service Query to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "QueryClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "QueryClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "QueryClient" to call the correct interceptors.

func RegisterQueryHandlerFromEndpoint 

func RegisterQueryHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterQueryHandlerFromEndpoint is same as RegisterQueryHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterQueryHandlerServer 

func RegisterQueryHandlerServer(ctx context.Context, mux *runtime.ServeMux, server QueryServer) error

RegisterQueryHandlerServer registers the http handlers for service Query to "mux". UnaryRPC :call QueryServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterQueryHandlerFromEndpoint instead.

func RegisterQueryServer 

func RegisterQueryServer(s grpc1.Server, srv QueryServer)

Types

type AccountKeeper 

type AccountKeeper interface {
	// GetModuleAddress is used to get the module account
	// to use it as the admin for denoms in x/tokenfactory.
	GetModuleAddress(name string) sdk.AccAddress
}

type Asset 

type Asset struct {
	// ID is the asset's primary key
	Id AssetID `protobuf:"bytes,1,opt,name=id,proto3" json:"id" yaml:"id"`
	// Status is a current status of the asset
	Status AssetStatus `protobuf:"varint,2,opt,name=status,proto3,enum=osmosis.bridge.v1beta1.AssetStatus" json:"status,omitempty" yaml:"status"`
	// Exponent represents the power of 10 used for coin representation
	Exponent uint64 `protobuf:"varint,3,opt,name=exponent,proto3" json:"exponent,omitempty" yaml:"exponent"`
	// ExternalConfirmations is a number of the confirmations on the external
	// chain needed to consider the transfer confirmed
	ExternalConfirmations uint64 `` /* 155-byte string literal not displayed */
}

Asset is a representation of the asset.

func DefaultAssets 

func DefaultAssets() []Asset

func (*Asset) Descriptor 

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

func (*Asset) GetExponent 

func (m *Asset) GetExponent() uint64

func (*Asset) GetExternalConfirmations 

func (m *Asset) GetExternalConfirmations() uint64

func (*Asset) GetId 

func (m *Asset) GetId() AssetID

func (*Asset) GetStatus 

func (m *Asset) GetStatus() AssetStatus

func (*Asset) Marshal 

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

func (*Asset) MarshalTo 

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

func (*Asset) MarshalToSizedBuffer 

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

func (Asset) Name 

func (m Asset) Name() string

func (*Asset) ProtoMessage 

func (*Asset) ProtoMessage()

func (*Asset) Reset 

func (m *Asset) Reset()

func (*Asset) Size 

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

func (*Asset) String 

func (m *Asset) String() string

func (*Asset) Unmarshal 

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

func (Asset) Validate 

func (m Asset) Validate() error

func (*Asset) XXX_DiscardUnknown 

func (m *Asset) XXX_DiscardUnknown()

func (*Asset) XXX_Marshal 

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

func (*Asset) XXX_Merge 

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

func (*Asset) XXX_Size 

func (m *Asset) XXX_Size() int

func (*Asset) XXX_Unmarshal 

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

type AssetID 

type AssetID struct {
	// SourceChain is a source chain name
	SourceChain string `protobuf:"bytes,1,opt,name=source_chain,json=sourceChain,proto3" json:"source_chain,omitempty" yaml:"source_chain"`
	// Denom is the Osmosis representation of the SourceChain
	Denom string `protobuf:"bytes,2,opt,name=denom,proto3" json:"denom,omitempty" yaml:"denom"`
}

AssetID defines a pair of the source chain name and its Osmosis representation denoted by denom. AssetID is a primary key for Asset.

func (*AssetID) Descriptor 

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

func (*AssetID) GetDenom 

func (m *AssetID) GetDenom() string

func (*AssetID) GetSourceChain 

func (m *AssetID) GetSourceChain() string

func (*AssetID) Marshal 

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

func (*AssetID) MarshalTo 

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

func (*AssetID) MarshalToSizedBuffer 

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

func (AssetID) Name 

func (m AssetID) Name() string

func (*AssetID) ProtoMessage 

func (*AssetID) ProtoMessage()

func (*AssetID) Reset 

func (m *AssetID) Reset()

func (*AssetID) Size 

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

func (*AssetID) String 

func (m *AssetID) String() string

func (*AssetID) Unmarshal 

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

func (AssetID) Validate 

func (m AssetID) Validate() error

func (*AssetID) XXX_DiscardUnknown 

func (m *AssetID) XXX_DiscardUnknown()

func (*AssetID) XXX_Marshal 

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

func (*AssetID) XXX_Merge 

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

func (*AssetID) XXX_Size 

func (m *AssetID) XXX_Size() int

func (*AssetID) XXX_Unmarshal 

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

type AssetStatus 

type AssetStatus int32
const (
	AssetStatus_ASSET_STATUS_UNSPECIFIED      AssetStatus = 0
	AssetStatus_ASSET_STATUS_OK               AssetStatus = 1
	AssetStatus_ASSET_STATUS_BLOCKED_INBOUND  AssetStatus = 2
	AssetStatus_ASSET_STATUS_BLOCKED_OUTBOUND AssetStatus = 3
	AssetStatus_ASSET_STATUS_BLOCKED_BOTH     AssetStatus = 4
)

func (AssetStatus) EnumDescriptor 

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

func (AssetStatus) InboundActive 

func (m AssetStatus) InboundActive() bool

func (AssetStatus) OutboundActive 

func (m AssetStatus) OutboundActive() bool

func (AssetStatus) String 

func (x AssetStatus) String() string

func (AssetStatus) Validate 

func (m AssetStatus) Validate() error

type EventChangeAssetStatus 

type EventChangeAssetStatus struct {
	Sender    string      `protobuf:"bytes,1,opt,name=sender,proto3" json:"sender,omitempty"`
	AssetId   AssetID     `protobuf:"bytes,2,opt,name=asset_id,json=assetId,proto3" json:"asset_id"`
	OldStatus AssetStatus `` /* 129-byte string literal not displayed */
	NewStatus AssetStatus `` /* 129-byte string literal not displayed */
}

func (*EventChangeAssetStatus) Descriptor 

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

func (*EventChangeAssetStatus) GetAssetId 

func (m *EventChangeAssetStatus) GetAssetId() AssetID

func (*EventChangeAssetStatus) GetNewStatus 

func (m *EventChangeAssetStatus) GetNewStatus() AssetStatus

func (*EventChangeAssetStatus) GetOldStatus 

func (m *EventChangeAssetStatus) GetOldStatus() AssetStatus

func (*EventChangeAssetStatus) GetSender 

func (m *EventChangeAssetStatus) GetSender() string

func (*EventChangeAssetStatus) Marshal 

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

func (*EventChangeAssetStatus) MarshalTo 

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

func (*EventChangeAssetStatus) MarshalToSizedBuffer 

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

func (*EventChangeAssetStatus) ProtoMessage 

func (*EventChangeAssetStatus) ProtoMessage()

func (*EventChangeAssetStatus) Reset 

func (m *EventChangeAssetStatus) Reset()

func (*EventChangeAssetStatus) Size 

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

func (*EventChangeAssetStatus) String 

func (m *EventChangeAssetStatus) String() string

func (*EventChangeAssetStatus) Unmarshal 

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

func (*EventChangeAssetStatus) XXX_DiscardUnknown 

func (m *EventChangeAssetStatus) XXX_DiscardUnknown()

func (*EventChangeAssetStatus) XXX_Marshal 

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

func (*EventChangeAssetStatus) XXX_Merge 

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

func (*EventChangeAssetStatus) XXX_Size 

func (m *EventChangeAssetStatus) XXX_Size() int

func (*EventChangeAssetStatus) XXX_Unmarshal 

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

type EventInboundTransfer 

type EventInboundTransfer struct {
	// Sender is a sender's address
	Sender string `protobuf:"bytes,1,opt,name=sender,proto3" json:"sender,omitempty"`
	// DestAddr is a destination Osmosis address
	DestAddr string `protobuf:"bytes,2,opt,name=dest_addr,json=destAddr,proto3" json:"dest_addr,omitempty"`
	// AssetID is the ID of the asset being transferred
	AssetId AssetID `protobuf:"bytes,3,opt,name=asset_id,json=assetId,proto3" json:"asset_id"`
	// Amount of coins to transfer
	Amount cosmossdk_io_math.Int `protobuf:"bytes,4,opt,name=amount,proto3,customtype=cosmossdk.io/math.Int" json:"amount"`
}

func (*EventInboundTransfer) Descriptor 

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

func (*EventInboundTransfer) GetAssetId 

func (m *EventInboundTransfer) GetAssetId() AssetID

func (*EventInboundTransfer) GetDestAddr 

func (m *EventInboundTransfer) GetDestAddr() string

func (*EventInboundTransfer) GetSender 

func (m *EventInboundTransfer) GetSender() string

func (*EventInboundTransfer) Marshal 

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

func (*EventInboundTransfer) MarshalTo 

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

func (*EventInboundTransfer) MarshalToSizedBuffer 

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

func (*EventInboundTransfer) ProtoMessage 

func (*EventInboundTransfer) ProtoMessage()

func (*EventInboundTransfer) Reset 

func (m *EventInboundTransfer) Reset()

func (*EventInboundTransfer) Size 

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

func (*EventInboundTransfer) String 

func (m *EventInboundTransfer) String() string

func (*EventInboundTransfer) Unmarshal 

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

func (*EventInboundTransfer) XXX_DiscardUnknown 

func (m *EventInboundTransfer) XXX_DiscardUnknown()

func (*EventInboundTransfer) XXX_Marshal 

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

func (*EventInboundTransfer) XXX_Merge 

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

func (*EventInboundTransfer) XXX_Size 

func (m *EventInboundTransfer) XXX_Size() int

func (*EventInboundTransfer) XXX_Unmarshal 

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

type EventOutboundTransfer 

type EventOutboundTransfer struct {
	// Sender is a sender's address
	Sender string `protobuf:"bytes,1,opt,name=sender,proto3" json:"sender,omitempty"`
	// DestAddr is a destination Osmosis address
	DestAddr string `protobuf:"bytes,2,opt,name=dest_addr,json=destAddr,proto3" json:"dest_addr,omitempty"`
	// AssetID is the ID of the asset being transferred
	AssetId AssetID `protobuf:"bytes,3,opt,name=asset_id,json=assetId,proto3" json:"asset_id"`
	// Amount of coins to transfer
	Amount cosmossdk_io_math.Int `protobuf:"bytes,4,opt,name=amount,proto3,customtype=cosmossdk.io/math.Int" json:"amount"`
}

func (*EventOutboundTransfer) Descriptor 

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

func (*EventOutboundTransfer) GetAssetId 

func (m *EventOutboundTransfer) GetAssetId() AssetID

func (*EventOutboundTransfer) GetDestAddr 

func (m *EventOutboundTransfer) GetDestAddr() string

func (*EventOutboundTransfer) GetSender 

func (m *EventOutboundTransfer) GetSender() string

func (*EventOutboundTransfer) Marshal 

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

func (*EventOutboundTransfer) MarshalTo 

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

func (*EventOutboundTransfer) MarshalToSizedBuffer 

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

func (*EventOutboundTransfer) ProtoMessage 

func (*EventOutboundTransfer) ProtoMessage()

func (*EventOutboundTransfer) Reset 

func (m *EventOutboundTransfer) Reset()

func (*EventOutboundTransfer) Size 

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

func (*EventOutboundTransfer) String 

func (m *EventOutboundTransfer) String() string

func (*EventOutboundTransfer) Unmarshal 

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

func (*EventOutboundTransfer) XXX_DiscardUnknown 

func (m *EventOutboundTransfer) XXX_DiscardUnknown()

func (*EventOutboundTransfer) XXX_Marshal 

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

func (*EventOutboundTransfer) XXX_Merge 

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

func (*EventOutboundTransfer) XXX_Size 

func (m *EventOutboundTransfer) XXX_Size() int

func (*EventOutboundTransfer) XXX_Unmarshal 

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

type EventUpdateParams 

type EventUpdateParams struct {
	NewSigners     []string                    `protobuf:"bytes,1,rep,name=new_signers,json=newSigners,proto3" json:"new_signers,omitempty"`
	CreatedSigners []string                    `protobuf:"bytes,2,rep,name=created_signers,json=createdSigners,proto3" json:"created_signers,omitempty"`
	DeletedSigners []string                    `protobuf:"bytes,3,rep,name=deleted_signers,json=deletedSigners,proto3" json:"deleted_signers,omitempty"`
	NewAssets      []Asset                     `protobuf:"bytes,4,rep,name=new_assets,json=newAssets,proto3" json:"new_assets"`
	CreatedAssets  []Asset                     `protobuf:"bytes,5,rep,name=created_assets,json=createdAssets,proto3" json:"created_assets"`
	DeletedAssets  []Asset                     `protobuf:"bytes,6,rep,name=deleted_assets,json=deletedAssets,proto3" json:"deleted_assets"`
	NewVotesNeeded uint64                      `protobuf:"varint,7,opt,name=new_votes_needed,json=newVotesNeeded,proto3" json:"new_votes_needed,omitempty"`
	NewFee         cosmossdk_io_math.LegacyDec `protobuf:"bytes,8,opt,name=new_fee,json=newFee,proto3,customtype=cosmossdk.io/math.LegacyDec" json:"new_fee"`
}

func (*EventUpdateParams) Descriptor 

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

func (*EventUpdateParams) GetCreatedAssets 

func (m *EventUpdateParams) GetCreatedAssets() []Asset

func (*EventUpdateParams) GetCreatedSigners 

func (m *EventUpdateParams) GetCreatedSigners() []string

func (*EventUpdateParams) GetDeletedAssets 

func (m *EventUpdateParams) GetDeletedAssets() []Asset

func (*EventUpdateParams) GetDeletedSigners 

func (m *EventUpdateParams) GetDeletedSigners() []string

func (*EventUpdateParams) GetNewAssets 

func (m *EventUpdateParams) GetNewAssets() []Asset

func (*EventUpdateParams) GetNewSigners 

func (m *EventUpdateParams) GetNewSigners() []string

func (*EventUpdateParams) GetNewVotesNeeded 

func (m *EventUpdateParams) GetNewVotesNeeded() uint64

func (*EventUpdateParams) Marshal 

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

func (*EventUpdateParams) MarshalTo 

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

func (*EventUpdateParams) MarshalToSizedBuffer 

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

func (*EventUpdateParams) ProtoMessage 

func (*EventUpdateParams) ProtoMessage()

func (*EventUpdateParams) Reset 

func (m *EventUpdateParams) Reset()

func (*EventUpdateParams) Size 

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

func (*EventUpdateParams) String 

func (m *EventUpdateParams) String() string

func (*EventUpdateParams) Unmarshal 

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

func (*EventUpdateParams) XXX_DiscardUnknown 

func (m *EventUpdateParams) XXX_DiscardUnknown()

func (*EventUpdateParams) XXX_Marshal 

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

func (*EventUpdateParams) XXX_Merge 

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

func (*EventUpdateParams) XXX_Size 

func (m *EventUpdateParams) XXX_Size() int

func (*EventUpdateParams) XXX_Unmarshal 

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

type GenesisState 

type GenesisState struct {
	// Params defines params for x/bridge module.
	Params Params `protobuf:"bytes,1,opt,name=params,proto3" json:"params"`
}

GenesisState defines the mint module's genesis state.

func DefaultGenesis 

func DefaultGenesis() *GenesisState

DefaultGenesis returns the default Capability genesis state

func (*GenesisState) Descriptor 

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

func (*GenesisState) GetParams 

func (m *GenesisState) GetParams() Params

func (*GenesisState) Marshal 

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

func (*GenesisState) MarshalTo 

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

func (*GenesisState) MarshalToSizedBuffer 

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

func (*GenesisState) ProtoMessage 

func (*GenesisState) ProtoMessage()

func (*GenesisState) Reset 

func (m *GenesisState) Reset()

func (*GenesisState) Size 

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

func (*GenesisState) String 

func (m *GenesisState) String() string

func (*GenesisState) Unmarshal 

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

func (GenesisState) Validate 

func (gs GenesisState) Validate() error

Validate performs basic genesis state validation returning an error upon any failure.

func (*GenesisState) XXX_DiscardUnknown 

func (m *GenesisState) XXX_DiscardUnknown()

func (*GenesisState) XXX_Marshal 

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

func (*GenesisState) XXX_Merge 

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

func (*GenesisState) XXX_Size 

func (m *GenesisState) XXX_Size() int

func (*GenesisState) XXX_Unmarshal 

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

type InboundTransfer 

type InboundTransfer struct {
	// ExternalId is a unique ID of the transfer coming from outside.
	// Serves the purpose of uniquely identifying the transfer in another chain
	// (e.g., this might be the BTC tx hash).
	ExternalId string `protobuf:"bytes,1,opt,name=external_id,json=externalId,proto3" json:"external_id,omitempty" yaml:"external_id"`
	// ExternalHeight is the height at which the transfer occurred in the external
	// chain
	ExternalHeight uint64 `` /* 127-byte string literal not displayed */
	// DestAddr is a destination Osmosis address
	DestAddr string `protobuf:"bytes,3,opt,name=dest_addr,json=destAddr,proto3" json:"dest_addr,omitempty" yaml:"dest_addr"`
	// AssetID is the ID of the asset being transferred
	AssetId AssetID `protobuf:"bytes,4,opt,name=asset_id,json=assetId,proto3" json:"asset_id" yaml:"asset_id"`
	// Amount of coins to transfer
	Amount cosmossdk_io_math.Int `protobuf:"bytes,5,opt,name=amount,proto3,customtype=cosmossdk.io/math.Int" json:"amount" yaml:"amount"`
	// Voters is a list of validators signed this transfer
	Voters []string `protobuf:"bytes,6,rep,name=voters,proto3" json:"voters,omitempty" yaml:"voters"`
	// Finalized indicates whether the transfer needs more votes or has
	// already accumulated a sufficient number. The finalised flag is set
	// to true as soon as length(voters) is greater than or equal to
	// the module's param votes_needed.
	Finalized bool `protobuf:"varint,7,opt,name=finalized,proto3" json:"finalized,omitempty" yaml:"finalized"`
}

InboundTransfer is a representation of the inbound transfer.

func NewInboundTransfer 

func NewInboundTransfer(
	externalID string,
	externalHeight uint64,
	destAddr string,
	assetID AssetID,
	amount math.Int,
) InboundTransfer

func (*InboundTransfer) Descriptor 

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

func (*InboundTransfer) GetAssetId 

func (m *InboundTransfer) GetAssetId() AssetID

func (*InboundTransfer) GetDestAddr 

func (m *InboundTransfer) GetDestAddr() string

func (*InboundTransfer) GetExternalHeight 

func (m *InboundTransfer) GetExternalHeight() uint64

func (*InboundTransfer) GetExternalId 

func (m *InboundTransfer) GetExternalId() string

func (*InboundTransfer) GetFinalized 

func (m *InboundTransfer) GetFinalized() bool

func (*InboundTransfer) GetVoters 

func (m *InboundTransfer) GetVoters() []string

func (*InboundTransfer) Marshal 

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

func (*InboundTransfer) MarshalTo 

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

func (*InboundTransfer) MarshalToSizedBuffer 

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

func (*InboundTransfer) ProtoMessage 

func (*InboundTransfer) ProtoMessage()

func (*InboundTransfer) Reset 

func (m *InboundTransfer) Reset()

func (*InboundTransfer) Size 

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

func (*InboundTransfer) String 

func (m *InboundTransfer) String() string

func (*InboundTransfer) Unmarshal 

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

func (*InboundTransfer) XXX_DiscardUnknown 

func (m *InboundTransfer) XXX_DiscardUnknown()

func (*InboundTransfer) XXX_Marshal 

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

func (*InboundTransfer) XXX_Merge 

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

func (*InboundTransfer) XXX_Size 

func (m *InboundTransfer) XXX_Size() int

func (*InboundTransfer) XXX_Unmarshal 

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

type LastTransferHeightRequest 

type LastTransferHeightRequest struct {
	AssetId AssetID `protobuf:"bytes,1,opt,name=asset_id,json=assetId,proto3" json:"asset_id" yaml:"asset_id"`
}

LastTransferHeightRequest is the request type for the Query/LastTransferHeight RPC method.

func (*LastTransferHeightRequest) Descriptor 

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

func (*LastTransferHeightRequest) GetAssetId 

func (m *LastTransferHeightRequest) GetAssetId() AssetID

func (*LastTransferHeightRequest) Marshal 

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

func (*LastTransferHeightRequest) MarshalTo 

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

func (*LastTransferHeightRequest) MarshalToSizedBuffer 

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

func (*LastTransferHeightRequest) ProtoMessage 

func (*LastTransferHeightRequest) ProtoMessage()

func (*LastTransferHeightRequest) Reset 

func (m *LastTransferHeightRequest) Reset()

func (*LastTransferHeightRequest) Size 

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

func (*LastTransferHeightRequest) String 

func (m *LastTransferHeightRequest) String() string

func (*LastTransferHeightRequest) Unmarshal 

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

func (*LastTransferHeightRequest) XXX_DiscardUnknown 

func (m *LastTransferHeightRequest) XXX_DiscardUnknown()

func (*LastTransferHeightRequest) XXX_Marshal 

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

func (*LastTransferHeightRequest) XXX_Merge 

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

func (*LastTransferHeightRequest) XXX_Size 

func (m *LastTransferHeightRequest) XXX_Size() int

func (*LastTransferHeightRequest) XXX_Unmarshal 

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

type LastTransferHeightResponse 

type LastTransferHeightResponse struct {
	LastTransferHeight uint64 `` /* 146-byte string literal not displayed */
}

LastTransferHeightResponse is the response type for the Query/LastTransferHeight RPC method.

func (*LastTransferHeightResponse) Descriptor 

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

func (*LastTransferHeightResponse) GetLastTransferHeight 

func (m *LastTransferHeightResponse) GetLastTransferHeight() uint64

func (*LastTransferHeightResponse) Marshal 

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

func (*LastTransferHeightResponse) MarshalTo 

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

func (*LastTransferHeightResponse) MarshalToSizedBuffer 

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

func (*LastTransferHeightResponse) ProtoMessage 

func (*LastTransferHeightResponse) ProtoMessage()

func (*LastTransferHeightResponse) Reset 

func (m *LastTransferHeightResponse) Reset()

func (*LastTransferHeightResponse) Size 

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

func (*LastTransferHeightResponse) String 

func (m *LastTransferHeightResponse) String() string

func (*LastTransferHeightResponse) Unmarshal 

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

func (*LastTransferHeightResponse) XXX_DiscardUnknown 

func (m *LastTransferHeightResponse) XXX_DiscardUnknown()

func (*LastTransferHeightResponse) XXX_Marshal 

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

func (*LastTransferHeightResponse) XXX_Merge 

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

func (*LastTransferHeightResponse) XXX_Size 

func (m *LastTransferHeightResponse) XXX_Size() int

func (*LastTransferHeightResponse) XXX_Unmarshal 

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

type MsgChangeAssetStatus 

type MsgChangeAssetStatus struct {
	// Sender is a sender's address
	Sender string `protobuf:"bytes,1,opt,name=sender,proto3" json:"sender,omitempty" yaml:"sender"`
	// AssetID is the ID of the asset to update.
	// The asset should be known; otherwise, the method will failed.
	AssetId AssetID `protobuf:"bytes,2,opt,name=asset_id,json=assetId,proto3" json:"asset_id" yaml:"asset_id"`
	// NewStatus is a new asset's status.
	NewStatus AssetStatus `` /* 147-byte string literal not displayed */
}

MsgChangeAssetStatus changes the status of the provided asset.

func NewMsgChangeAssetStatus 

func NewMsgChangeAssetStatus(
	sender string,
	assetID AssetID,
	newStatus AssetStatus,
) *MsgChangeAssetStatus

func (*MsgChangeAssetStatus) Descriptor 

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

func (*MsgChangeAssetStatus) GetAssetId 

func (m *MsgChangeAssetStatus) GetAssetId() AssetID

func (*MsgChangeAssetStatus) GetNewStatus 

func (m *MsgChangeAssetStatus) GetNewStatus() AssetStatus

func (*MsgChangeAssetStatus) GetSender 

func (m *MsgChangeAssetStatus) GetSender() string

func (MsgChangeAssetStatus) GetSigners 

func (m MsgChangeAssetStatus) GetSigners() []sdk.AccAddress

func (*MsgChangeAssetStatus) Marshal 

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

func (*MsgChangeAssetStatus) MarshalTo 

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

func (*MsgChangeAssetStatus) MarshalToSizedBuffer 

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

func (*MsgChangeAssetStatus) ProtoMessage 

func (*MsgChangeAssetStatus) ProtoMessage()

func (*MsgChangeAssetStatus) Reset 

func (m *MsgChangeAssetStatus) Reset()

func (*MsgChangeAssetStatus) Size 

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

func (*MsgChangeAssetStatus) String 

func (m *MsgChangeAssetStatus) String() string

func (*MsgChangeAssetStatus) Unmarshal 

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

func (MsgChangeAssetStatus) ValidateBasic 

func (m MsgChangeAssetStatus) ValidateBasic() error

func (*MsgChangeAssetStatus) XXX_DiscardUnknown 

func (m *MsgChangeAssetStatus) XXX_DiscardUnknown()

func (*MsgChangeAssetStatus) XXX_Marshal 

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

func (*MsgChangeAssetStatus) XXX_Merge 

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

func (*MsgChangeAssetStatus) XXX_Size 

func (m *MsgChangeAssetStatus) XXX_Size() int

func (*MsgChangeAssetStatus) XXX_Unmarshal 

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

type MsgChangeAssetStatusResponse 

type MsgChangeAssetStatusResponse struct {
}

func (*MsgChangeAssetStatusResponse) Descriptor 

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

func (*MsgChangeAssetStatusResponse) Marshal 

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

func (*MsgChangeAssetStatusResponse) MarshalTo 

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

func (*MsgChangeAssetStatusResponse) MarshalToSizedBuffer 

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

func (*MsgChangeAssetStatusResponse) ProtoMessage 

func (*MsgChangeAssetStatusResponse) ProtoMessage()

func (*MsgChangeAssetStatusResponse) Reset 

func (m *MsgChangeAssetStatusResponse) Reset()

func (*MsgChangeAssetStatusResponse) Size 

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

func (*MsgChangeAssetStatusResponse) String 

func (m *MsgChangeAssetStatusResponse) String() string

func (*MsgChangeAssetStatusResponse) Unmarshal 

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

func (*MsgChangeAssetStatusResponse) XXX_DiscardUnknown 

func (m *MsgChangeAssetStatusResponse) XXX_DiscardUnknown()

func (*MsgChangeAssetStatusResponse) XXX_Marshal 

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

func (*MsgChangeAssetStatusResponse) XXX_Merge 

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

func (*MsgChangeAssetStatusResponse) XXX_Size 

func (m *MsgChangeAssetStatusResponse) XXX_Size() int

func (*MsgChangeAssetStatusResponse) XXX_Unmarshal 

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

type MsgClient 

type MsgClient interface {
	// InboundTransfer is used for inbound transfers (<other_chain> -> OSMO).
	InboundTransfer(ctx context.Context, in *MsgInboundTransfer, opts ...grpc.CallOption) (*MsgInboundTransferResponse, error)
	// OutboundTransfer is used for outbound transfers (OSMO -> <other_chain>).
	OutboundTransfer(ctx context.Context, in *MsgOutboundTransfer, opts ...grpc.CallOption) (*MsgOutboundTransferResponse, error)
	// UpdateParams is used for updating module params.
	UpdateParams(ctx context.Context, in *MsgUpdateParams, opts ...grpc.CallOption) (*MsgUpdateParamsResponse, error)
	// ChangeAssetStatus will change the provided asset's status.
	ChangeAssetStatus(ctx context.Context, in *MsgChangeAssetStatus, opts ...grpc.CallOption) (*MsgChangeAssetStatusResponse, 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 MsgInboundTransfer 

type MsgInboundTransfer struct {
	// ExternalId is a unique ID of the transfer coming from outside.
	// Serves the purpose of uniquely identifying the transfer in another chain
	// (e.g., this might be the BTC tx hash)
	ExternalId string `protobuf:"bytes,1,opt,name=external_id,json=externalId,proto3" json:"external_id,omitempty" yaml:"external_id"`
	// ExternalHeight is the height at which the transfer occurred in the external
	// chain
	ExternalHeight uint64 `` /* 127-byte string literal not displayed */
	// Sender is a sender's address
	Sender string `protobuf:"bytes,3,opt,name=sender,proto3" json:"sender,omitempty" yaml:"sender"`
	// DestAddr is a destination Osmosis address
	DestAddr string `protobuf:"bytes,4,opt,name=dest_addr,json=destAddr,proto3" json:"dest_addr,omitempty" yaml:"dest_addr"`
	// AssetID is the ID of the asset being transferred
	AssetId AssetID `protobuf:"bytes,5,opt,name=asset_id,json=assetId,proto3" json:"asset_id" yaml:"asset_id"`
	// Amount of coins to transfer
	Amount cosmossdk_io_math.Int `protobuf:"bytes,6,opt,name=amount,proto3,customtype=cosmossdk.io/math.Int" json:"amount" yaml:"amount"`
}

MsgInboundTransfer defines the message structure for the InboundTransfer gRPC service method. It allows a sender to perform an inbound cross-chain transfer, i.e., to transfer their tokens from the source chain to Osmosis and get the equivalent amount of the corresponding token (specified in subdenom) on Osmosis in return. The tokens are minted through the x/tokenfactory module to the destination address.

func NewMsgInboundTransfer 

func NewMsgInboundTransfer(
	externalID string,
	sender string,
	destAddr string,
	assetID AssetID,
	amount math.Int,
) *MsgInboundTransfer

func (*MsgInboundTransfer) Descriptor 

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

func (*MsgInboundTransfer) GetAssetId 

func (m *MsgInboundTransfer) GetAssetId() AssetID

func (*MsgInboundTransfer) GetDestAddr 

func (m *MsgInboundTransfer) GetDestAddr() string

func (*MsgInboundTransfer) GetExternalHeight 

func (m *MsgInboundTransfer) GetExternalHeight() uint64

func (*MsgInboundTransfer) GetExternalId 

func (m *MsgInboundTransfer) GetExternalId() string

func (*MsgInboundTransfer) GetSender 

func (m *MsgInboundTransfer) GetSender() string

func (MsgInboundTransfer) GetSigners 

func (m MsgInboundTransfer) GetSigners() []sdk.AccAddress

func (*MsgInboundTransfer) Marshal 

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

func (*MsgInboundTransfer) MarshalTo 

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

func (*MsgInboundTransfer) MarshalToSizedBuffer 

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

func (*MsgInboundTransfer) ProtoMessage 

func (*MsgInboundTransfer) ProtoMessage()

func (*MsgInboundTransfer) Reset 

func (m *MsgInboundTransfer) Reset()

func (*MsgInboundTransfer) Size 

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

func (*MsgInboundTransfer) String 

func (m *MsgInboundTransfer) String() string

func (*MsgInboundTransfer) Unmarshal 

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

func (MsgInboundTransfer) ValidateBasic 

func (m MsgInboundTransfer) ValidateBasic() error

func (*MsgInboundTransfer) XXX_DiscardUnknown 

func (m *MsgInboundTransfer) XXX_DiscardUnknown()

func (*MsgInboundTransfer) XXX_Marshal 

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

func (*MsgInboundTransfer) XXX_Merge 

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

func (*MsgInboundTransfer) XXX_Size 

func (m *MsgInboundTransfer) XXX_Size() int

func (*MsgInboundTransfer) XXX_Unmarshal 

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

type MsgInboundTransferResponse 

type MsgInboundTransferResponse struct {
}

func (*MsgInboundTransferResponse) Descriptor 

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

func (*MsgInboundTransferResponse) Marshal 

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

func (*MsgInboundTransferResponse) MarshalTo 

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

func (*MsgInboundTransferResponse) MarshalToSizedBuffer 

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

func (*MsgInboundTransferResponse) ProtoMessage 

func (*MsgInboundTransferResponse) ProtoMessage()

func (*MsgInboundTransferResponse) Reset 

func (m *MsgInboundTransferResponse) Reset()

func (*MsgInboundTransferResponse) Size 

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

func (*MsgInboundTransferResponse) String 

func (m *MsgInboundTransferResponse) String() string

func (*MsgInboundTransferResponse) Unmarshal 

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

func (*MsgInboundTransferResponse) XXX_DiscardUnknown 

func (m *MsgInboundTransferResponse) XXX_DiscardUnknown()

func (*MsgInboundTransferResponse) XXX_Marshal 

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

func (*MsgInboundTransferResponse) XXX_Merge 

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

func (*MsgInboundTransferResponse) XXX_Size 

func (m *MsgInboundTransferResponse) XXX_Size() int

func (*MsgInboundTransferResponse) XXX_Unmarshal 

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

type MsgOutboundTransfer 

type MsgOutboundTransfer struct {
	// Sender is a sender's Osmosis address
	Sender string `protobuf:"bytes,1,opt,name=sender,proto3" json:"sender,omitempty" yaml:"sender"`
	// DestAddr is a destination address
	DestAddr string `protobuf:"bytes,2,opt,name=dest_addr,json=destAddr,proto3" json:"dest_addr,omitempty" yaml:"dest_addr"`
	// AssetID is the ID of the asset being transferred
	AssetId AssetID `protobuf:"bytes,3,opt,name=asset_id,json=assetId,proto3" json:"asset_id" yaml:"asset_id"`
	// Amount of coins to transfer
	Amount cosmossdk_io_math.Int `protobuf:"bytes,4,opt,name=amount,proto3,customtype=cosmossdk.io/math.Int" json:"amount" yaml:"amount"`
}

MsgOutboundTransfer defines the message structure for the OutboundTransfer gRPC service method. It allows a sender to perform an outbound cross-chain transfer, i.e., to transfer their tokens from Osmosis to the destination chain. The tokens are burned through the x/tokenfactory module from the sender's address.

func NewMsgOutboundTransfer 

func NewMsgOutboundTransfer(
	sender string,
	destAddr string,
	assetID AssetID,
	amount math.Int,
) *MsgOutboundTransfer

func (*MsgOutboundTransfer) Descriptor 

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

func (*MsgOutboundTransfer) GetAssetId 

func (m *MsgOutboundTransfer) GetAssetId() AssetID

func (*MsgOutboundTransfer) GetDestAddr 

func (m *MsgOutboundTransfer) GetDestAddr() string

func (*MsgOutboundTransfer) GetSender 

func (m *MsgOutboundTransfer) GetSender() string

func (MsgOutboundTransfer) GetSigners 

func (m MsgOutboundTransfer) GetSigners() []sdk.AccAddress

func (*MsgOutboundTransfer) Marshal 

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

func (*MsgOutboundTransfer) MarshalTo 

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

func (*MsgOutboundTransfer) MarshalToSizedBuffer 

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

func (*MsgOutboundTransfer) ProtoMessage 

func (*MsgOutboundTransfer) ProtoMessage()

func (*MsgOutboundTransfer) Reset 

func (m *MsgOutboundTransfer) Reset()

func (*MsgOutboundTransfer) Size 

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

func (*MsgOutboundTransfer) String 

func (m *MsgOutboundTransfer) String() string

func (*MsgOutboundTransfer) Unmarshal 

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

func (MsgOutboundTransfer) ValidateBasic 

func (m MsgOutboundTransfer) ValidateBasic() error

func (*MsgOutboundTransfer) XXX_DiscardUnknown 

func (m *MsgOutboundTransfer) XXX_DiscardUnknown()

func (*MsgOutboundTransfer) XXX_Marshal 

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

func (*MsgOutboundTransfer) XXX_Merge 

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

func (*MsgOutboundTransfer) XXX_Size 

func (m *MsgOutboundTransfer) XXX_Size() int

func (*MsgOutboundTransfer) XXX_Unmarshal 

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

type MsgOutboundTransferResponse 

type MsgOutboundTransferResponse struct {
}

func (*MsgOutboundTransferResponse) Descriptor 

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

func (*MsgOutboundTransferResponse) Marshal 

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

func (*MsgOutboundTransferResponse) MarshalTo 

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

func (*MsgOutboundTransferResponse) MarshalToSizedBuffer 

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

func (*MsgOutboundTransferResponse) ProtoMessage 

func (*MsgOutboundTransferResponse) ProtoMessage()

func (*MsgOutboundTransferResponse) Reset 

func (m *MsgOutboundTransferResponse) Reset()

func (*MsgOutboundTransferResponse) Size 

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

func (*MsgOutboundTransferResponse) String 

func (m *MsgOutboundTransferResponse) String() string

func (*MsgOutboundTransferResponse) Unmarshal 

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

func (*MsgOutboundTransferResponse) XXX_DiscardUnknown 

func (m *MsgOutboundTransferResponse) XXX_DiscardUnknown()

func (*MsgOutboundTransferResponse) XXX_Marshal 

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

func (*MsgOutboundTransferResponse) XXX_Merge 

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

func (*MsgOutboundTransferResponse) XXX_Size 

func (m *MsgOutboundTransferResponse) XXX_Size() int

func (*MsgOutboundTransferResponse) XXX_Unmarshal 

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

type MsgServer 

type MsgServer interface {
	// InboundTransfer is used for inbound transfers (<other_chain> -> OSMO).
	InboundTransfer(context.Context, *MsgInboundTransfer) (*MsgInboundTransferResponse, error)
	// OutboundTransfer is used for outbound transfers (OSMO -> <other_chain>).
	OutboundTransfer(context.Context, *MsgOutboundTransfer) (*MsgOutboundTransferResponse, error)
	// UpdateParams is used for updating module params.
	UpdateParams(context.Context, *MsgUpdateParams) (*MsgUpdateParamsResponse, error)
	// ChangeAssetStatus will change the provided asset's status.
	ChangeAssetStatus(context.Context, *MsgChangeAssetStatus) (*MsgChangeAssetStatusResponse, error)
}

MsgServer is the server API for Msg service.

type MsgUpdateParams 

type MsgUpdateParams struct {
	// Sender is a sender's address
	Sender string `protobuf:"bytes,1,opt,name=sender,proto3" json:"sender,omitempty" yaml:"sender"`
	// NewParams should be fully populated
	NewParams Params `protobuf:"bytes,2,opt,name=new_params,json=newParams,proto3" json:"new_params" yaml:"new_params"`
}

MsgUpdateParams allows to update module params. It contains UpdateParams instead of just Params to forbid status updating using this method. All new assets introduced with this method have ASSET_STATUS_BLOCKED_BOTH status by default.

func NewMsgUpdateParams 

func NewMsgUpdateParams(
	sender string,
	newParams Params,
) *MsgUpdateParams

func (*MsgUpdateParams) Descriptor 

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

func (*MsgUpdateParams) GetNewParams 

func (m *MsgUpdateParams) GetNewParams() Params

func (*MsgUpdateParams) GetSender 

func (m *MsgUpdateParams) GetSender() string

func (MsgUpdateParams) GetSigners 

func (m MsgUpdateParams) GetSigners() []sdk.AccAddress

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) Unmarshal 

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

func (MsgUpdateParams) ValidateBasic 

func (m MsgUpdateParams) ValidateBasic() error

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 {
}

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 Params 

type Params struct {
	// Signers used to sign inbound and release outbound transactions
	Signers []string `protobuf:"bytes,1,rep,name=signers,proto3" json:"signers,omitempty" yaml:"signers"`
	// Assets is a list used to create tokenfactory denoms
	// for corresponding trading pairs
	Assets []Asset `protobuf:"bytes,2,rep,name=assets,proto3" json:"assets" yaml:"assets"`
	// VotesNeeded marks how many signers out of the list of signers need
	// to sign until a tx can be considered finalized
	VotesNeeded uint64 `protobuf:"varint,3,opt,name=votes_needed,json=votesNeeded,proto3" json:"votes_needed,omitempty" yaml:"votes_needed"`
	// Fee defines a param for fee that go towards the validator set
	// signing the incoming/outgoing txs. The fee is measured as a ratio,
	// so its value lies between 0 and 1.
	Fee cosmossdk_io_math.LegacyDec `protobuf:"bytes,4,opt,name=fee,proto3,customtype=cosmossdk.io/math.LegacyDec" json:"fee" yaml:"fee"`
}

Params defines params for x/bridge module.

func DefaultParams 

func DefaultParams() Params

DefaultParams creates default x/bridge params.

func NewParams 

func NewParams(
	signers []string,
	assets []Asset,
	votesNeeded uint64,
	fee math.LegacyDec,
) Params

func (*Params) Descriptor 

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

func (Params) GetAsset 

func (p Params) GetAsset(id AssetID) (Asset, bool)

func (Params) GetAssetIndex 

func (p Params) GetAssetIndex(id AssetID) int

func (*Params) GetAssets 

func (m *Params) GetAssets() []Asset

func (*Params) GetSigners 

func (m *Params) GetSigners() []string

func (*Params) GetVotesNeeded 

func (m *Params) GetVotesNeeded() 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) ParamSetPairs 

func (p *Params) ParamSetPairs() paramtypes.ParamSetPairs

ParamSetPairs implements params.ParamSet.

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 x/bridge 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 QueryClient 

type QueryClient interface {
	// Params returns x/bridge module params.
	Params(ctx context.Context, in *QueryParamsRequest, opts ...grpc.CallOption) (*QueryParamsResponse, error)
	// LastTransferHeight returns the height of the external chain at which
	// the last transfer with the given asset was successfully completed
	// (finalized).
	LastTransferHeight(ctx context.Context, in *LastTransferHeightRequest, opts ...grpc.CallOption) (*LastTransferHeightResponse, 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 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 Params `protobuf:"bytes,1,opt,name=params,proto3" json:"params" yaml:"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 {
	// Params returns x/bridge module params.
	Params(context.Context, *QueryParamsRequest) (*QueryParamsResponse, error)
	// LastTransferHeight returns the height of the external chain at which
	// the last transfer with the given asset was successfully completed
	// (finalized).
	LastTransferHeight(context.Context, *LastTransferHeightRequest) (*LastTransferHeightResponse, error)
}

QueryServer is the server API for Query service.

type UnimplementedMsgServer 

type UnimplementedMsgServer struct {
}

UnimplementedMsgServer can be embedded to have forward compatible implementations.

func (*UnimplementedMsgServer) ChangeAssetStatus 

func (*UnimplementedMsgServer) ChangeAssetStatus(ctx context.Context, req *MsgChangeAssetStatus) (*MsgChangeAssetStatusResponse, error)

func (*UnimplementedMsgServer) InboundTransfer 

func (*UnimplementedMsgServer) InboundTransfer(ctx context.Context, req *MsgInboundTransfer) (*MsgInboundTransferResponse, error)

func (*UnimplementedMsgServer) OutboundTransfer 

func (*UnimplementedMsgServer) OutboundTransfer(ctx context.Context, req *MsgOutboundTransfer) (*MsgOutboundTransferResponse, error)

func (*UnimplementedMsgServer) UpdateParams 

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

type UnimplementedQueryServer 

type UnimplementedQueryServer struct {
}

UnimplementedQueryServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryServer) LastTransferHeight 

func (*UnimplementedQueryServer) LastTransferHeight(ctx context.Context, req *LastTransferHeightRequest) (*LastTransferHeightResponse, error)

func (*UnimplementedQueryServer) Params 

func (*UnimplementedQueryServer) Params(ctx context.Context, req *QueryParamsRequest) (*QueryParamsResponse, 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.