types

package
v1.0.0-rc4-testnet Latest Latest
Warning

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

 Go to latest Published: Dec 2, 2024 License: MIT 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 (
	EventTypeBridgeIn        = "bridge_in"
	EventTypeBridgeOut       = "bridge_out"
	EventTypeRegisterNewCoin = "register_new_coin"
	EventTypeDeregisterCoin  = "deregister_coin"

	AttributeKeyCoins   = "coins"
	AttributeKeyDenom   = "denom"
	AttributeKeyAddress = "address"

	AttributeValueCategory = ModuleName
)

staking module event types

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
)

Variables

View Source 
var (
	Amino     = codec.NewLegacyAmino()
	ModuleCdc = codec.NewProtoCodec(cdctypes.NewInterfaceRegistry())
)
View Source 
var (
	ErrCoinNotRegister          = errorsmod.Register(ModuleName, 1600, "coin not in register list")
	ErrCoinAlreadyRegister      = errorsmod.Register(ModuleName, 1601, "coin already in register list")
	ErrEpochDurationZero        = errorsmod.Register(ModuleName, 1602, "epoch duration should NOT be 0")
	ErrInflowThresholdExceeded  = errorsmod.Register(ModuleName, 1603, "inflow threshold exceeded")
	ErrOutflowThresholdExceeded = errorsmod.Register(ModuleName, 1604, "outflow threshold exceeded")
	ErrZeroRatelimit            = errorsmod.Register(ModuleName, 1605, "ratelimit must not be zero")
)

x/bridge 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 (
	ParamsKey             = collections.NewPrefix(0)
	EpochInfoKey          = collections.NewPrefix(1)
	RegisteredCoinsPrefix = collections.NewPrefix(2)
)
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 (
	ErrInvalidLengthRatelimit        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowRatelimit          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupRatelimit = 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")
)

Functions

func RegisterCodec 

func RegisterCodec(cdc *codec.LegacyAmino)

func RegisterInterfaces 

func RegisterInterfaces(registry cdctypes.InterfaceRegistry)

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 {
	AddressCodec() address.Codec
	GetAccount(ctx context.Context, addr sdk.AccAddress) sdk.AccountI
	GetModuleAddress(name string) sdk.AccAddress
}

AccountKeeper defines the expected account keeper used for simulations (noalias)

type BankKeeper 

type BankKeeper interface {
	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
	MintCoins(ctx context.Context, name string, amt sdk.Coins) error
	BurnCoins(ctx context.Context, name string, amt sdk.Coins) error
}

BankKeeper defines the contract needed to be fulfilled for banking and supply dependencies.

type DenomAndRateLimit 

type DenomAndRateLimit struct {
	// denom of the coin.
	Denom string `protobuf:"bytes,1,opt,name=denom,proto3" json:"denom,omitempty"`
	// ratelimit of the coin.
	RateLimit RateLimit `protobuf:"bytes,2,opt,name=rate_limit,json=rateLimit,proto3" json:"rate_limit"`
}

func (*DenomAndRateLimit) Descriptor 

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

func (*DenomAndRateLimit) GetDenom 

func (m *DenomAndRateLimit) GetDenom() string

func (*DenomAndRateLimit) GetRateLimit 

func (m *DenomAndRateLimit) GetRateLimit() RateLimit

func (*DenomAndRateLimit) Marshal 

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

func (*DenomAndRateLimit) MarshalTo 

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

func (*DenomAndRateLimit) MarshalToSizedBuffer 

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

func (*DenomAndRateLimit) ProtoMessage 

func (*DenomAndRateLimit) ProtoMessage()

func (*DenomAndRateLimit) Reset 

func (m *DenomAndRateLimit) Reset()

func (*DenomAndRateLimit) Size 

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

func (*DenomAndRateLimit) String 

func (m *DenomAndRateLimit) String() string

func (*DenomAndRateLimit) Unmarshal 

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

func (*DenomAndRateLimit) XXX_DiscardUnknown 

func (m *DenomAndRateLimit) XXX_DiscardUnknown()

func (*DenomAndRateLimit) XXX_Marshal 

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

func (*DenomAndRateLimit) XXX_Merge 

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

func (*DenomAndRateLimit) XXX_Size 

func (m *DenomAndRateLimit) XXX_Size() int

func (*DenomAndRateLimit) XXX_Unmarshal 

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

type EpochInfo 

type EpochInfo struct {
	// start_time is the time at which the timer first ever ticks.
	// If start_time is in the future, the epoch will not begin until the start
	// time.
	StartTime time.Time `protobuf:"bytes,1,opt,name=start_time,json=startTime,proto3,stdtime" json:"start_time"`
	// duration is the time in between epoch ticks.
	// In order for intended behavior to be met, duration should
	// be greater than the chains expected block time.
	// Duration must be non-zero.
	Duration              time.Duration `protobuf:"bytes,2,opt,name=duration,proto3,stdduration" json:"duration,omitempty"`
	CurrentEpochStartTime time.Time     `` /* 126-byte string literal not displayed */
	// epoch_counting_started is a boolean, that indicates whether this
	// epoch timer has began yet.
	EpochCountingStarted    bool  `protobuf:"varint,4,opt,name=epoch_counting_started,json=epochCountingStarted,proto3" json:"epoch_counting_started,omitempty"`
	CurrentEpochStartHeight int64 `` /* 135-byte string literal not displayed */
}

EpochInfo defines the rate limit epoch info

func DefaultEpochInfo 

func DefaultEpochInfo() EpochInfo

func (*EpochInfo) Descriptor 

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

func (*EpochInfo) GetCurrentEpochStartHeight 

func (m *EpochInfo) GetCurrentEpochStartHeight() int64

func (*EpochInfo) GetCurrentEpochStartTime 

func (m *EpochInfo) GetCurrentEpochStartTime() time.Time

func (*EpochInfo) GetDuration 

func (m *EpochInfo) GetDuration() time.Duration

func (*EpochInfo) GetEpochCountingStarted 

func (m *EpochInfo) GetEpochCountingStarted() bool

func (*EpochInfo) GetStartTime 

func (m *EpochInfo) GetStartTime() time.Time

func (*EpochInfo) Marshal 

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

func (*EpochInfo) MarshalTo 

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

func (*EpochInfo) MarshalToSizedBuffer 

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

func (*EpochInfo) ProtoMessage 

func (*EpochInfo) ProtoMessage()

func (*EpochInfo) Reset 

func (m *EpochInfo) Reset()

func (*EpochInfo) Size 

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

func (*EpochInfo) String 

func (m *EpochInfo) String() string

func (*EpochInfo) Unmarshal 

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

func (*EpochInfo) Validate 

func (epoch *EpochInfo) Validate() error

func (*EpochInfo) XXX_DiscardUnknown 

func (m *EpochInfo) XXX_DiscardUnknown()

func (*EpochInfo) XXX_Marshal 

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

func (*EpochInfo) XXX_Merge 

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

func (*EpochInfo) XXX_Size 

func (m *EpochInfo) XXX_Size() int

func (*EpochInfo) XXX_Unmarshal 

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

type GenesisState 

type GenesisState struct {
	Params Params `protobuf:"bytes,1,opt,name=params,proto3" json:"params"`
	// registered denoms and its rate limit
	RegisteredCoins github_com_cosmos_cosmos_sdk_types.Coins `` /* 150-byte string literal not displayed */
	// rate limit epoch info
	RatelimitEpochInfo EpochInfo `protobuf:"bytes,3,opt,name=ratelimit_epoch_info,json=ratelimitEpochInfo,proto3" json:"ratelimit_epoch_info"`
}

GenesisState defines the bridge 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) GetRatelimitEpochInfo 

func (m *GenesisState) GetRatelimitEpochInfo() EpochInfo

func (*GenesisState) GetRegisteredCoins 

func (m *GenesisState) GetRegisteredCoins() github_com_cosmos_cosmos_sdk_types.Coins

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 MsgBridgeIn 

type MsgBridgeIn struct {
	Authority string     `protobuf:"bytes,1,opt,name=authority,proto3" json:"authority,omitempty"`
	Coin      types.Coin `protobuf:"bytes,2,opt,name=coin,proto3,castrepeated=github.com/cosmos/cosmos-sdk/types.Coin" json:"coin"`
	Reciever  string     `protobuf:"bytes,3,opt,name=reciever,proto3" json:"reciever,omitempty"`
}

func (*MsgBridgeIn) Descriptor 

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

func (*MsgBridgeIn) GetAuthority 

func (m *MsgBridgeIn) GetAuthority() string

func (*MsgBridgeIn) GetCoin 

func (m *MsgBridgeIn) GetCoin() types.Coin

func (*MsgBridgeIn) GetReciever 

func (m *MsgBridgeIn) GetReciever() string

func (*MsgBridgeIn) Marshal 

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

func (*MsgBridgeIn) MarshalTo 

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

func (*MsgBridgeIn) MarshalToSizedBuffer 

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

func (*MsgBridgeIn) ProtoMessage 

func (*MsgBridgeIn) ProtoMessage()

func (*MsgBridgeIn) Reset 

func (m *MsgBridgeIn) Reset()

func (*MsgBridgeIn) Size 

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

func (*MsgBridgeIn) String 

func (m *MsgBridgeIn) String() string

func (*MsgBridgeIn) Unmarshal 

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

func (*MsgBridgeIn) XXX_DiscardUnknown 

func (m *MsgBridgeIn) XXX_DiscardUnknown()

func (*MsgBridgeIn) XXX_Marshal 

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

func (*MsgBridgeIn) XXX_Merge 

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

func (*MsgBridgeIn) XXX_Size 

func (m *MsgBridgeIn) XXX_Size() int

func (*MsgBridgeIn) XXX_Unmarshal 

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

type MsgBridgeInResponse 

type MsgBridgeInResponse struct {
}

func (*MsgBridgeInResponse) Descriptor 

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

func (*MsgBridgeInResponse) Marshal 

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

func (*MsgBridgeInResponse) MarshalTo 

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

func (*MsgBridgeInResponse) MarshalToSizedBuffer 

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

func (*MsgBridgeInResponse) ProtoMessage 

func (*MsgBridgeInResponse) ProtoMessage()

func (*MsgBridgeInResponse) Reset 

func (m *MsgBridgeInResponse) Reset()

func (*MsgBridgeInResponse) Size 

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

func (*MsgBridgeInResponse) String 

func (m *MsgBridgeInResponse) String() string

func (*MsgBridgeInResponse) Unmarshal 

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

func (*MsgBridgeInResponse) XXX_DiscardUnknown 

func (m *MsgBridgeInResponse) XXX_DiscardUnknown()

func (*MsgBridgeInResponse) XXX_Marshal 

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

func (*MsgBridgeInResponse) XXX_Merge 

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

func (*MsgBridgeInResponse) XXX_Size 

func (m *MsgBridgeInResponse) XXX_Size() int

func (*MsgBridgeInResponse) XXX_Unmarshal 

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

type MsgBridgeOut 

type MsgBridgeOut struct {
	Signer string     `protobuf:"bytes,1,opt,name=signer,proto3" json:"signer,omitempty"`
	Coin   types.Coin `protobuf:"bytes,2,opt,name=coin,proto3,castrepeated=github.com/cosmos/cosmos-sdk/types.Coin" json:"coin"`
}

func (*MsgBridgeOut) Descriptor 

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

func (*MsgBridgeOut) GetCoin 

func (m *MsgBridgeOut) GetCoin() types.Coin

func (*MsgBridgeOut) GetSigner 

func (m *MsgBridgeOut) GetSigner() string

func (*MsgBridgeOut) Marshal 

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

func (*MsgBridgeOut) MarshalTo 

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

func (*MsgBridgeOut) MarshalToSizedBuffer 

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

func (*MsgBridgeOut) ProtoMessage 

func (*MsgBridgeOut) ProtoMessage()

func (*MsgBridgeOut) Reset 

func (m *MsgBridgeOut) Reset()

func (*MsgBridgeOut) Size 

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

func (*MsgBridgeOut) String 

func (m *MsgBridgeOut) String() string

func (*MsgBridgeOut) Unmarshal 

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

func (*MsgBridgeOut) XXX_DiscardUnknown 

func (m *MsgBridgeOut) XXX_DiscardUnknown()

func (*MsgBridgeOut) XXX_Marshal 

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

func (*MsgBridgeOut) XXX_Merge 

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

func (*MsgBridgeOut) XXX_Size 

func (m *MsgBridgeOut) XXX_Size() int

func (*MsgBridgeOut) XXX_Unmarshal 

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

type MsgBridgeOutResponse 

type MsgBridgeOutResponse struct {
}

func (*MsgBridgeOutResponse) Descriptor 

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

func (*MsgBridgeOutResponse) Marshal 

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

func (*MsgBridgeOutResponse) MarshalTo 

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

func (*MsgBridgeOutResponse) MarshalToSizedBuffer 

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

func (*MsgBridgeOutResponse) ProtoMessage 

func (*MsgBridgeOutResponse) ProtoMessage()

func (*MsgBridgeOutResponse) Reset 

func (m *MsgBridgeOutResponse) Reset()

func (*MsgBridgeOutResponse) Size 

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

func (*MsgBridgeOutResponse) String 

func (m *MsgBridgeOutResponse) String() string

func (*MsgBridgeOutResponse) Unmarshal 

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

func (*MsgBridgeOutResponse) XXX_DiscardUnknown 

func (m *MsgBridgeOutResponse) XXX_DiscardUnknown()

func (*MsgBridgeOutResponse) XXX_Marshal 

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

func (*MsgBridgeOutResponse) XXX_Merge 

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

func (*MsgBridgeOutResponse) XXX_Size 

func (m *MsgBridgeOutResponse) XXX_Size() int

func (*MsgBridgeOutResponse) XXX_Unmarshal 

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

type MsgClient 

type MsgClient interface {
	BridgeIn(ctx context.Context, in *MsgBridgeIn, opts ...grpc.CallOption) (*MsgBridgeInResponse, error)
	BridgeOut(ctx context.Context, in *MsgBridgeOut, opts ...grpc.CallOption) (*MsgBridgeOutResponse, error)
	RegisterNewCoins(ctx context.Context, in *MsgRegisterNewCoins, opts ...grpc.CallOption) (*MsgRegisterNewCoinsResponse, error)
	DeregisterCoins(ctx context.Context, in *MsgDeregisterCoins, opts ...grpc.CallOption) (*MsgDeregisterCoinsResponse, error)
	UpdateParams(ctx context.Context, in *MsgUpdateParams, opts ...grpc.CallOption) (*MsgUpdateParamsResponse, error)
	UpdateEpochDuration(ctx context.Context, in *MsgUpdateEpochDuration, opts ...grpc.CallOption) (*MsgUpdateEpochDurationResponse, 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 MsgDeregisterCoins 

type MsgDeregisterCoins struct {
	Authority string   `protobuf:"bytes,1,opt,name=authority,proto3" json:"authority,omitempty"`
	Denoms    []string `protobuf:"bytes,2,rep,name=denoms,proto3" json:"denoms,omitempty"`
}

func (*MsgDeregisterCoins) Descriptor 

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

func (*MsgDeregisterCoins) GetAuthority 

func (m *MsgDeregisterCoins) GetAuthority() string

func (*MsgDeregisterCoins) GetDenoms 

func (m *MsgDeregisterCoins) GetDenoms() []string

func (*MsgDeregisterCoins) Marshal 

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

func (*MsgDeregisterCoins) MarshalTo 

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

func (*MsgDeregisterCoins) MarshalToSizedBuffer 

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

func (*MsgDeregisterCoins) ProtoMessage 

func (*MsgDeregisterCoins) ProtoMessage()

func (*MsgDeregisterCoins) Reset 

func (m *MsgDeregisterCoins) Reset()

func (*MsgDeregisterCoins) Size 

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

func (*MsgDeregisterCoins) String 

func (m *MsgDeregisterCoins) String() string

func (*MsgDeregisterCoins) Unmarshal 

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

func (*MsgDeregisterCoins) XXX_DiscardUnknown 

func (m *MsgDeregisterCoins) XXX_DiscardUnknown()

func (*MsgDeregisterCoins) XXX_Marshal 

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

func (*MsgDeregisterCoins) XXX_Merge 

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

func (*MsgDeregisterCoins) XXX_Size 

func (m *MsgDeregisterCoins) XXX_Size() int

func (*MsgDeregisterCoins) XXX_Unmarshal 

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

type MsgDeregisterCoinsResponse 

type MsgDeregisterCoinsResponse struct {
}

func (*MsgDeregisterCoinsResponse) Descriptor 

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

func (*MsgDeregisterCoinsResponse) Marshal 

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

func (*MsgDeregisterCoinsResponse) MarshalTo 

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

func (*MsgDeregisterCoinsResponse) MarshalToSizedBuffer 

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

func (*MsgDeregisterCoinsResponse) ProtoMessage 

func (*MsgDeregisterCoinsResponse) ProtoMessage()

func (*MsgDeregisterCoinsResponse) Reset 

func (m *MsgDeregisterCoinsResponse) Reset()

func (*MsgDeregisterCoinsResponse) Size 

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

func (*MsgDeregisterCoinsResponse) String 

func (m *MsgDeregisterCoinsResponse) String() string

func (*MsgDeregisterCoinsResponse) Unmarshal 

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

func (*MsgDeregisterCoinsResponse) XXX_DiscardUnknown 

func (m *MsgDeregisterCoinsResponse) XXX_DiscardUnknown()

func (*MsgDeregisterCoinsResponse) XXX_Marshal 

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

func (*MsgDeregisterCoinsResponse) XXX_Merge 

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

func (*MsgDeregisterCoinsResponse) XXX_Size 

func (m *MsgDeregisterCoinsResponse) XXX_Size() int

func (*MsgDeregisterCoinsResponse) XXX_Unmarshal 

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

type MsgRegisterNewCoins 

type MsgRegisterNewCoins struct {
	Authority string                                   `protobuf:"bytes,1,opt,name=authority,proto3" json:"authority,omitempty"`
	Coins     github_com_cosmos_cosmos_sdk_types.Coins `protobuf:"bytes,2,rep,name=coins,proto3,castrepeated=github.com/cosmos/cosmos-sdk/types.Coins" json:"coins"`
}

func (*MsgRegisterNewCoins) Descriptor 

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

func (*MsgRegisterNewCoins) GetAuthority 

func (m *MsgRegisterNewCoins) GetAuthority() string

func (*MsgRegisterNewCoins) GetCoins 

func (m *MsgRegisterNewCoins) GetCoins() github_com_cosmos_cosmos_sdk_types.Coins

func (*MsgRegisterNewCoins) Marshal 

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

func (*MsgRegisterNewCoins) MarshalTo 

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

func (*MsgRegisterNewCoins) MarshalToSizedBuffer 

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

func (*MsgRegisterNewCoins) ProtoMessage 

func (*MsgRegisterNewCoins) ProtoMessage()

func (*MsgRegisterNewCoins) Reset 

func (m *MsgRegisterNewCoins) Reset()

func (*MsgRegisterNewCoins) Size 

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

func (*MsgRegisterNewCoins) String 

func (m *MsgRegisterNewCoins) String() string

func (*MsgRegisterNewCoins) Unmarshal 

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

func (*MsgRegisterNewCoins) XXX_DiscardUnknown 

func (m *MsgRegisterNewCoins) XXX_DiscardUnknown()

func (*MsgRegisterNewCoins) XXX_Marshal 

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

func (*MsgRegisterNewCoins) XXX_Merge 

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

func (*MsgRegisterNewCoins) XXX_Size 

func (m *MsgRegisterNewCoins) XXX_Size() int

func (*MsgRegisterNewCoins) XXX_Unmarshal 

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

type MsgRegisterNewCoinsResponse 

type MsgRegisterNewCoinsResponse struct {
}

func (*MsgRegisterNewCoinsResponse) Descriptor 

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

func (*MsgRegisterNewCoinsResponse) Marshal 

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

func (*MsgRegisterNewCoinsResponse) MarshalTo 

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

func (*MsgRegisterNewCoinsResponse) MarshalToSizedBuffer 

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

func (*MsgRegisterNewCoinsResponse) ProtoMessage 

func (*MsgRegisterNewCoinsResponse) ProtoMessage()

func (*MsgRegisterNewCoinsResponse) Reset 

func (m *MsgRegisterNewCoinsResponse) Reset()

func (*MsgRegisterNewCoinsResponse) Size 

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

func (*MsgRegisterNewCoinsResponse) String 

func (m *MsgRegisterNewCoinsResponse) String() string

func (*MsgRegisterNewCoinsResponse) Unmarshal 

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

func (*MsgRegisterNewCoinsResponse) XXX_DiscardUnknown 

func (m *MsgRegisterNewCoinsResponse) XXX_DiscardUnknown()

func (*MsgRegisterNewCoinsResponse) XXX_Marshal 

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

func (*MsgRegisterNewCoinsResponse) XXX_Merge 

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

func (*MsgRegisterNewCoinsResponse) XXX_Size 

func (m *MsgRegisterNewCoinsResponse) XXX_Size() int

func (*MsgRegisterNewCoinsResponse) XXX_Unmarshal 

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

type MsgServer 

type MsgServer interface {
	BridgeIn(context.Context, *MsgBridgeIn) (*MsgBridgeInResponse, error)
	BridgeOut(context.Context, *MsgBridgeOut) (*MsgBridgeOutResponse, error)
	RegisterNewCoins(context.Context, *MsgRegisterNewCoins) (*MsgRegisterNewCoinsResponse, error)
	DeregisterCoins(context.Context, *MsgDeregisterCoins) (*MsgDeregisterCoinsResponse, error)
	UpdateParams(context.Context, *MsgUpdateParams) (*MsgUpdateParamsResponse, error)
	UpdateEpochDuration(context.Context, *MsgUpdateEpochDuration) (*MsgUpdateEpochDurationResponse, error)
}

MsgServer is the server API for Msg service.

type MsgUpdateEpochDuration 

type MsgUpdateEpochDuration struct {
	// authority is the address that controls the module (defaults to x/gov unless
	// overwritten).
	Authority string        `protobuf:"bytes,1,opt,name=authority,proto3" json:"authority,omitempty"`
	Duration  time.Duration `protobuf:"bytes,2,opt,name=duration,proto3,stdduration" json:"duration,omitempty"`
}

func (*MsgUpdateEpochDuration) Descriptor 

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

func (*MsgUpdateEpochDuration) GetAuthority 

func (m *MsgUpdateEpochDuration) GetAuthority() string

func (*MsgUpdateEpochDuration) GetDuration 

func (m *MsgUpdateEpochDuration) GetDuration() time.Duration

func (*MsgUpdateEpochDuration) Marshal 

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

func (*MsgUpdateEpochDuration) MarshalTo 

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

func (*MsgUpdateEpochDuration) MarshalToSizedBuffer 

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

func (*MsgUpdateEpochDuration) ProtoMessage 

func (*MsgUpdateEpochDuration) ProtoMessage()

func (*MsgUpdateEpochDuration) Reset 

func (m *MsgUpdateEpochDuration) Reset()

func (*MsgUpdateEpochDuration) Size 

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

func (*MsgUpdateEpochDuration) String 

func (m *MsgUpdateEpochDuration) String() string

func (*MsgUpdateEpochDuration) Unmarshal 

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

func (*MsgUpdateEpochDuration) XXX_DiscardUnknown 

func (m *MsgUpdateEpochDuration) XXX_DiscardUnknown()

func (*MsgUpdateEpochDuration) XXX_Marshal 

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

func (*MsgUpdateEpochDuration) XXX_Merge 

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

func (*MsgUpdateEpochDuration) XXX_Size 

func (m *MsgUpdateEpochDuration) XXX_Size() int

func (*MsgUpdateEpochDuration) XXX_Unmarshal 

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

type MsgUpdateEpochDurationResponse 

type MsgUpdateEpochDurationResponse struct {
}

func (*MsgUpdateEpochDurationResponse) Descriptor 

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

func (*MsgUpdateEpochDurationResponse) Marshal 

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

func (*MsgUpdateEpochDurationResponse) MarshalTo 

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

func (*MsgUpdateEpochDurationResponse) MarshalToSizedBuffer 

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

func (*MsgUpdateEpochDurationResponse) ProtoMessage 

func (*MsgUpdateEpochDurationResponse) ProtoMessage()

func (*MsgUpdateEpochDurationResponse) Reset 

func (m *MsgUpdateEpochDurationResponse) Reset()

func (*MsgUpdateEpochDurationResponse) Size 

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

func (*MsgUpdateEpochDurationResponse) String 

func (m *MsgUpdateEpochDurationResponse) String() string

func (*MsgUpdateEpochDurationResponse) Unmarshal 

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

func (*MsgUpdateEpochDurationResponse) XXX_DiscardUnknown 

func (m *MsgUpdateEpochDurationResponse) XXX_DiscardUnknown()

func (*MsgUpdateEpochDurationResponse) XXX_Marshal 

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

func (*MsgUpdateEpochDurationResponse) XXX_Merge 

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

func (*MsgUpdateEpochDurationResponse) XXX_Size 

func (m *MsgUpdateEpochDurationResponse) XXX_Size() int

func (*MsgUpdateEpochDurationResponse) XXX_Unmarshal 

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

type MsgUpdateParams 

type MsgUpdateParams struct {
	// authority is the address that controls the module (defaults to x/gov unless
	// overwritten).
	Authority string `protobuf:"bytes,1,opt,name=authority,proto3" json:"authority,omitempty"`
	// params defines the x/bridge parameters to update.
	//
	// NOTE: All parameters must be supplied.
	Params Params `protobuf:"bytes,2,opt,name=params,proto3" json:"params"`
}

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

func (m *MsgUpdateParams) Unmarshal(dAtA []byte) 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 {
	Authority string `protobuf:"bytes,1,opt,name=authority,proto3" json:"authority,omitempty"`
}

Params defines the parameters for the module.

func DefaultParams 

func DefaultParams() Params

default bridge module parameters

func NewParams 

func NewParams(authority string) Params

NewParams returns Params instance with the given values.

func (*Params) Descriptor 

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

func (*Params) GetAuthority 

func (m *Params) GetAuthority() string

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 (p Params) String() string

String implements the Stringer interface.

func (*Params) Unmarshal 

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

func (Params) Validate 

func (p Params) Validate() error

validate 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 {
	// Parameters queries the parameters of the module.
	Params(ctx context.Context, in *QueryParamsRequest, opts ...grpc.CallOption) (*QueryParamsResponse, error)
	// Parameters queries the ratelimits of the module.
	RateLimits(ctx context.Context, in *QueryRateLimitsRequest, opts ...grpc.CallOption) (*QueryRateLimitsResponse, error)
	// Parameters queries the ratelimit of a specific denom of the module.
	RateLimit(ctx context.Context, in *QueryRateLimitRequest, opts ...grpc.CallOption) (*QueryRateLimitResponse, error)
	// Parameters queries the epoch info of the module.
	EpochInfo(ctx context.Context, in *QueryEpochInfoRequest, opts ...grpc.CallOption) (*QueryEpochInfoResponse, 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 QueryEpochInfoRequest 

type QueryEpochInfoRequest struct {
}

QueryEpochInfoRequest is request type for the Query/EpochInfo RPC method.

func (*QueryEpochInfoRequest) Descriptor 

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

func (*QueryEpochInfoRequest) Marshal 

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

func (*QueryEpochInfoRequest) MarshalTo 

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

func (*QueryEpochInfoRequest) MarshalToSizedBuffer 

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

func (*QueryEpochInfoRequest) ProtoMessage 

func (*QueryEpochInfoRequest) ProtoMessage()

func (*QueryEpochInfoRequest) Reset 

func (m *QueryEpochInfoRequest) Reset()

func (*QueryEpochInfoRequest) Size 

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

func (*QueryEpochInfoRequest) String 

func (m *QueryEpochInfoRequest) String() string

func (*QueryEpochInfoRequest) Unmarshal 

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

func (*QueryEpochInfoRequest) XXX_DiscardUnknown 

func (m *QueryEpochInfoRequest) XXX_DiscardUnknown()

func (*QueryEpochInfoRequest) XXX_Marshal 

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

func (*QueryEpochInfoRequest) XXX_Merge 

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

func (*QueryEpochInfoRequest) XXX_Size 

func (m *QueryEpochInfoRequest) XXX_Size() int

func (*QueryEpochInfoRequest) XXX_Unmarshal 

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

type QueryEpochInfoResponse 

type QueryEpochInfoResponse struct {
	EpochInfo EpochInfo `protobuf:"bytes,1,opt,name=epoch_info,json=epochInfo,proto3" json:"epoch_info"`
}

QueryEpochInfoResponse is response type for the Query/EpochInfo RPC method.

func (*QueryEpochInfoResponse) Descriptor 

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

func (*QueryEpochInfoResponse) GetEpochInfo 

func (m *QueryEpochInfoResponse) GetEpochInfo() EpochInfo

func (*QueryEpochInfoResponse) Marshal 

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

func (*QueryEpochInfoResponse) MarshalTo 

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

func (*QueryEpochInfoResponse) MarshalToSizedBuffer 

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

func (*QueryEpochInfoResponse) ProtoMessage 

func (*QueryEpochInfoResponse) ProtoMessage()

func (*QueryEpochInfoResponse) Reset 

func (m *QueryEpochInfoResponse) Reset()

func (*QueryEpochInfoResponse) Size 

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

func (*QueryEpochInfoResponse) String 

func (m *QueryEpochInfoResponse) String() string

func (*QueryEpochInfoResponse) Unmarshal 

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

func (*QueryEpochInfoResponse) XXX_DiscardUnknown 

func (m *QueryEpochInfoResponse) XXX_DiscardUnknown()

func (*QueryEpochInfoResponse) XXX_Marshal 

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

func (*QueryEpochInfoResponse) XXX_Merge 

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

func (*QueryEpochInfoResponse) XXX_Size 

func (m *QueryEpochInfoResponse) XXX_Size() int

func (*QueryEpochInfoResponse) XXX_Unmarshal 

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

type QueryParamsRequest 

type QueryParamsRequest struct {
}

QueryParamsRequest is 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 holds all the parameters of this module.
	Params Params `protobuf:"bytes,1,opt,name=params,proto3" json:"params"`
}

QueryParamsResponse is 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 QueryRateLimitRequest 

type QueryRateLimitRequest struct {
	// denom of the coin to query for.
	Denom string `protobuf:"bytes,1,opt,name=denom,proto3" json:"denom,omitempty"`
}

QueryRateLimitRequest is request type for the Query/RateLimit RPC method.

func (*QueryRateLimitRequest) Descriptor 

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

func (*QueryRateLimitRequest) GetDenom 

func (m *QueryRateLimitRequest) GetDenom() string

func (*QueryRateLimitRequest) Marshal 

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

func (*QueryRateLimitRequest) MarshalTo 

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

func (*QueryRateLimitRequest) MarshalToSizedBuffer 

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

func (*QueryRateLimitRequest) ProtoMessage 

func (*QueryRateLimitRequest) ProtoMessage()

func (*QueryRateLimitRequest) Reset 

func (m *QueryRateLimitRequest) Reset()

func (*QueryRateLimitRequest) Size 

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

func (*QueryRateLimitRequest) String 

func (m *QueryRateLimitRequest) String() string

func (*QueryRateLimitRequest) Unmarshal 

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

func (*QueryRateLimitRequest) XXX_DiscardUnknown 

func (m *QueryRateLimitRequest) XXX_DiscardUnknown()

func (*QueryRateLimitRequest) XXX_Marshal 

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

func (*QueryRateLimitRequest) XXX_Merge 

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

func (*QueryRateLimitRequest) XXX_Size 

func (m *QueryRateLimitRequest) XXX_Size() int

func (*QueryRateLimitRequest) XXX_Unmarshal 

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

type QueryRateLimitResponse 

type QueryRateLimitResponse struct {
	Ratelimit RateLimit `protobuf:"bytes,1,opt,name=ratelimit,proto3" json:"ratelimit"`
}

QueryRateLimitResponse is response type for the Query/RateLimit RPC method.

func (*QueryRateLimitResponse) Descriptor 

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

func (*QueryRateLimitResponse) GetRatelimit 

func (m *QueryRateLimitResponse) GetRatelimit() RateLimit

func (*QueryRateLimitResponse) Marshal 

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

func (*QueryRateLimitResponse) MarshalTo 

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

func (*QueryRateLimitResponse) MarshalToSizedBuffer 

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

func (*QueryRateLimitResponse) ProtoMessage 

func (*QueryRateLimitResponse) ProtoMessage()

func (*QueryRateLimitResponse) Reset 

func (m *QueryRateLimitResponse) Reset()

func (*QueryRateLimitResponse) Size 

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

func (*QueryRateLimitResponse) String 

func (m *QueryRateLimitResponse) String() string

func (*QueryRateLimitResponse) Unmarshal 

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

func (*QueryRateLimitResponse) XXX_DiscardUnknown 

func (m *QueryRateLimitResponse) XXX_DiscardUnknown()

func (*QueryRateLimitResponse) XXX_Marshal 

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

func (*QueryRateLimitResponse) XXX_Merge 

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

func (*QueryRateLimitResponse) XXX_Size 

func (m *QueryRateLimitResponse) XXX_Size() int

func (*QueryRateLimitResponse) XXX_Unmarshal 

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

type QueryRateLimitsRequest 

type QueryRateLimitsRequest struct {
}

QueryRateLimitsRequest is request type for the Query/RateLimits RPC method.

func (*QueryRateLimitsRequest) Descriptor 

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

func (*QueryRateLimitsRequest) Marshal 

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

func (*QueryRateLimitsRequest) MarshalTo 

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

func (*QueryRateLimitsRequest) MarshalToSizedBuffer 

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

func (*QueryRateLimitsRequest) ProtoMessage 

func (*QueryRateLimitsRequest) ProtoMessage()

func (*QueryRateLimitsRequest) Reset 

func (m *QueryRateLimitsRequest) Reset()

func (*QueryRateLimitsRequest) Size 

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

func (*QueryRateLimitsRequest) String 

func (m *QueryRateLimitsRequest) String() string

func (*QueryRateLimitsRequest) Unmarshal 

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

func (*QueryRateLimitsRequest) XXX_DiscardUnknown 

func (m *QueryRateLimitsRequest) XXX_DiscardUnknown()

func (*QueryRateLimitsRequest) XXX_Marshal 

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

func (*QueryRateLimitsRequest) XXX_Merge 

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

func (*QueryRateLimitsRequest) XXX_Size 

func (m *QueryRateLimitsRequest) XXX_Size() int

func (*QueryRateLimitsRequest) XXX_Unmarshal 

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

type QueryRateLimitsResponse 

type QueryRateLimitsResponse struct {
	Ratelimits []DenomAndRateLimit `protobuf:"bytes,1,rep,name=ratelimits,proto3" json:"ratelimits"`
}

QueryRateLimitsResponse is response type for the Query/RateLimits RPC method.

func (*QueryRateLimitsResponse) Descriptor 

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

func (*QueryRateLimitsResponse) GetRatelimits 

func (m *QueryRateLimitsResponse) GetRatelimits() []DenomAndRateLimit

func (*QueryRateLimitsResponse) Marshal 

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

func (*QueryRateLimitsResponse) MarshalTo 

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

func (*QueryRateLimitsResponse) MarshalToSizedBuffer 

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

func (*QueryRateLimitsResponse) ProtoMessage 

func (*QueryRateLimitsResponse) ProtoMessage()

func (*QueryRateLimitsResponse) Reset 

func (m *QueryRateLimitsResponse) Reset()

func (*QueryRateLimitsResponse) Size 

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

func (*QueryRateLimitsResponse) String 

func (m *QueryRateLimitsResponse) String() string

func (*QueryRateLimitsResponse) Unmarshal 

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

func (*QueryRateLimitsResponse) XXX_DiscardUnknown 

func (m *QueryRateLimitsResponse) XXX_DiscardUnknown()

func (*QueryRateLimitsResponse) XXX_Marshal 

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

func (*QueryRateLimitsResponse) XXX_Merge 

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

func (*QueryRateLimitsResponse) XXX_Size 

func (m *QueryRateLimitsResponse) XXX_Size() int

func (*QueryRateLimitsResponse) XXX_Unmarshal 

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

type QueryServer 

type QueryServer interface {
	// Parameters queries the parameters of the module.
	Params(context.Context, *QueryParamsRequest) (*QueryParamsResponse, error)
	// Parameters queries the ratelimits of the module.
	RateLimits(context.Context, *QueryRateLimitsRequest) (*QueryRateLimitsResponse, error)
	// Parameters queries the ratelimit of a specific denom of the module.
	RateLimit(context.Context, *QueryRateLimitRequest) (*QueryRateLimitResponse, error)
	// Parameters queries the epoch info of the module.
	EpochInfo(context.Context, *QueryEpochInfoRequest) (*QueryEpochInfoResponse, error)
}

QueryServer is the server API for Query service.

type RateLimit 

type RateLimit struct {
	Ratelimit     cosmossdk_io_math.Int `protobuf:"bytes,1,opt,name=ratelimit,proto3,customtype=cosmossdk.io/math.Int" json:"ratelimit"`
	CurrentInflow cosmossdk_io_math.Int `protobuf:"bytes,2,opt,name=current_inflow,json=currentInflow,proto3,customtype=cosmossdk.io/math.Int" json:"current_inflow"`
}

func (*RateLimit) CheckAddInflowThreshold 

func (r *RateLimit) CheckAddInflowThreshold(amount math.Int) error

Adds an amount to the rate limit's flow after a packet was sent Returns an error if the new inflow will cause the rate limit to exceed its quota

func (*RateLimit) Descriptor 

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

func (*RateLimit) Marshal 

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

func (*RateLimit) MarshalTo 

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

func (*RateLimit) MarshalToSizedBuffer 

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

func (*RateLimit) ProtoMessage 

func (*RateLimit) ProtoMessage()

func (*RateLimit) Reset 

func (m *RateLimit) Reset()

func (*RateLimit) Size 

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

func (*RateLimit) String 

func (m *RateLimit) String() string

func (*RateLimit) Unmarshal 

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

func (*RateLimit) XXX_DiscardUnknown 

func (m *RateLimit) XXX_DiscardUnknown()

func (*RateLimit) XXX_Marshal 

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

func (*RateLimit) XXX_Merge 

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

func (*RateLimit) XXX_Size 

func (m *RateLimit) XXX_Size() int

func (*RateLimit) XXX_Unmarshal 

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

type UnimplementedMsgServer 

type UnimplementedMsgServer struct {
}

UnimplementedMsgServer can be embedded to have forward compatible implementations.

func (*UnimplementedMsgServer) BridgeIn 

func (*UnimplementedMsgServer) BridgeIn(ctx context.Context, req *MsgBridgeIn) (*MsgBridgeInResponse, error)

func (*UnimplementedMsgServer) BridgeOut 

func (*UnimplementedMsgServer) BridgeOut(ctx context.Context, req *MsgBridgeOut) (*MsgBridgeOutResponse, error)

func (*UnimplementedMsgServer) DeregisterCoins 

func (*UnimplementedMsgServer) DeregisterCoins(ctx context.Context, req *MsgDeregisterCoins) (*MsgDeregisterCoinsResponse, error)

func (*UnimplementedMsgServer) RegisterNewCoins 

func (*UnimplementedMsgServer) RegisterNewCoins(ctx context.Context, req *MsgRegisterNewCoins) (*MsgRegisterNewCoinsResponse, error)

func (*UnimplementedMsgServer) UpdateEpochDuration 

func (*UnimplementedMsgServer) UpdateEpochDuration(ctx context.Context, req *MsgUpdateEpochDuration) (*MsgUpdateEpochDurationResponse, 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) EpochInfo 

func (*UnimplementedQueryServer) EpochInfo(ctx context.Context, req *QueryEpochInfoRequest) (*QueryEpochInfoResponse, error)

func (*UnimplementedQueryServer) Params 

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

func (*UnimplementedQueryServer) RateLimit 

func (*UnimplementedQueryServer) RateLimit(ctx context.Context, req *QueryRateLimitRequest) (*QueryRateLimitResponse, error)

func (*UnimplementedQueryServer) RateLimits 

func (*UnimplementedQueryServer) RateLimits(ctx context.Context, req *QueryRateLimitsRequest) (*QueryRateLimitsResponse, 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.