types

package
v0.0.0-...-cd4288d Latest Latest
Warning

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

 Go to latest Published: Jun 20, 2024 License: AGPL-3.0, Apache-2.0 Imports: 35 Imported by: 0

Documentation

Overview

Package types is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

View Source 
const (
	// ModuleName defines the module name
	// Use `ratelimit` instead of `ratelimit` to prevent potential key space conflicts with the IBC module.
	ModuleName = "ratelimit"

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

	// DenomCapacityKeyPrefix is the prefix for the key-value store for DenomCapacity
	DenomCapacityKeyPrefix = "DenomCapacity:"

	// LimitParamsKeyPrefix is the prefix for the key-value store for LimitParams
	LimitParamsKeyPrefix = "LimitParams:"

	// PendingSendPacketPrefix is the prefix for the key-value store for PendingSendPacket.
	PendingSendPacketPrefix = "PendingSendPacket:"
)

Module name and store keys

Variables

View Source 
var (
	ErrInvalidLengthCapacity        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowCapacity          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupCapacity = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	Amino     = codec.NewLegacyAmino()
	ModuleCdc = codec.NewProtoCodec(cdctypes.NewInterfaceRegistry())
)
View Source 
var (
	ErrInvalidAuthority = errorsmod.Register(
		ModuleName,
		1001,
		"Authority is invalid",
	)
	ErrWithdrawalExceedsCapacity = errorsmod.Register(
		ModuleName,
		1002,
		"withdrawal amount would exceed rate-limit capacity",
	)
	ErrMismatchedCapacityLimitersLength = errorsmod.Register(
		ModuleName,
		1003,
		"capacity list length does not match number of limiters",
	)
	ErrInvalidRateLimitPeriod = errorsmod.Register(
		ModuleName,
		1004,
		"rate limit period should be positive",
	)
	ErrInvalidBaselineMinimum = errorsmod.Register(
		ModuleName,
		1005,
		"baseline_minimum should be positive",
	)
	ErrInvalidBaselineTvlPpm = errorsmod.Register(
		ModuleName,
		1006,
		"Baseline_tvl_ppm must in the range (0, 1_000_000)",
	)
	ErrInvalidInput = errorsmod.Register(
		ModuleName,
		1007,
		"Invalid input",
	)
)

x/ratelimit 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 (
	ErrInvalidLengthLimitParams        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowLimitParams          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupLimitParams = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthPendingSendPacket        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowPendingSendPacket          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupPendingSendPacket = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthQuery        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowQuery          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupQuery = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthTx        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTx          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupTx = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var BigBaselineMinimum1Day = new(big.Int).Mul(
	big.NewInt(10_000_000),
	lib.BigPow10(-assettypes.UusdcDenomExponent),
)

BigBaselineMinimum1Day defines the minimum baseline USDC for the 1-day rate-limit.

View Source 
var BigBaselineMinimum1Hr = new(big.Int).Mul(
	big.NewInt(1_000_000),
	lib.BigPow10(-assettypes.UusdcDenomExponent),
)

BigBaselineMinimum1Hr defines the minimum baseline USDC for the 1-hour rate-limit.

View Source 
var DefaultUsdcDailyLimiter = Limiter{
	Period:          24 * time.Hour,
	BaselineMinimum: dtypes.NewIntFromBigInt(BigBaselineMinimum1Day),
	BaselineTvlPpm:  100_000,
}
View Source 
var DefaultUsdcHourlyLimter = Limiter{
	Period:          3600 * time.Second,
	BaselineMinimum: dtypes.NewIntFromBigInt(BigBaselineMinimum1Hr),
	BaselineTvlPpm:  10_000,
}

Functions

func GetPendingSendPacketKey 

func GetPendingSendPacketKey(channelId string, sequenceNumber uint64) []byte

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)

func SplitPendingSendPacketKey 

func SplitPendingSendPacketKey(key []byte) (string, uint64, error)

Types

type AckResponseStatus 

type AckResponseStatus int

AckResponseStatus represents the status of an acknowledgement of IBC transfer packet. 

const (
	AckResponseStatus_NOT_SPECIFIED AckResponseStatus = iota
	AckResponseStatus_SUCCESS
	AckResponseStatus_TIMEOUT
	AckResponseStatus_FAILURE
)

type AcknowledgementResponse 

type AcknowledgementResponse struct {
	Status AckResponseStatus
	Error  string
}

AcknowledgementResponse contains information about an acknowledgement of IBC transfer packet.

type BankKeeper 

type BankKeeper interface {
	GetSupply(ctx context.Context, denom string) sdk.Coin
}

BankKeeper defines the expected bank keeper used for simulations.

type BlockTimeKeeper 

type BlockTimeKeeper interface {
	GetTimeSinceLastBlock(ctx sdk.Context) time.Duration
}

type DenomCapacity 

type DenomCapacity struct {
	// denom is the denomination of the token being rate limited.
	// e.g. ibc/8E27BA2D5493AF5636760E354E46004562C46AB7EC0CC4C1CA14E9E20E2545B5
	Denom string `protobuf:"bytes,1,opt,name=denom,proto3" json:"denom,omitempty"`
	// capacity_list is a list of capacity amount tracked for each `Limiter`
	// on the denom. This list has a 1:1 mapping to `limiter` list under
	// `LimitParams`.
	CapacityList []github_com_StreamFinance_Protocol_stream_chain_protocol_dtypes.SerializableInt `` /* 177-byte string literal not displayed */
}

DenomCapacity stores a list of rate limit capacity for a denom.

func (*DenomCapacity) Descriptor 

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

func (*DenomCapacity) GetDenom 

func (m *DenomCapacity) GetDenom() string

func (*DenomCapacity) Marshal 

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

func (*DenomCapacity) MarshalTo 

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

func (*DenomCapacity) MarshalToSizedBuffer 

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

func (*DenomCapacity) ProtoMessage 

func (*DenomCapacity) ProtoMessage()

func (*DenomCapacity) Reset 

func (m *DenomCapacity) Reset()

func (*DenomCapacity) Size 

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

func (*DenomCapacity) String 

func (m *DenomCapacity) String() string

func (*DenomCapacity) Unmarshal 

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

func (*DenomCapacity) XXX_DiscardUnknown 

func (m *DenomCapacity) XXX_DiscardUnknown()

func (*DenomCapacity) XXX_Marshal 

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

func (*DenomCapacity) XXX_Merge 

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

func (*DenomCapacity) XXX_Size 

func (m *DenomCapacity) XXX_Size() int

func (*DenomCapacity) XXX_Unmarshal 

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

type GenesisState 

type GenesisState struct {
	// limit_params_list defines the list of `LimitParams` at genesis.
	LimitParamsList []LimitParams `protobuf:"bytes,1,rep,name=limit_params_list,json=limitParamsList,proto3" json:"limit_params_list"`
}

GenesisState defines the ratelimit module's genesis state.

func DefaultGenesis 

func DefaultGenesis() *GenesisState

DefaultGenesis returns the default genesis state

func (*GenesisState) Descriptor 

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

func (*GenesisState) GetLimitParamsList 

func (m *GenesisState) GetLimitParamsList() []LimitParams

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 IBCTransferPacketInfo 

type IBCTransferPacketInfo struct {
	ChannelID string
	Denom     string
	Amount    *big.Int
}

IBCTransferPacketInfo contains relevant information from an IBC packet needed for rate-limiting.

type ICS4Wrapper 

type ICS4Wrapper interface {
	WriteAcknowledgement(
		ctx sdk.Context,
		chanCap *capabilitytypes.Capability,
		packet ibcexported.PacketI,
		acknowledgement ibcexported.Acknowledgement,
	) error
	SendPacket(
		ctx sdk.Context,
		chanCap *capabilitytypes.Capability,
		sourcePort string,
		sourceChannel string,
		timeoutHeight clienttypes.Height,
		timeoutTimestamp uint64,
		data []byte,
	) (sequence uint64, err error)
	GetAppVersion(ctx sdk.Context, portID, channelID string) (string, bool)
}

ICS4Wrapper defines the expected ICS4Wrapper for middleware

type LimitParams 

type LimitParams struct {
	// denom is the denomination of the token being rate limited.
	// e.g. ibc/8E27BA2D5493AF5636760E354E46004562C46AB7EC0CC4C1CA14E9E20E2545B5
	Denom string `protobuf:"bytes,1,opt,name=denom,proto3" json:"denom,omitempty"`
	// limiters is a list of rate-limiters on this denom. All limiters
	// must be satified for a withdrawal to proceed.
	Limiters []Limiter `protobuf:"bytes,2,rep,name=limiters,proto3" json:"limiters"`
}

LimitParams defines rate limit params on a denom.

func DefaultUsdcRateLimitParams 

func DefaultUsdcRateLimitParams() LimitParams

DefaultUsdcRateLimitParams returns default rate-limit params for USDC.

func (*LimitParams) Descriptor 

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

func (*LimitParams) GetDenom 

func (m *LimitParams) GetDenom() string

func (*LimitParams) GetLimiters 

func (m *LimitParams) GetLimiters() []Limiter

func (*LimitParams) Marshal 

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

func (*LimitParams) MarshalTo 

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

func (*LimitParams) MarshalToSizedBuffer 

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

func (*LimitParams) ProtoMessage 

func (*LimitParams) ProtoMessage()

func (*LimitParams) Reset 

func (m *LimitParams) Reset()

func (*LimitParams) Size 

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

func (*LimitParams) String 

func (m *LimitParams) String() string

func (*LimitParams) Unmarshal 

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

func (*LimitParams) Validate 

func (p *LimitParams) Validate() error

Validate validates the set of params

func (*LimitParams) XXX_DiscardUnknown 

func (m *LimitParams) XXX_DiscardUnknown()

func (*LimitParams) XXX_Marshal 

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

func (*LimitParams) XXX_Merge 

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

func (*LimitParams) XXX_Size 

func (m *LimitParams) XXX_Size() int

func (*LimitParams) XXX_Unmarshal 

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

type Limiter 

type Limiter struct {
	// period is the rolling time period for which the limit applies
	// e.g. 3600 (an hour)
	Period time.Duration `protobuf:"bytes,1,opt,name=period,proto3,stdduration" json:"period"`
	// baseline_minimum is the minimum maximum withdrawal coin amount within the
	// time period.
	// e.g. 100_000_000_000 uusdc for 100k USDC; 5e22 adv4tnt for 50k DV4TNT
	BaselineMinimum github_com_StreamFinance_Protocol_stream_chain_protocol_dtypes.SerializableInt `` /* 186-byte string literal not displayed */
	// baseline_tvl_ppm is the maximum ratio of TVL withdrawable in
	// the time period, in part-per-million.
	// e.g. 100_000 (10%)
	BaselineTvlPpm uint32 `protobuf:"varint,4,opt,name=baseline_tvl_ppm,json=baselineTvlPpm,proto3" json:"baseline_tvl_ppm,omitempty"`
}

Limiter defines one rate-limiter on a specfic denom.

func (*Limiter) Descriptor 

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

func (*Limiter) GetBaselineTvlPpm 

func (m *Limiter) GetBaselineTvlPpm() uint32

func (*Limiter) GetPeriod 

func (m *Limiter) GetPeriod() time.Duration

func (*Limiter) Marshal 

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

func (*Limiter) MarshalTo 

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

func (*Limiter) MarshalToSizedBuffer 

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

func (*Limiter) ProtoMessage 

func (*Limiter) ProtoMessage()

func (*Limiter) Reset 

func (m *Limiter) Reset()

func (*Limiter) Size 

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

func (*Limiter) String 

func (m *Limiter) String() string

func (*Limiter) Unmarshal 

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

func (*Limiter) XXX_DiscardUnknown 

func (m *Limiter) XXX_DiscardUnknown()

func (*Limiter) XXX_Marshal 

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

func (*Limiter) XXX_Merge 

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

func (*Limiter) XXX_Size 

func (m *Limiter) XXX_Size() int

func (*Limiter) XXX_Unmarshal 

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

type LimiterCapacity 

type LimiterCapacity struct {
	Limiter  Limiter                                                                        `protobuf:"bytes,1,opt,name=limiter,proto3" json:"limiter"`
	Capacity github_com_StreamFinance_Protocol_stream_chain_protocol_dtypes.SerializableInt `` /* 149-byte string literal not displayed */
}

LimiterCapacity contains a pair of limiter and its corresponding capacity.

func (*LimiterCapacity) Descriptor 

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

func (*LimiterCapacity) GetLimiter 

func (m *LimiterCapacity) GetLimiter() Limiter

func (*LimiterCapacity) Marshal 

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

func (*LimiterCapacity) MarshalTo 

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

func (*LimiterCapacity) MarshalToSizedBuffer 

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

func (*LimiterCapacity) ProtoMessage 

func (*LimiterCapacity) ProtoMessage()

func (*LimiterCapacity) Reset 

func (m *LimiterCapacity) Reset()

func (*LimiterCapacity) Size 

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

func (*LimiterCapacity) String 

func (m *LimiterCapacity) String() string

func (*LimiterCapacity) Unmarshal 

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

func (*LimiterCapacity) XXX_DiscardUnknown 

func (m *LimiterCapacity) XXX_DiscardUnknown()

func (*LimiterCapacity) XXX_Marshal 

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

func (*LimiterCapacity) XXX_Merge 

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

func (*LimiterCapacity) XXX_Size 

func (m *LimiterCapacity) XXX_Size() int

func (*LimiterCapacity) XXX_Unmarshal 

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

type ListLimitParamsRequest 

type ListLimitParamsRequest struct {
}

ListLimitParamsRequest is a request type of the ListLimitParams RPC method.

func (*ListLimitParamsRequest) Descriptor 

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

func (*ListLimitParamsRequest) Marshal 

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

func (*ListLimitParamsRequest) MarshalTo 

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

func (*ListLimitParamsRequest) MarshalToSizedBuffer 

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

func (*ListLimitParamsRequest) ProtoMessage 

func (*ListLimitParamsRequest) ProtoMessage()

func (*ListLimitParamsRequest) Reset 

func (m *ListLimitParamsRequest) Reset()

func (*ListLimitParamsRequest) Size 

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

func (*ListLimitParamsRequest) String 

func (m *ListLimitParamsRequest) String() string

func (*ListLimitParamsRequest) Unmarshal 

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

func (*ListLimitParamsRequest) XXX_DiscardUnknown 

func (m *ListLimitParamsRequest) XXX_DiscardUnknown()

func (*ListLimitParamsRequest) XXX_Marshal 

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

func (*ListLimitParamsRequest) XXX_Merge 

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

func (*ListLimitParamsRequest) XXX_Size 

func (m *ListLimitParamsRequest) XXX_Size() int

func (*ListLimitParamsRequest) XXX_Unmarshal 

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

type ListLimitParamsResponse 

type ListLimitParamsResponse struct {
	LimitParamsList []LimitParams `protobuf:"bytes,1,rep,name=limit_params_list,json=limitParamsList,proto3" json:"limit_params_list"`
}

ListLimitParamsResponse is a response type of the ListLimitParams RPC method.

func (*ListLimitParamsResponse) Descriptor 

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

func (*ListLimitParamsResponse) GetLimitParamsList 

func (m *ListLimitParamsResponse) GetLimitParamsList() []LimitParams

func (*ListLimitParamsResponse) Marshal 

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

func (*ListLimitParamsResponse) MarshalTo 

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

func (*ListLimitParamsResponse) MarshalToSizedBuffer 

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

func (*ListLimitParamsResponse) ProtoMessage 

func (*ListLimitParamsResponse) ProtoMessage()

func (*ListLimitParamsResponse) Reset 

func (m *ListLimitParamsResponse) Reset()

func (*ListLimitParamsResponse) Size 

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

func (*ListLimitParamsResponse) String 

func (m *ListLimitParamsResponse) String() string

func (*ListLimitParamsResponse) Unmarshal 

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

func (*ListLimitParamsResponse) XXX_DiscardUnknown 

func (m *ListLimitParamsResponse) XXX_DiscardUnknown()

func (*ListLimitParamsResponse) XXX_Marshal 

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

func (*ListLimitParamsResponse) XXX_Merge 

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

func (*ListLimitParamsResponse) XXX_Size 

func (m *ListLimitParamsResponse) XXX_Size() int

func (*ListLimitParamsResponse) XXX_Unmarshal 

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

type MsgClient 

type MsgClient interface {
	// SetLimitParams sets a `LimitParams` object in state.
	SetLimitParams(ctx context.Context, in *MsgSetLimitParams, opts ...grpc.CallOption) (*MsgSetLimitParamsResponse, 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 MsgServer 

type MsgServer interface {
	// SetLimitParams sets a `LimitParams` object in state.
	SetLimitParams(context.Context, *MsgSetLimitParams) (*MsgSetLimitParamsResponse, error)
}

MsgServer is the server API for Msg service.

type MsgSetLimitParams 

type MsgSetLimitParams struct {
	Authority string `protobuf:"bytes,1,opt,name=authority,proto3" json:"authority,omitempty"`
	// Defines the parameters to set. All parameters must be supplied.
	LimitParams LimitParams `protobuf:"bytes,2,opt,name=limit_params,json=limitParams,proto3" json:"limit_params"`
}

MsgSetLimitParams is the Msg/SetLimitParams request type.

func (*MsgSetLimitParams) Descriptor 

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

func (*MsgSetLimitParams) GetAuthority 

func (m *MsgSetLimitParams) GetAuthority() string

func (*MsgSetLimitParams) GetLimitParams 

func (m *MsgSetLimitParams) GetLimitParams() LimitParams

func (*MsgSetLimitParams) GetSigners 

func (msg *MsgSetLimitParams) GetSigners() []sdk.AccAddress

func (*MsgSetLimitParams) Marshal 

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

func (*MsgSetLimitParams) MarshalTo 

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

func (*MsgSetLimitParams) MarshalToSizedBuffer 

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

func (*MsgSetLimitParams) ProtoMessage 

func (*MsgSetLimitParams) ProtoMessage()

func (*MsgSetLimitParams) Reset 

func (m *MsgSetLimitParams) Reset()

func (*MsgSetLimitParams) Size 

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

func (*MsgSetLimitParams) String 

func (m *MsgSetLimitParams) String() string

func (*MsgSetLimitParams) Unmarshal 

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

func (*MsgSetLimitParams) ValidateBasic 

func (msg *MsgSetLimitParams) ValidateBasic() error

func (*MsgSetLimitParams) XXX_DiscardUnknown 

func (m *MsgSetLimitParams) XXX_DiscardUnknown()

func (*MsgSetLimitParams) XXX_Marshal 

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

func (*MsgSetLimitParams) XXX_Merge 

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

func (*MsgSetLimitParams) XXX_Size 

func (m *MsgSetLimitParams) XXX_Size() int

func (*MsgSetLimitParams) XXX_Unmarshal 

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

type MsgSetLimitParamsResponse 

type MsgSetLimitParamsResponse struct {
}

MsgSetLimitParamsResponse is the Msg/SetLimitParams response type.

func (*MsgSetLimitParamsResponse) Descriptor 

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

func (*MsgSetLimitParamsResponse) Marshal 

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

func (*MsgSetLimitParamsResponse) MarshalTo 

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

func (*MsgSetLimitParamsResponse) MarshalToSizedBuffer 

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

func (*MsgSetLimitParamsResponse) ProtoMessage 

func (*MsgSetLimitParamsResponse) ProtoMessage()

func (*MsgSetLimitParamsResponse) Reset 

func (m *MsgSetLimitParamsResponse) Reset()

func (*MsgSetLimitParamsResponse) Size 

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

func (*MsgSetLimitParamsResponse) String 

func (m *MsgSetLimitParamsResponse) String() string

func (*MsgSetLimitParamsResponse) Unmarshal 

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

func (*MsgSetLimitParamsResponse) XXX_DiscardUnknown 

func (m *MsgSetLimitParamsResponse) XXX_DiscardUnknown()

func (*MsgSetLimitParamsResponse) XXX_Marshal 

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

func (*MsgSetLimitParamsResponse) XXX_Merge 

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

func (*MsgSetLimitParamsResponse) XXX_Size 

func (m *MsgSetLimitParamsResponse) XXX_Size() int

func (*MsgSetLimitParamsResponse) XXX_Unmarshal 

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

type PacketDirection 

type PacketDirection int32
const (
	PACKET_SEND PacketDirection = 0
	PACKET_RECV PacketDirection = 1
)

type PendingSendPacket 

type PendingSendPacket struct {
	ChannelId string `protobuf:"bytes,1,opt,name=channel_id,json=channelId,proto3" json:"channel_id,omitempty"`
	Sequence  uint64 `protobuf:"varint,2,opt,name=sequence,proto3" json:"sequence,omitempty"`
}

PendingSendPacket contains the channel_id and sequence pair to identify a pending packet

func (*PendingSendPacket) Descriptor 

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

func (*PendingSendPacket) GetChannelId 

func (m *PendingSendPacket) GetChannelId() string

func (*PendingSendPacket) GetSequence 

func (m *PendingSendPacket) GetSequence() uint64

func (*PendingSendPacket) Marshal 

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

func (*PendingSendPacket) MarshalTo 

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

func (*PendingSendPacket) MarshalToSizedBuffer 

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

func (*PendingSendPacket) ProtoMessage 

func (*PendingSendPacket) ProtoMessage()

func (*PendingSendPacket) Reset 

func (m *PendingSendPacket) Reset()

func (*PendingSendPacket) Size 

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

func (*PendingSendPacket) String 

func (m *PendingSendPacket) String() string

func (*PendingSendPacket) Unmarshal 

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

func (*PendingSendPacket) XXX_DiscardUnknown 

func (m *PendingSendPacket) XXX_DiscardUnknown()

func (*PendingSendPacket) XXX_Marshal 

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

func (*PendingSendPacket) XXX_Merge 

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

func (*PendingSendPacket) XXX_Size 

func (m *PendingSendPacket) XXX_Size() int

func (*PendingSendPacket) XXX_Unmarshal 

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

type QueryAllPendingSendPacketsRequest 

type QueryAllPendingSendPacketsRequest struct {
}

QueryAllPendingSendPacketsRequest is a request type for the AllPendingSendPackets RPC

func (*QueryAllPendingSendPacketsRequest) Descriptor 

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

func (*QueryAllPendingSendPacketsRequest) Marshal 

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

func (*QueryAllPendingSendPacketsRequest) MarshalTo 

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

func (*QueryAllPendingSendPacketsRequest) MarshalToSizedBuffer 

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

func (*QueryAllPendingSendPacketsRequest) ProtoMessage 

func (*QueryAllPendingSendPacketsRequest) ProtoMessage()

func (*QueryAllPendingSendPacketsRequest) Reset 

func (m *QueryAllPendingSendPacketsRequest) Reset()

func (*QueryAllPendingSendPacketsRequest) Size 

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

func (*QueryAllPendingSendPacketsRequest) String 

func (m *QueryAllPendingSendPacketsRequest) String() string

func (*QueryAllPendingSendPacketsRequest) Unmarshal 

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

func (*QueryAllPendingSendPacketsRequest) XXX_DiscardUnknown 

func (m *QueryAllPendingSendPacketsRequest) XXX_DiscardUnknown()

func (*QueryAllPendingSendPacketsRequest) XXX_Marshal 

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

func (*QueryAllPendingSendPacketsRequest) XXX_Merge 

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

func (*QueryAllPendingSendPacketsRequest) XXX_Size 

func (m *QueryAllPendingSendPacketsRequest) XXX_Size() int

func (*QueryAllPendingSendPacketsRequest) XXX_Unmarshal 

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

type QueryAllPendingSendPacketsResponse 

type QueryAllPendingSendPacketsResponse struct {
	PendingSendPackets []PendingSendPacket `protobuf:"bytes,1,rep,name=pending_send_packets,json=pendingSendPackets,proto3" json:"pending_send_packets"`
}

QueryAllPendingSendPacketsResponse is a response type of the AllPendingSendPackets RPC

func (*QueryAllPendingSendPacketsResponse) Descriptor 

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

func (*QueryAllPendingSendPacketsResponse) GetPendingSendPackets 

func (m *QueryAllPendingSendPacketsResponse) GetPendingSendPackets() []PendingSendPacket

func (*QueryAllPendingSendPacketsResponse) Marshal 

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

func (*QueryAllPendingSendPacketsResponse) MarshalTo 

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

func (*QueryAllPendingSendPacketsResponse) MarshalToSizedBuffer 

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

func (*QueryAllPendingSendPacketsResponse) ProtoMessage 

func (*QueryAllPendingSendPacketsResponse) ProtoMessage()

func (*QueryAllPendingSendPacketsResponse) Reset 

func (m *QueryAllPendingSendPacketsResponse) Reset()

func (*QueryAllPendingSendPacketsResponse) Size 

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

func (*QueryAllPendingSendPacketsResponse) String 

func (m *QueryAllPendingSendPacketsResponse) String() string

func (*QueryAllPendingSendPacketsResponse) Unmarshal 

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

func (*QueryAllPendingSendPacketsResponse) XXX_DiscardUnknown 

func (m *QueryAllPendingSendPacketsResponse) XXX_DiscardUnknown()

func (*QueryAllPendingSendPacketsResponse) XXX_Marshal 

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

func (*QueryAllPendingSendPacketsResponse) XXX_Merge 

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

func (*QueryAllPendingSendPacketsResponse) XXX_Size 

func (m *QueryAllPendingSendPacketsResponse) XXX_Size() int

func (*QueryAllPendingSendPacketsResponse) XXX_Unmarshal 

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

type QueryCapacityByDenomRequest 

type QueryCapacityByDenomRequest struct {
	Denom string `protobuf:"bytes,1,opt,name=denom,proto3" json:"denom,omitempty"`
}

QueryCapacityByDenomRequest is a request type for the CapacityByDenom RPC method.

func (*QueryCapacityByDenomRequest) Descriptor 

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

func (*QueryCapacityByDenomRequest) GetDenom 

func (m *QueryCapacityByDenomRequest) GetDenom() string

func (*QueryCapacityByDenomRequest) Marshal 

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

func (*QueryCapacityByDenomRequest) MarshalTo 

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

func (*QueryCapacityByDenomRequest) MarshalToSizedBuffer 

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

func (*QueryCapacityByDenomRequest) ProtoMessage 

func (*QueryCapacityByDenomRequest) ProtoMessage()

func (*QueryCapacityByDenomRequest) Reset 

func (m *QueryCapacityByDenomRequest) Reset()

func (*QueryCapacityByDenomRequest) Size 

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

func (*QueryCapacityByDenomRequest) String 

func (m *QueryCapacityByDenomRequest) String() string

func (*QueryCapacityByDenomRequest) Unmarshal 

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

func (*QueryCapacityByDenomRequest) XXX_DiscardUnknown 

func (m *QueryCapacityByDenomRequest) XXX_DiscardUnknown()

func (*QueryCapacityByDenomRequest) XXX_Marshal 

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

func (*QueryCapacityByDenomRequest) XXX_Merge 

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

func (*QueryCapacityByDenomRequest) XXX_Size 

func (m *QueryCapacityByDenomRequest) XXX_Size() int

func (*QueryCapacityByDenomRequest) XXX_Unmarshal 

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

type QueryCapacityByDenomResponse 

type QueryCapacityByDenomResponse struct {
	LimiterCapacityList []LimiterCapacity `protobuf:"bytes,1,rep,name=limiter_capacity_list,json=limiterCapacityList,proto3" json:"limiter_capacity_list"`
}

QueryCapacityByDenomResponse is a response type of the CapacityByDenom RPC method.

func (*QueryCapacityByDenomResponse) Descriptor 

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

func (*QueryCapacityByDenomResponse) GetLimiterCapacityList 

func (m *QueryCapacityByDenomResponse) GetLimiterCapacityList() []LimiterCapacity

func (*QueryCapacityByDenomResponse) Marshal 

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

func (*QueryCapacityByDenomResponse) MarshalTo 

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

func (*QueryCapacityByDenomResponse) MarshalToSizedBuffer 

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

func (*QueryCapacityByDenomResponse) ProtoMessage 

func (*QueryCapacityByDenomResponse) ProtoMessage()

func (*QueryCapacityByDenomResponse) Reset 

func (m *QueryCapacityByDenomResponse) Reset()

func (*QueryCapacityByDenomResponse) Size 

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

func (*QueryCapacityByDenomResponse) String 

func (m *QueryCapacityByDenomResponse) String() string

func (*QueryCapacityByDenomResponse) Unmarshal 

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

func (*QueryCapacityByDenomResponse) XXX_DiscardUnknown 

func (m *QueryCapacityByDenomResponse) XXX_DiscardUnknown()

func (*QueryCapacityByDenomResponse) XXX_Marshal 

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

func (*QueryCapacityByDenomResponse) XXX_Merge 

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

func (*QueryCapacityByDenomResponse) XXX_Size 

func (m *QueryCapacityByDenomResponse) XXX_Size() int

func (*QueryCapacityByDenomResponse) XXX_Unmarshal 

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

type QueryClient 

type QueryClient interface {
	// List all limit params.
	ListLimitParams(ctx context.Context, in *ListLimitParamsRequest, opts ...grpc.CallOption) (*ListLimitParamsResponse, error)
	// Query capacity by denom.
	CapacityByDenom(ctx context.Context, in *QueryCapacityByDenomRequest, opts ...grpc.CallOption) (*QueryCapacityByDenomResponse, error)
	// Get all pending send packets
	AllPendingSendPackets(ctx context.Context, in *QueryAllPendingSendPacketsRequest, opts ...grpc.CallOption) (*QueryAllPendingSendPacketsResponse, error)
}

QueryClient is the client API for Query service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewQueryClient 

func NewQueryClient(cc grpc1.ClientConn) QueryClient

type QueryServer 

type QueryServer interface {
	// List all limit params.
	ListLimitParams(context.Context, *ListLimitParamsRequest) (*ListLimitParamsResponse, error)
	// Query capacity by denom.
	CapacityByDenom(context.Context, *QueryCapacityByDenomRequest) (*QueryCapacityByDenomResponse, error)
	// Get all pending send packets
	AllPendingSendPackets(context.Context, *QueryAllPendingSendPacketsRequest) (*QueryAllPendingSendPacketsResponse, 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) SetLimitParams 

func (*UnimplementedMsgServer) SetLimitParams(ctx context.Context, req *MsgSetLimitParams) (*MsgSetLimitParamsResponse, error)

type UnimplementedQueryServer 

type UnimplementedQueryServer struct {
}

UnimplementedQueryServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryServer) AllPendingSendPackets 

func (*UnimplementedQueryServer) AllPendingSendPackets(ctx context.Context, req *QueryAllPendingSendPacketsRequest) (*QueryAllPendingSendPacketsResponse, error)

func (*UnimplementedQueryServer) CapacityByDenom 

func (*UnimplementedQueryServer) CapacityByDenom(ctx context.Context, req *QueryCapacityByDenomRequest) (*QueryCapacityByDenomResponse, error)

func (*UnimplementedQueryServer) ListLimitParams 

func (*UnimplementedQueryServer) ListLimitParams(ctx context.Context, req *ListLimitParamsRequest) (*ListLimitParamsResponse, 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.