types

package
v1.7.0-rc01 Latest Latest
Warning

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

 Go to latest Published: Aug 13, 2024 License: Apache-2.0 Imports: 38 Imported by: 0

Documentation

Overview

Package types is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

View Source 
const (
	EventTypeCreateGasTank       = "create_gas_tank"
	EventTypeUpdateGasTankStatus = "update_gas_tank_status"
	EventTypeUpdateGasTankConfig = "update_gas_tank_config"
	EventTypeBlockConsumer       = "block_consumer"
	EventTypeUnblockConsumer     = "unblock_consumer"
	EventTypeFeeConsumption      = "fee_consumption"

	AttributeKeyCreator                = "creator"
	AttributeKeyProvider               = "provider"
	AttributeKeyConsumer               = "consumer"
	AttributeKeyGasTankID              = "gas_tank_id"
	AttributeKeyFeeDenom               = "fee_denom"
	AttributeKeyGasTankStatus          = "gas_tank_status"
	AttributeKeyMaxFeeUsagePerTx       = "max_fee_usage_per_tx"
	AttributeKeyMaxFeeUsagePerConsumer = "max_fee_usage_per_consumer"
	AttributeKeyUsageIdentifiers       = "usage_identifiers"
	AttributeKeyFeeConsumptionMessage  = "message"
	AttributeKeyFeeSource              = "fee_source"
	AttributeKeyFailedGasTankIDs       = "failed_gas_tank_ids"
	AttributeKeyFailedGasTankErrors    = "failed_gas_tank_errors"
	AttributeKeySucceededGtid          = "succeeded_gas_tank_id"
)

Event types for the gasless module.

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

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

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

	// QuerierRoute defines the module's query routing key.
	QuerierRoute = ModuleName
)
View Source 
const (
	TypeMsgCreateGasTank          = "create_gas_tank"
	TypeMsgUpdateGasTankStatus    = "update_gas_tank_status"
	TypeMsgUpdateGasTankConfig    = "update_gas_tank_config"
	TypeMsgBlockConsumer          = "block_consumer"
	TypeMsgUnblockConsumer        = "unblock_consumer"
	TypeMsgUpdateGasConsumerLimit = "update_gas_consumer_limit"
)

Message types for the gasless module.

View Source 
const (
	GasTankAddressPrefix      = "GasTankAddress"
	ModuleAddressNameSplitter = "|"
)

Variables

View Source 
var (
	ErrInvalidLengthGasless        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowGasless          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupGasless = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthGenesis        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowGenesis          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupGenesis = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	UsageIdentifierToGasTankIdsKeyPrefix = []byte{0xa0}
	LastGasTankIDKey                     = []byte{0xa1}
	GasTankKeyPrefix                     = []byte{0xa2}
	GasConsumerKeyPrefix                 = []byte{0xa3}
)
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 (
	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 (
	DefaultMinimumGasDeposit = sdk.NewCoins(sdk.NewCoin(sdk.DefaultBondDenom, sdkmath.NewInt(10_000_000)))
)

gasless module's params default values

View Source 
var (
	ErrorFeeConsumptionFailure = sdkerrors.Register(ModuleName, 10001, "fee cannot be deducted from gas tank")
)
View Source 
var (
	KeyMinimumGasDeposit = []byte("MinimumGasDeposit")
)
View Source 
var (
	ModuleCdc = codec.NewAminoCodec(amino)
)

Functions

func BaseValidation 

func BaseValidation(
	gasTankID uint64,
	provider, consumer string,
) error

func DeriveGasTankReserveAddress 

func DeriveGasTankReserveAddress(gasTankID uint64) sdk.AccAddress

func GetAllGasConsumersKey 

func GetAllGasConsumersKey() []byte

func GetAllGasTanksKey 

func GetAllGasTanksKey() []byte

func GetAllUsageIdentifierToGasTankIdsKey 

func GetAllUsageIdentifierToGasTankIdsKey() []byte

func GetGasConsumerKey 

func GetGasConsumerKey(consumer sdk.AccAddress) []byte

func GetGasTankKey 

func GetGasTankKey(gasTankID uint64) []byte

func GetLastGasTankIDKey 

func GetLastGasTankIDKey() []byte

func GetUsageIdentifierToGasTankIdsKey 

func GetUsageIdentifierToGasTankIdsKey(usageIdentifier string) []byte

func LengthPrefixString 

func LengthPrefixString(s string) []byte

LengthPrefixString returns length-prefixed bytes representation of a string.

func MustMarshalGasConsumer 

func MustMarshalGasConsumer(cdc codec.BinaryCodec, gasConsumer GasConsumer) []byte

MustMarshalGasConsumer returns the GasConsumer bytes. It throws panic if it fails.

func MustMarshalGasTank 

func MustMarshalGasTank(cdc codec.BinaryCodec, gasTank GasTank) []byte

MustMarshalGasTank returns the GasTank bytes. It throws panic if it fails.

func MustMarshalUsageIdentifierToGastankIds 

func MustMarshalUsageIdentifierToGastankIds(cdc codec.BinaryCodec, usageIdentifierToGastankIds UsageIdentifierToGasTankIds) []byte

MustMarshalUsageIdentifierToGastankIds returns the UsageIdentifierToGasTankIds bytes. It throws panic if it fails.

func ParamKeyTable 

func ParamKeyTable() paramstypes.KeyTable

func RegisterInterfaces 

func RegisterInterfaces(registry cdctypes.InterfaceRegistry)

RegisterInterfaces registers the x/gasless interfaces types with the interface registry.

func RegisterLegacyAminoCodec 

func RegisterLegacyAminoCodec(cdc *codec.LegacyAmino)

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

func RegisterMsgServer 

func RegisterMsgServer(s grpc1.Server, srv MsgServer)

func RegisterQueryHandler 

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

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

func RegisterQueryHandlerClient 

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

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

func RegisterQueryHandlerFromEndpoint 

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

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

func RegisterQueryHandlerServer 

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

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

func RegisterQueryServer 

func RegisterQueryServer(s grpc1.Server, srv QueryServer)

Types

type BankKeeper 

type BankKeeper interface {
	GetBalance(ctx sdk.Context, addr sdk.AccAddress, denom string) sdk.Coin
	SendCoins(ctx sdk.Context, fromAddr, toAddr sdk.AccAddress, amt sdk.Coins) error
	SendCoinsFromAccountToModule(ctx sdk.Context, senderAddr sdk.AccAddress, recipientModule string, amt sdk.Coins) error
	BurnCoins(ctx sdk.Context, moduleName string, amt sdk.Coins) error
}

BankKeeper is the expected bank keeper.

type ConsumptionDetail 

type ConsumptionDetail struct {
	// gas_tank_id defines the if of the gas tank
	GasTankId uint64 `protobuf:"varint,1,opt,name=gas_tank_id,json=gasTankId,proto3" json:"gas_tank_id,omitempty"`
	// is_blocked defines if the consumer is blocked or not by the gas tank
	IsBlocked bool `protobuf:"varint,2,opt,name=is_blocked,json=isBlocked,proto3" json:"is_blocked,omitempty"`
	// total_fee_consumption_allowed defines the maximum fee consumption allowed by the gas tank to the consumer
	TotalFeeConsumptionAllowed github_com_cosmos_cosmos_sdk_types.Int `` /* 183-byte string literal not displayed */
	// total_fees_consumed defines the total fee consumed so far by the consumer in this gas tank
	TotalFeesConsumed github_com_cosmos_cosmos_sdk_types.Int `` /* 154-byte string literal not displayed */
	// usage defines the usage of gas within this gas tank
	Usage []*Usage `protobuf:"bytes,5,rep,name=usage,proto3" json:"usage,omitempty"`
}

GasConsumer > ConsumptionDetail defines the usage statistics of the consumer within each gas tank

func NewConsumptionDetail 

func NewConsumptionDetail(
	gasTankID uint64,
	totalFeeConsumptionAllowed sdkmath.Int,
) *ConsumptionDetail

func (*ConsumptionDetail) Descriptor 

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

func (*ConsumptionDetail) Marshal 

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

func (*ConsumptionDetail) MarshalTo 

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

func (*ConsumptionDetail) MarshalToSizedBuffer 

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

func (*ConsumptionDetail) ProtoMessage 

func (*ConsumptionDetail) ProtoMessage()

func (*ConsumptionDetail) Reset 

func (m *ConsumptionDetail) Reset()

func (*ConsumptionDetail) Size 

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

func (*ConsumptionDetail) String 

func (m *ConsumptionDetail) String() string

func (*ConsumptionDetail) Unmarshal 

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

func (*ConsumptionDetail) XXX_DiscardUnknown 

func (m *ConsumptionDetail) XXX_DiscardUnknown()

func (*ConsumptionDetail) XXX_Marshal 

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

func (*ConsumptionDetail) XXX_Merge 

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

func (*ConsumptionDetail) XXX_Size 

func (m *ConsumptionDetail) XXX_Size() int

func (*ConsumptionDetail) XXX_Unmarshal 

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

type ContractDetails 

type ContractDetails struct {
	CodeId  uint64 `protobuf:"varint,1,opt,name=code_id,json=codeId,proto3" json:"code_id,omitempty"`
	Address string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
	Label   string `protobuf:"bytes,3,opt,name=label,proto3" json:"label,omitempty"`
}

ContractDetails defines specific contract details

func (*ContractDetails) Descriptor 

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

func (*ContractDetails) GetAddress 

func (m *ContractDetails) GetAddress() string

func (*ContractDetails) GetCodeId 

func (m *ContractDetails) GetCodeId() uint64

func (*ContractDetails) GetLabel 

func (m *ContractDetails) GetLabel() string

func (*ContractDetails) Marshal 

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

func (*ContractDetails) MarshalTo 

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

func (*ContractDetails) MarshalToSizedBuffer 

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

func (*ContractDetails) ProtoMessage 

func (*ContractDetails) ProtoMessage()

func (*ContractDetails) Reset 

func (m *ContractDetails) Reset()

func (*ContractDetails) Size 

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

func (*ContractDetails) String 

func (m *ContractDetails) String() string

func (*ContractDetails) Unmarshal 

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

func (*ContractDetails) XXX_DiscardUnknown 

func (m *ContractDetails) XXX_DiscardUnknown()

func (*ContractDetails) XXX_Marshal 

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

func (*ContractDetails) XXX_Merge 

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

func (*ContractDetails) XXX_Size 

func (m *ContractDetails) XXX_Size() int

func (*ContractDetails) XXX_Unmarshal 

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

type Detail 

type Detail struct {
	// timestamp defines the timestamp at which the fee was consumed
	Timestamp time.Time `protobuf:"bytes,1,opt,name=timestamp,proto3,stdtime" json:"timestamp"`
	// gas_consumed defines the amount of fee consumed by the tx
	GasConsumed github_com_cosmos_cosmos_sdk_types.Int `` /* 134-byte string literal not displayed */
}

GasConsumer > ConsumptionDetail > Usage > Detail stores the consumption activity of the consumer

func (*Detail) Descriptor 

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

func (*Detail) Marshal 

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

func (*Detail) MarshalTo 

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

func (*Detail) MarshalToSizedBuffer 

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

func (*Detail) ProtoMessage 

func (*Detail) ProtoMessage()

func (*Detail) Reset 

func (m *Detail) Reset()

func (*Detail) Size 

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

func (*Detail) String 

func (m *Detail) String() string

func (*Detail) Unmarshal 

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

func (*Detail) XXX_DiscardUnknown 

func (m *Detail) XXX_DiscardUnknown()

func (*Detail) XXX_Marshal 

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

func (*Detail) XXX_Merge 

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

func (*Detail) XXX_Size 

func (m *Detail) XXX_Size() int

func (*Detail) XXX_Unmarshal 

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

type GasConsumer 

type GasConsumer struct {
	// bech32 encoded address of the consumer
	Consumer string `protobuf:"bytes,1,opt,name=consumer,proto3" json:"consumer,omitempty"`
	// consumtion statistics of the consumer
	Consumptions []*ConsumptionDetail `protobuf:"bytes,2,rep,name=consumptions,proto3" json:"consumptions,omitempty"`
}

GasConsumer stores the consumer address and all the gas consumption activities within the gas tank

func MustUnmarshalGasConsumer 

func MustUnmarshalGasConsumer(cdc codec.BinaryCodec, value []byte) GasConsumer

MustUnmarshalGasConsumer return the unmarshalled GasConsumer from bytes. It throws panic if it fails.

func NewGasConsumer 

func NewGasConsumer(
	consumer sdk.AccAddress,
) GasConsumer

func UnmarshalGasConsumer 

func UnmarshalGasConsumer(cdc codec.BinaryCodec, value []byte) (gasConsumer GasConsumer, err error)

UnmarshalGasConsumer returns the GasConsumer from bytes.

func (*GasConsumer) Descriptor 

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

func (*GasConsumer) Marshal 

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

func (*GasConsumer) MarshalTo 

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

func (*GasConsumer) MarshalToSizedBuffer 

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

func (*GasConsumer) ProtoMessage 

func (*GasConsumer) ProtoMessage()

func (*GasConsumer) Reset 

func (m *GasConsumer) Reset()

func (*GasConsumer) Size 

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

func (*GasConsumer) String 

func (m *GasConsumer) String() string

func (*GasConsumer) Unmarshal 

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

func (GasConsumer) Validate 

func (gasConsumer GasConsumer) Validate() error

func (*GasConsumer) XXX_DiscardUnknown 

func (m *GasConsumer) XXX_DiscardUnknown()

func (*GasConsumer) XXX_Marshal 

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

func (*GasConsumer) XXX_Merge 

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

func (*GasConsumer) XXX_Size 

func (m *GasConsumer) XXX_Size() int

func (*GasConsumer) XXX_Unmarshal 

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

type GasConsumersByGasTankIDResponse 

type GasConsumersByGasTankIDResponse struct {
	Consumer                   string     `protobuf:"bytes,1,opt,name=consumer,proto3" json:"consumer,omitempty"`
	IsBlocked                  bool       `protobuf:"varint,2,opt,name=is_blocked,json=isBlocked,proto3" json:"is_blocked,omitempty"`
	TotalFeeConsumptionAllowed types.Coin `` /* 133-byte string literal not displayed */
	TotalFeesConsumed          types.Coin `protobuf:"bytes,4,opt,name=total_fees_consumed,json=totalFeesConsumed,proto3" json:"total_fees_consumed"`
	Usage                      []*Usage   `protobuf:"bytes,5,rep,name=usage,proto3" json:"usage,omitempty"`
}

func (*GasConsumersByGasTankIDResponse) Descriptor 

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

func (*GasConsumersByGasTankIDResponse) GetConsumer 

func (m *GasConsumersByGasTankIDResponse) GetConsumer() string

func (*GasConsumersByGasTankIDResponse) GetIsBlocked 

func (m *GasConsumersByGasTankIDResponse) GetIsBlocked() bool

func (*GasConsumersByGasTankIDResponse) GetTotalFeeConsumptionAllowed 

func (m *GasConsumersByGasTankIDResponse) GetTotalFeeConsumptionAllowed() types.Coin

func (*GasConsumersByGasTankIDResponse) GetTotalFeesConsumed 

func (m *GasConsumersByGasTankIDResponse) GetTotalFeesConsumed() types.Coin

func (*GasConsumersByGasTankIDResponse) GetUsage 

func (m *GasConsumersByGasTankIDResponse) GetUsage() []*Usage

func (*GasConsumersByGasTankIDResponse) Marshal 

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

func (*GasConsumersByGasTankIDResponse) MarshalTo 

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

func (*GasConsumersByGasTankIDResponse) MarshalToSizedBuffer 

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

func (*GasConsumersByGasTankIDResponse) ProtoMessage 

func (*GasConsumersByGasTankIDResponse) ProtoMessage()

func (*GasConsumersByGasTankIDResponse) Reset 

func (m *GasConsumersByGasTankIDResponse) Reset()

func (*GasConsumersByGasTankIDResponse) Size 

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

func (*GasConsumersByGasTankIDResponse) String 

func (m *GasConsumersByGasTankIDResponse) String() string

func (*GasConsumersByGasTankIDResponse) Unmarshal 

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

func (*GasConsumersByGasTankIDResponse) XXX_DiscardUnknown 

func (m *GasConsumersByGasTankIDResponse) XXX_DiscardUnknown()

func (*GasConsumersByGasTankIDResponse) XXX_Marshal 

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

func (*GasConsumersByGasTankIDResponse) XXX_Merge 

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

func (*GasConsumersByGasTankIDResponse) XXX_Size 

func (m *GasConsumersByGasTankIDResponse) XXX_Size() int

func (*GasConsumersByGasTankIDResponse) XXX_Unmarshal 

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

type GasTank 

type GasTank struct {
	// id defines the id of gas tank
	Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// provider defines the creator/owner of the gas tank
	Provider string `protobuf:"bytes,2,opt,name=provider,proto3" json:"provider,omitempty"`
	// reserve defines the reserve address of the gas tank where deposited funds are stored
	Reserve string `protobuf:"bytes,3,opt,name=reserve,proto3" json:"reserve,omitempty"`
	// status of the gas tank if it is active or not
	IsActive bool `protobuf:"varint,4,opt,name=is_active,json=isActive,proto3" json:"is_active,omitempty"`
	// max_fee_usage_per_consumer defines the gas consumption limit which consumer is allowed, beyod this limit gas tank will not sponsor the tx
	MaxFeeUsagePerConsumer github_com_cosmos_cosmos_sdk_types.Int `` /* 173-byte string literal not displayed */
	// max_fee_usage_per_tx defines the maximum limit for the fee ased by the tx, beyond this gastank cannot sponsor the tx
	MaxFeeUsagePerTx github_com_cosmos_cosmos_sdk_types.Int `` /* 155-byte string literal not displayed */
	// usage_identifiers defines the unique list of MessageTypes,ContractAddress or any valid usage identifier which are whitelisted by gas tank.
	UsageIdentifiers []string `protobuf:"bytes,7,rep,name=usage_identifiers,json=usageIdentifiers,proto3" json:"usage_identifiers,omitempty"`
	// fee_denom defines the supported fee denom by gas tank.
	FeeDenom string `protobuf:"bytes,8,opt,name=fee_denom,json=feeDenom,proto3" json:"fee_denom,omitempty"`
}

GasTank defines the store for all the configurations of a set by a gas provider

func MustUnmarshalGasTank 

func MustUnmarshalGasTank(cdc codec.BinaryCodec, value []byte) GasTank

MustUnmarshalGasTank return the unmarshalled GasTank from bytes. It throws panic if it fails.

func NewGasTank 

func NewGasTank(
	id uint64,
	provider sdk.AccAddress,
	maxFeeUsagePerConsumer sdkmath.Int,
	maxFeeUsagePerTx sdkmath.Int,
	usageIdentifiers []string,
	feeDenom string,
) GasTank

func UnmarshalGasTank 

func UnmarshalGasTank(cdc codec.BinaryCodec, value []byte) (gasTank GasTank, err error)

UnmarshalGasTank returns the GasTank from bytes.

func (*GasTank) Descriptor 

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

func (GasTank) GetGasTankReserveAddress 

func (gasTank GasTank) GetGasTankReserveAddress() sdk.AccAddress

func (*GasTank) Marshal 

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

func (*GasTank) MarshalTo 

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

func (*GasTank) MarshalToSizedBuffer 

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

func (*GasTank) ProtoMessage 

func (*GasTank) ProtoMessage()

func (*GasTank) Reset 

func (m *GasTank) Reset()

func (*GasTank) Size 

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

func (*GasTank) String 

func (m *GasTank) String() string

func (*GasTank) Unmarshal 

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

func (GasTank) Validate 

func (gasTank GasTank) Validate() error

func (*GasTank) XXX_DiscardUnknown 

func (m *GasTank) XXX_DiscardUnknown()

func (*GasTank) XXX_Marshal 

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

func (*GasTank) XXX_Merge 

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

func (*GasTank) XXX_Size 

func (m *GasTank) XXX_Size() int

func (*GasTank) XXX_Unmarshal 

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

type GasTankResponse 

type GasTankResponse struct {
	Id                        uint64                                 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Provider                  string                                 `protobuf:"bytes,2,opt,name=provider,proto3" json:"provider,omitempty"`
	Reserve                   string                                 `protobuf:"bytes,3,opt,name=reserve,proto3" json:"reserve,omitempty"`
	GasTankBalance            types.Coin                             `protobuf:"bytes,4,opt,name=gas_tank_balance,json=gasTankBalance,proto3" json:"gas_tank_balance"`
	IsActive                  bool                                   `protobuf:"varint,5,opt,name=is_active,json=isActive,proto3" json:"is_active,omitempty"`
	MaxFeeUsagePerConsumer    github_com_cosmos_cosmos_sdk_types.Int `` /* 173-byte string literal not displayed */
	MaxFeeUsagePerTx          github_com_cosmos_cosmos_sdk_types.Int `` /* 155-byte string literal not displayed */
	SupportedUsageIdentifiers []string                               `` /* 138-byte string literal not displayed */
	FeeDenom                  string                                 `protobuf:"bytes,9,opt,name=fee_denom,json=feeDenom,proto3" json:"fee_denom,omitempty"`
}

func NewGasTankResponse 

func NewGasTankResponse(gasTank GasTank, balance sdk.Coin) GasTankResponse

func (*GasTankResponse) Descriptor 

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

func (*GasTankResponse) GetFeeDenom 

func (m *GasTankResponse) GetFeeDenom() string

func (*GasTankResponse) GetGasTankBalance 

func (m *GasTankResponse) GetGasTankBalance() types.Coin

func (*GasTankResponse) GetId 

func (m *GasTankResponse) GetId() uint64

func (*GasTankResponse) GetIsActive 

func (m *GasTankResponse) GetIsActive() bool

func (*GasTankResponse) GetProvider 

func (m *GasTankResponse) GetProvider() string

func (*GasTankResponse) GetReserve 

func (m *GasTankResponse) GetReserve() string

func (*GasTankResponse) GetSupportedUsageIdentifiers 

func (m *GasTankResponse) GetSupportedUsageIdentifiers() []string

func (*GasTankResponse) Marshal 

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

func (*GasTankResponse) MarshalTo 

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

func (*GasTankResponse) MarshalToSizedBuffer 

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

func (*GasTankResponse) ProtoMessage 

func (*GasTankResponse) ProtoMessage()

func (*GasTankResponse) Reset 

func (m *GasTankResponse) Reset()

func (*GasTankResponse) Size 

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

func (*GasTankResponse) String 

func (m *GasTankResponse) String() string

func (*GasTankResponse) Unmarshal 

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

func (*GasTankResponse) XXX_DiscardUnknown 

func (m *GasTankResponse) XXX_DiscardUnknown()

func (*GasTankResponse) XXX_Marshal 

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

func (*GasTankResponse) XXX_Merge 

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

func (*GasTankResponse) XXX_Size 

func (m *GasTankResponse) XXX_Size() int

func (*GasTankResponse) XXX_Unmarshal 

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

type GenesisState 

type GenesisState struct {
	// parms defines the parameters of the gasess module
	Params Params `protobuf:"bytes,1,opt,name=params,proto3" json:"params"`
	// usage_identifier_to_gastank_ids defines maps of all the gas tank ids with the usage identifier
	UsageIdentifierToGastankIds []UsageIdentifierToGasTankIds `` /* 138-byte string literal not displayed */
	// last_gas_tank_id defines most recent gas tank id within the key store
	LastGasTankId uint64 `protobuf:"varint,3,opt,name=last_gas_tank_id,json=lastGasTankId,proto3" json:"last_gas_tank_id,omitempty"`
	// gas_tanks defines all available gas tanks
	GasTanks []GasTank `protobuf:"bytes,4,rep,name=gas_tanks,json=gasTanks,proto3" json:"gas_tanks"`
	// gas_consumers defines all available gas consumer
	GasConsumers []GasConsumer `protobuf:"bytes,5,rep,name=gas_consumers,json=gasConsumers,proto3" json:"gas_consumers"`
}

GenesisState defines the gasless 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) 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 (genState 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 MsgBlockConsumer 

type MsgBlockConsumer struct {
	// gas_tank_id specifies the id of the gas tank
	GasTankId uint64 `protobuf:"varint,1,opt,name=gas_tank_id,json=gasTankId,proto3" json:"gas_tank_id,omitempty"`
	// provider specifies the bech32-encoded address that is the gas provider.
	Provider string `protobuf:"bytes,2,opt,name=provider,proto3" json:"provider,omitempty"`
	// consumer specifies the bech32-encoded address of a consumer.
	Consumer string `protobuf:"bytes,3,opt,name=consumer,proto3" json:"consumer,omitempty"`
}

MsgBlockConsumer defines an SDK message for blocking the suspected malicious consumer.

func NewMsgBlockConsumer 

func NewMsgBlockConsumer(
	gasTankID uint64,
	provider, consumer sdk.AccAddress,
) *MsgBlockConsumer

NewMsgBlockConsumer returns a new MsgBlockConsumer.

func (*MsgBlockConsumer) Descriptor 

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

func (*MsgBlockConsumer) GetConsumer 

func (m *MsgBlockConsumer) GetConsumer() string

func (*MsgBlockConsumer) GetGasTankId 

func (m *MsgBlockConsumer) GetGasTankId() uint64

func (*MsgBlockConsumer) GetProvider 

func (m *MsgBlockConsumer) GetProvider() string

func (MsgBlockConsumer) GetSignBytes 

func (msg MsgBlockConsumer) GetSignBytes() []byte

func (MsgBlockConsumer) GetSigners 

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

func (*MsgBlockConsumer) Marshal 

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

func (*MsgBlockConsumer) MarshalTo 

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

func (*MsgBlockConsumer) MarshalToSizedBuffer 

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

func (*MsgBlockConsumer) ProtoMessage 

func (*MsgBlockConsumer) ProtoMessage()

func (*MsgBlockConsumer) Reset 

func (m *MsgBlockConsumer) Reset()

func (MsgBlockConsumer) Route 

func (msg MsgBlockConsumer) Route() string

func (*MsgBlockConsumer) Size 

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

func (*MsgBlockConsumer) String 

func (m *MsgBlockConsumer) String() string

func (MsgBlockConsumer) Type 

func (msg MsgBlockConsumer) Type() string

func (*MsgBlockConsumer) Unmarshal 

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

func (MsgBlockConsumer) ValidateBasic 

func (msg MsgBlockConsumer) ValidateBasic() error

func (*MsgBlockConsumer) XXX_DiscardUnknown 

func (m *MsgBlockConsumer) XXX_DiscardUnknown()

func (*MsgBlockConsumer) XXX_Marshal 

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

func (*MsgBlockConsumer) XXX_Merge 

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

func (*MsgBlockConsumer) XXX_Size 

func (m *MsgBlockConsumer) XXX_Size() int

func (*MsgBlockConsumer) XXX_Unmarshal 

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

type MsgBlockConsumerResponse 

type MsgBlockConsumerResponse struct {
}

func (*MsgBlockConsumerResponse) Descriptor 

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

func (*MsgBlockConsumerResponse) Marshal 

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

func (*MsgBlockConsumerResponse) MarshalTo 

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

func (*MsgBlockConsumerResponse) MarshalToSizedBuffer 

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

func (*MsgBlockConsumerResponse) ProtoMessage 

func (*MsgBlockConsumerResponse) ProtoMessage()

func (*MsgBlockConsumerResponse) Reset 

func (m *MsgBlockConsumerResponse) Reset()

func (*MsgBlockConsumerResponse) Size 

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

func (*MsgBlockConsumerResponse) String 

func (m *MsgBlockConsumerResponse) String() string

func (*MsgBlockConsumerResponse) Unmarshal 

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

func (*MsgBlockConsumerResponse) XXX_DiscardUnknown 

func (m *MsgBlockConsumerResponse) XXX_DiscardUnknown()

func (*MsgBlockConsumerResponse) XXX_Marshal 

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

func (*MsgBlockConsumerResponse) XXX_Merge 

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

func (*MsgBlockConsumerResponse) XXX_Size 

func (m *MsgBlockConsumerResponse) XXX_Size() int

func (*MsgBlockConsumerResponse) XXX_Unmarshal 

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

type MsgClient 

type MsgClient interface {
	// CreateGasTank defines a method for creating a new gas tank
	CreateGasTank(ctx context.Context, in *MsgCreateGasTank, opts ...grpc.CallOption) (*MsgCreateGasTankResponse, error)
	// UpdateGasTankStatus defines a method for marking gas tank as active or inactive
	UpdateGasTankStatus(ctx context.Context, in *MsgUpdateGasTankStatus, opts ...grpc.CallOption) (*MsgUpdateGasTankStatusResponse, error)
	// UpdateGasTankConfigs defines a method for updating the configs of gas tank
	UpdateGasTankConfigs(ctx context.Context, in *MsgUpdateGasTankConfig, opts ...grpc.CallOption) (*MsgUpdateGasTankConfigResponse, error)
	// BlockConsumer defines a method for blocking a suspected malicious consumer
	BlockConsumer(ctx context.Context, in *MsgBlockConsumer, opts ...grpc.CallOption) (*MsgBlockConsumerResponse, error)
	// UnblockConsumer defines a method for unblocking consumer
	UnblockConsumer(ctx context.Context, in *MsgUnblockConsumer, opts ...grpc.CallOption) (*MsgUnblockConsumerResponse, error)
	// UpdateGasConsumerLimit defines a method for updating consumption limit of gas consumer
	UpdateGasConsumerLimit(ctx context.Context, in *MsgUpdateGasConsumerLimit, opts ...grpc.CallOption) (*MsgUpdateGasConsumerLimitResponse, 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 MsgCreateGasTank 

type MsgCreateGasTank struct {
	// provider specifies the bech32-encoded address that is the gas provider.
	Provider string `protobuf:"bytes,1,opt,name=provider,proto3" json:"provider,omitempty"`
	// fee_denom specifies the denom of the gas deposit coin
	FeeDenom string `protobuf:"bytes,2,opt,name=fee_denom,json=feeDenom,proto3" json:"fee_denom,omitempty"`
	// max_fee_usage_per_tx specifies the maximum fee allowed for each tx
	MaxFeeUsagePerTx github_com_cosmos_cosmos_sdk_types.Int `` /* 155-byte string literal not displayed */
	// max_fee_usage_per_consumer specifies the maximum fee consumption allowed for each consumer
	MaxFeeUsagePerConsumer github_com_cosmos_cosmos_sdk_types.Int `` /* 173-byte string literal not displayed */
	// usage_identifiers specifies usage identifiers allowed to consume gas from the gas tank
	UsageIdentifiers []string `protobuf:"bytes,5,rep,name=usage_identifiers,json=usageIdentifiers,proto3" json:"usage_identifiers,omitempty"`
	// gas_deposit specifies the initial desposit in the gas tank
	GasDeposit types.Coin `protobuf:"bytes,6,opt,name=gas_deposit,json=gasDeposit,proto3" json:"gas_deposit"`
}

MsgCreateGasTank defines an SDK message for creating a new GasTank.

func NewMsgCreateGasTank 

func NewMsgCreateGasTank(
	provider sdk.AccAddress,
	feeDenom string,
	maxFeeUsagePerTx sdkmath.Int,
	maxFeeUsagePerConsumer sdkmath.Int,
	usageIdentifiers []string,
	gasDeposit sdk.Coin,
) *MsgCreateGasTank

NewMsgCreateGasTank returns a new MsgCreateGasTank.

func (*MsgCreateGasTank) Descriptor 

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

func (*MsgCreateGasTank) GetFeeDenom 

func (m *MsgCreateGasTank) GetFeeDenom() string

func (*MsgCreateGasTank) GetGasDeposit 

func (m *MsgCreateGasTank) GetGasDeposit() types.Coin

func (*MsgCreateGasTank) GetProvider 

func (m *MsgCreateGasTank) GetProvider() string

func (MsgCreateGasTank) GetSignBytes 

func (msg MsgCreateGasTank) GetSignBytes() []byte

func (MsgCreateGasTank) GetSigners 

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

func (*MsgCreateGasTank) GetUsageIdentifiers 

func (m *MsgCreateGasTank) GetUsageIdentifiers() []string

func (*MsgCreateGasTank) Marshal 

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

func (*MsgCreateGasTank) MarshalTo 

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

func (*MsgCreateGasTank) MarshalToSizedBuffer 

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

func (*MsgCreateGasTank) ProtoMessage 

func (*MsgCreateGasTank) ProtoMessage()

func (*MsgCreateGasTank) Reset 

func (m *MsgCreateGasTank) Reset()

func (MsgCreateGasTank) Route 

func (msg MsgCreateGasTank) Route() string

func (*MsgCreateGasTank) Size 

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

func (*MsgCreateGasTank) String 

func (m *MsgCreateGasTank) String() string

func (MsgCreateGasTank) Type 

func (msg MsgCreateGasTank) Type() string

func (*MsgCreateGasTank) Unmarshal 

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

func (MsgCreateGasTank) ValidateBasic 

func (msg MsgCreateGasTank) ValidateBasic() error

func (*MsgCreateGasTank) XXX_DiscardUnknown 

func (m *MsgCreateGasTank) XXX_DiscardUnknown()

func (*MsgCreateGasTank) XXX_Marshal 

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

func (*MsgCreateGasTank) XXX_Merge 

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

func (*MsgCreateGasTank) XXX_Size 

func (m *MsgCreateGasTank) XXX_Size() int

func (*MsgCreateGasTank) XXX_Unmarshal 

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

type MsgCreateGasTankResponse 

type MsgCreateGasTankResponse struct {
}

func (*MsgCreateGasTankResponse) Descriptor 

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

func (*MsgCreateGasTankResponse) Marshal 

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

func (*MsgCreateGasTankResponse) MarshalTo 

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

func (*MsgCreateGasTankResponse) MarshalToSizedBuffer 

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

func (*MsgCreateGasTankResponse) ProtoMessage 

func (*MsgCreateGasTankResponse) ProtoMessage()

func (*MsgCreateGasTankResponse) Reset 

func (m *MsgCreateGasTankResponse) Reset()

func (*MsgCreateGasTankResponse) Size 

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

func (*MsgCreateGasTankResponse) String 

func (m *MsgCreateGasTankResponse) String() string

func (*MsgCreateGasTankResponse) Unmarshal 

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

func (*MsgCreateGasTankResponse) XXX_DiscardUnknown 

func (m *MsgCreateGasTankResponse) XXX_DiscardUnknown()

func (*MsgCreateGasTankResponse) XXX_Marshal 

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

func (*MsgCreateGasTankResponse) XXX_Merge 

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

func (*MsgCreateGasTankResponse) XXX_Size 

func (m *MsgCreateGasTankResponse) XXX_Size() int

func (*MsgCreateGasTankResponse) XXX_Unmarshal 

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

type MsgServer 

type MsgServer interface {
	// CreateGasTank defines a method for creating a new gas tank
	CreateGasTank(context.Context, *MsgCreateGasTank) (*MsgCreateGasTankResponse, error)
	// UpdateGasTankStatus defines a method for marking gas tank as active or inactive
	UpdateGasTankStatus(context.Context, *MsgUpdateGasTankStatus) (*MsgUpdateGasTankStatusResponse, error)
	// UpdateGasTankConfigs defines a method for updating the configs of gas tank
	UpdateGasTankConfigs(context.Context, *MsgUpdateGasTankConfig) (*MsgUpdateGasTankConfigResponse, error)
	// BlockConsumer defines a method for blocking a suspected malicious consumer
	BlockConsumer(context.Context, *MsgBlockConsumer) (*MsgBlockConsumerResponse, error)
	// UnblockConsumer defines a method for unblocking consumer
	UnblockConsumer(context.Context, *MsgUnblockConsumer) (*MsgUnblockConsumerResponse, error)
	// UpdateGasConsumerLimit defines a method for updating consumption limit of gas consumer
	UpdateGasConsumerLimit(context.Context, *MsgUpdateGasConsumerLimit) (*MsgUpdateGasConsumerLimitResponse, error)
}

MsgServer is the server API for Msg service.

type MsgUnblockConsumer 

type MsgUnblockConsumer struct {
	// gas_tank_id specifies the id of the gas tank
	GasTankId uint64 `protobuf:"varint,1,opt,name=gas_tank_id,json=gasTankId,proto3" json:"gas_tank_id,omitempty"`
	// provider specifies the bech32-encoded address that is the gas provider.
	Provider string `protobuf:"bytes,2,opt,name=provider,proto3" json:"provider,omitempty"`
	// consumer specifies the bech32-encoded address of a consumer.
	Consumer string `protobuf:"bytes,3,opt,name=consumer,proto3" json:"consumer,omitempty"`
}

MsgUnblockConsumer defines an SDK message for unblocking consumer.

func NewMsgUnblockConsumer 

func NewMsgUnblockConsumer(
	gasTankID uint64,
	provider, consumer sdk.AccAddress,
) *MsgUnblockConsumer

NewMsgUnblockConsumer returns a new MsgUnblockConsumer.

func (*MsgUnblockConsumer) Descriptor 

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

func (*MsgUnblockConsumer) GetConsumer 

func (m *MsgUnblockConsumer) GetConsumer() string

func (*MsgUnblockConsumer) GetGasTankId 

func (m *MsgUnblockConsumer) GetGasTankId() uint64

func (*MsgUnblockConsumer) GetProvider 

func (m *MsgUnblockConsumer) GetProvider() string

func (MsgUnblockConsumer) GetSignBytes 

func (msg MsgUnblockConsumer) GetSignBytes() []byte

func (MsgUnblockConsumer) GetSigners 

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

func (*MsgUnblockConsumer) Marshal 

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

func (*MsgUnblockConsumer) MarshalTo 

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

func (*MsgUnblockConsumer) MarshalToSizedBuffer 

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

func (*MsgUnblockConsumer) ProtoMessage 

func (*MsgUnblockConsumer) ProtoMessage()

func (*MsgUnblockConsumer) Reset 

func (m *MsgUnblockConsumer) Reset()

func (MsgUnblockConsumer) Route 

func (msg MsgUnblockConsumer) Route() string

func (*MsgUnblockConsumer) Size 

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

func (*MsgUnblockConsumer) String 

func (m *MsgUnblockConsumer) String() string

func (MsgUnblockConsumer) Type 

func (msg MsgUnblockConsumer) Type() string

func (*MsgUnblockConsumer) Unmarshal 

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

func (MsgUnblockConsumer) ValidateBasic 

func (msg MsgUnblockConsumer) ValidateBasic() error

func (*MsgUnblockConsumer) XXX_DiscardUnknown 

func (m *MsgUnblockConsumer) XXX_DiscardUnknown()

func (*MsgUnblockConsumer) XXX_Marshal 

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

func (*MsgUnblockConsumer) XXX_Merge 

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

func (*MsgUnblockConsumer) XXX_Size 

func (m *MsgUnblockConsumer) XXX_Size() int

func (*MsgUnblockConsumer) XXX_Unmarshal 

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

type MsgUnblockConsumerResponse 

type MsgUnblockConsumerResponse struct {
}

func (*MsgUnblockConsumerResponse) Descriptor 

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

func (*MsgUnblockConsumerResponse) Marshal 

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

func (*MsgUnblockConsumerResponse) MarshalTo 

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

func (*MsgUnblockConsumerResponse) MarshalToSizedBuffer 

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

func (*MsgUnblockConsumerResponse) ProtoMessage 

func (*MsgUnblockConsumerResponse) ProtoMessage()

func (*MsgUnblockConsumerResponse) Reset 

func (m *MsgUnblockConsumerResponse) Reset()

func (*MsgUnblockConsumerResponse) Size 

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

func (*MsgUnblockConsumerResponse) String 

func (m *MsgUnblockConsumerResponse) String() string

func (*MsgUnblockConsumerResponse) Unmarshal 

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

func (*MsgUnblockConsumerResponse) XXX_DiscardUnknown 

func (m *MsgUnblockConsumerResponse) XXX_DiscardUnknown()

func (*MsgUnblockConsumerResponse) XXX_Marshal 

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

func (*MsgUnblockConsumerResponse) XXX_Merge 

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

func (*MsgUnblockConsumerResponse) XXX_Size 

func (m *MsgUnblockConsumerResponse) XXX_Size() int

func (*MsgUnblockConsumerResponse) XXX_Unmarshal 

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

type MsgUpdateGasConsumerLimit 

type MsgUpdateGasConsumerLimit struct {
	// gas_tank_id specifies the id of the gas tank
	GasTankId uint64 `protobuf:"varint,1,opt,name=gas_tank_id,json=gasTankId,proto3" json:"gas_tank_id,omitempty"`
	// provider specifies the bech32-encoded address that is the gas provider.
	Provider string `protobuf:"bytes,2,opt,name=provider,proto3" json:"provider,omitempty"`
	// consumer specifies the bech32-encoded address of a consumer.
	Consumer string `protobuf:"bytes,3,opt,name=consumer,proto3" json:"consumer,omitempty"`
	// total_fee_consumption_allowed specifies the maximum fee consumption allowed for each consumer
	TotalFeeConsumptionAllowed github_com_cosmos_cosmos_sdk_types.Int `` /* 183-byte string literal not displayed */
}

MsgUpdateGasConsumerLimit defines an SDK message for updating the consumption limits of gas consumer.

func NewMsgUpdateGasConsumerLimit 

func NewMsgUpdateGasConsumerLimit(
	gasTankID uint64,
	provider, consumer sdk.AccAddress,
	totalFeeConsumptionAllowed sdkmath.Int,
) *MsgUpdateGasConsumerLimit

NewMsgUpdateGasConsumerLimit returns a new MsgUpdateGasConsumerLimit.

func (*MsgUpdateGasConsumerLimit) Descriptor 

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

func (*MsgUpdateGasConsumerLimit) GetConsumer 

func (m *MsgUpdateGasConsumerLimit) GetConsumer() string

func (*MsgUpdateGasConsumerLimit) GetGasTankId 

func (m *MsgUpdateGasConsumerLimit) GetGasTankId() uint64

func (*MsgUpdateGasConsumerLimit) GetProvider 

func (m *MsgUpdateGasConsumerLimit) GetProvider() string

func (MsgUpdateGasConsumerLimit) GetSignBytes 

func (msg MsgUpdateGasConsumerLimit) GetSignBytes() []byte

func (MsgUpdateGasConsumerLimit) GetSigners 

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

func (*MsgUpdateGasConsumerLimit) Marshal 

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

func (*MsgUpdateGasConsumerLimit) MarshalTo 

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

func (*MsgUpdateGasConsumerLimit) MarshalToSizedBuffer 

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

func (*MsgUpdateGasConsumerLimit) ProtoMessage 

func (*MsgUpdateGasConsumerLimit) ProtoMessage()

func (*MsgUpdateGasConsumerLimit) Reset 

func (m *MsgUpdateGasConsumerLimit) Reset()

func (MsgUpdateGasConsumerLimit) Route 

func (msg MsgUpdateGasConsumerLimit) Route() string

func (*MsgUpdateGasConsumerLimit) Size 

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

func (*MsgUpdateGasConsumerLimit) String 

func (m *MsgUpdateGasConsumerLimit) String() string

func (MsgUpdateGasConsumerLimit) Type 

func (msg MsgUpdateGasConsumerLimit) Type() string

func (*MsgUpdateGasConsumerLimit) Unmarshal 

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

func (MsgUpdateGasConsumerLimit) ValidateBasic 

func (msg MsgUpdateGasConsumerLimit) ValidateBasic() error

func (*MsgUpdateGasConsumerLimit) XXX_DiscardUnknown 

func (m *MsgUpdateGasConsumerLimit) XXX_DiscardUnknown()

func (*MsgUpdateGasConsumerLimit) XXX_Marshal 

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

func (*MsgUpdateGasConsumerLimit) XXX_Merge 

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

func (*MsgUpdateGasConsumerLimit) XXX_Size 

func (m *MsgUpdateGasConsumerLimit) XXX_Size() int

func (*MsgUpdateGasConsumerLimit) XXX_Unmarshal 

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

type MsgUpdateGasConsumerLimitResponse 

type MsgUpdateGasConsumerLimitResponse struct {
}

func (*MsgUpdateGasConsumerLimitResponse) Descriptor 

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

func (*MsgUpdateGasConsumerLimitResponse) Marshal 

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

func (*MsgUpdateGasConsumerLimitResponse) MarshalTo 

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

func (*MsgUpdateGasConsumerLimitResponse) MarshalToSizedBuffer 

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

func (*MsgUpdateGasConsumerLimitResponse) ProtoMessage 

func (*MsgUpdateGasConsumerLimitResponse) ProtoMessage()

func (*MsgUpdateGasConsumerLimitResponse) Reset 

func (m *MsgUpdateGasConsumerLimitResponse) Reset()

func (*MsgUpdateGasConsumerLimitResponse) Size 

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

func (*MsgUpdateGasConsumerLimitResponse) String 

func (m *MsgUpdateGasConsumerLimitResponse) String() string

func (*MsgUpdateGasConsumerLimitResponse) Unmarshal 

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

func (*MsgUpdateGasConsumerLimitResponse) XXX_DiscardUnknown 

func (m *MsgUpdateGasConsumerLimitResponse) XXX_DiscardUnknown()

func (*MsgUpdateGasConsumerLimitResponse) XXX_Marshal 

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

func (*MsgUpdateGasConsumerLimitResponse) XXX_Merge 

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

func (*MsgUpdateGasConsumerLimitResponse) XXX_Size 

func (m *MsgUpdateGasConsumerLimitResponse) XXX_Size() int

func (*MsgUpdateGasConsumerLimitResponse) XXX_Unmarshal 

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

type MsgUpdateGasTankConfig 

type MsgUpdateGasTankConfig struct {
	// gas_tank_id specifies the id of the gas tank
	GasTankId uint64 `protobuf:"varint,1,opt,name=gas_tank_id,json=gasTankId,proto3" json:"gas_tank_id,omitempty"`
	// provider specifies the bech32-encoded address that is the gas provider.
	Provider string `protobuf:"bytes,2,opt,name=provider,proto3" json:"provider,omitempty"`
	// max_fee_usage_per_tx specifies the maximum fee allowed for each tx
	MaxFeeUsagePerTx github_com_cosmos_cosmos_sdk_types.Int `` /* 155-byte string literal not displayed */
	// max_fee_usage_per_consumer specifies the maximum fee consumption allowed for each consumer
	MaxFeeUsagePerConsumer github_com_cosmos_cosmos_sdk_types.Int `` /* 173-byte string literal not displayed */
	// usage_identifiers specifies usage identifiers allowed to consume gas from the gas tank
	UsageIdentifiers []string `protobuf:"bytes,5,rep,name=usage_identifiers,json=usageIdentifiers,proto3" json:"usage_identifiers,omitempty"`
}

MsgUpdateGasTankConfig defines an SDK message for updating the configs of gas tank.

func NewMsgUpdateGasTankConfig 

func NewMsgUpdateGasTankConfig(
	gasTankID uint64,
	provider sdk.AccAddress,
	maxFeeUsagePerTx sdkmath.Int,
	maxFeeUsagePerConsumer sdkmath.Int,
	usageIdentifiers []string,
) *MsgUpdateGasTankConfig

NewMsgUpdateGasTankConfig returns a new MsgUpdateGasTankConfig.

func (*MsgUpdateGasTankConfig) Descriptor 

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

func (*MsgUpdateGasTankConfig) GetGasTankId 

func (m *MsgUpdateGasTankConfig) GetGasTankId() uint64

func (*MsgUpdateGasTankConfig) GetProvider 

func (m *MsgUpdateGasTankConfig) GetProvider() string

func (MsgUpdateGasTankConfig) GetSignBytes 

func (msg MsgUpdateGasTankConfig) GetSignBytes() []byte

func (MsgUpdateGasTankConfig) GetSigners 

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

func (*MsgUpdateGasTankConfig) GetUsageIdentifiers 

func (m *MsgUpdateGasTankConfig) GetUsageIdentifiers() []string

func (*MsgUpdateGasTankConfig) Marshal 

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

func (*MsgUpdateGasTankConfig) MarshalTo 

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

func (*MsgUpdateGasTankConfig) MarshalToSizedBuffer 

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

func (*MsgUpdateGasTankConfig) ProtoMessage 

func (*MsgUpdateGasTankConfig) ProtoMessage()

func (*MsgUpdateGasTankConfig) Reset 

func (m *MsgUpdateGasTankConfig) Reset()

func (MsgUpdateGasTankConfig) Route 

func (msg MsgUpdateGasTankConfig) Route() string

func (*MsgUpdateGasTankConfig) Size 

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

func (*MsgUpdateGasTankConfig) String 

func (m *MsgUpdateGasTankConfig) String() string

func (MsgUpdateGasTankConfig) Type 

func (msg MsgUpdateGasTankConfig) Type() string

func (*MsgUpdateGasTankConfig) Unmarshal 

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

func (MsgUpdateGasTankConfig) ValidateBasic 

func (msg MsgUpdateGasTankConfig) ValidateBasic() error

func (*MsgUpdateGasTankConfig) XXX_DiscardUnknown 

func (m *MsgUpdateGasTankConfig) XXX_DiscardUnknown()

func (*MsgUpdateGasTankConfig) XXX_Marshal 

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

func (*MsgUpdateGasTankConfig) XXX_Merge 

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

func (*MsgUpdateGasTankConfig) XXX_Size 

func (m *MsgUpdateGasTankConfig) XXX_Size() int

func (*MsgUpdateGasTankConfig) XXX_Unmarshal 

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

type MsgUpdateGasTankConfigResponse 

type MsgUpdateGasTankConfigResponse struct {
}

func (*MsgUpdateGasTankConfigResponse) Descriptor 

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

func (*MsgUpdateGasTankConfigResponse) Marshal 

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

func (*MsgUpdateGasTankConfigResponse) MarshalTo 

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

func (*MsgUpdateGasTankConfigResponse) MarshalToSizedBuffer 

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

func (*MsgUpdateGasTankConfigResponse) ProtoMessage 

func (*MsgUpdateGasTankConfigResponse) ProtoMessage()

func (*MsgUpdateGasTankConfigResponse) Reset 

func (m *MsgUpdateGasTankConfigResponse) Reset()

func (*MsgUpdateGasTankConfigResponse) Size 

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

func (*MsgUpdateGasTankConfigResponse) String 

func (m *MsgUpdateGasTankConfigResponse) String() string

func (*MsgUpdateGasTankConfigResponse) Unmarshal 

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

func (*MsgUpdateGasTankConfigResponse) XXX_DiscardUnknown 

func (m *MsgUpdateGasTankConfigResponse) XXX_DiscardUnknown()

func (*MsgUpdateGasTankConfigResponse) XXX_Marshal 

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

func (*MsgUpdateGasTankConfigResponse) XXX_Merge 

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

func (*MsgUpdateGasTankConfigResponse) XXX_Size 

func (m *MsgUpdateGasTankConfigResponse) XXX_Size() int

func (*MsgUpdateGasTankConfigResponse) XXX_Unmarshal 

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

type MsgUpdateGasTankStatus 

type MsgUpdateGasTankStatus struct {
	// gas_tank_id specifies the id of the gas tank
	GasTankId uint64 `protobuf:"varint,1,opt,name=gas_tank_id,json=gasTankId,proto3" json:"gas_tank_id,omitempty"`
	// provider specifies the bech32-encoded address that is the gas provider.
	Provider string `protobuf:"bytes,2,opt,name=provider,proto3" json:"provider,omitempty"`
}

MsgUpdateGasTankStatus defines an SDK message for updating the status of gas tank.

func NewMsgUpdateGasTankStatus 

func NewMsgUpdateGasTankStatus(
	gasTankID uint64,
	provider sdk.AccAddress,
) *MsgUpdateGasTankStatus

NewMsgUpdateGasTankStatus returns a new MsgUpdateGasTankStatus.

func (*MsgUpdateGasTankStatus) Descriptor 

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

func (*MsgUpdateGasTankStatus) GetGasTankId 

func (m *MsgUpdateGasTankStatus) GetGasTankId() uint64

func (*MsgUpdateGasTankStatus) GetProvider 

func (m *MsgUpdateGasTankStatus) GetProvider() string

func (MsgUpdateGasTankStatus) GetSignBytes 

func (msg MsgUpdateGasTankStatus) GetSignBytes() []byte

func (MsgUpdateGasTankStatus) GetSigners 

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

func (*MsgUpdateGasTankStatus) Marshal 

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

func (*MsgUpdateGasTankStatus) MarshalTo 

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

func (*MsgUpdateGasTankStatus) MarshalToSizedBuffer 

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

func (*MsgUpdateGasTankStatus) ProtoMessage 

func (*MsgUpdateGasTankStatus) ProtoMessage()

func (*MsgUpdateGasTankStatus) Reset 

func (m *MsgUpdateGasTankStatus) Reset()

func (MsgUpdateGasTankStatus) Route 

func (msg MsgUpdateGasTankStatus) Route() string

func (*MsgUpdateGasTankStatus) Size 

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

func (*MsgUpdateGasTankStatus) String 

func (m *MsgUpdateGasTankStatus) String() string

func (MsgUpdateGasTankStatus) Type 

func (msg MsgUpdateGasTankStatus) Type() string

func (*MsgUpdateGasTankStatus) Unmarshal 

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

func (MsgUpdateGasTankStatus) ValidateBasic 

func (msg MsgUpdateGasTankStatus) ValidateBasic() error

func (*MsgUpdateGasTankStatus) XXX_DiscardUnknown 

func (m *MsgUpdateGasTankStatus) XXX_DiscardUnknown()

func (*MsgUpdateGasTankStatus) XXX_Marshal 

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

func (*MsgUpdateGasTankStatus) XXX_Merge 

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

func (*MsgUpdateGasTankStatus) XXX_Size 

func (m *MsgUpdateGasTankStatus) XXX_Size() int

func (*MsgUpdateGasTankStatus) XXX_Unmarshal 

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

type MsgUpdateGasTankStatusResponse 

type MsgUpdateGasTankStatusResponse struct {
}

func (*MsgUpdateGasTankStatusResponse) Descriptor 

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

func (*MsgUpdateGasTankStatusResponse) Marshal 

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

func (*MsgUpdateGasTankStatusResponse) MarshalTo 

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

func (*MsgUpdateGasTankStatusResponse) MarshalToSizedBuffer 

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

func (*MsgUpdateGasTankStatusResponse) ProtoMessage 

func (*MsgUpdateGasTankStatusResponse) ProtoMessage()

func (*MsgUpdateGasTankStatusResponse) Reset 

func (m *MsgUpdateGasTankStatusResponse) Reset()

func (*MsgUpdateGasTankStatusResponse) Size 

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

func (*MsgUpdateGasTankStatusResponse) String 

func (m *MsgUpdateGasTankStatusResponse) String() string

func (*MsgUpdateGasTankStatusResponse) Unmarshal 

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

func (*MsgUpdateGasTankStatusResponse) XXX_DiscardUnknown 

func (m *MsgUpdateGasTankStatusResponse) XXX_DiscardUnknown()

func (*MsgUpdateGasTankStatusResponse) XXX_Marshal 

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

func (*MsgUpdateGasTankStatusResponse) XXX_Merge 

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

func (*MsgUpdateGasTankStatusResponse) XXX_Size 

func (m *MsgUpdateGasTankStatusResponse) XXX_Size() int

func (*MsgUpdateGasTankStatusResponse) XXX_Unmarshal 

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

type Params 

type Params struct {
	//  minimum_gas_deposit defines the minimum coins required while creating gas tank
	MinimumGasDeposit github_com_cosmos_cosmos_sdk_types.Coins `` /* 158-byte string literal not displayed */
}

Params defines the parameters for the module.

func DefaultParams 

func DefaultParams() Params

DefaultParams returns a default params for the liquidity module.

func NewParams 

func NewParams(minGasDeposit sdk.Coins) Params

NewParams creates a new Params instance

func (*Params) Descriptor 

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

func (*Params) Marshal 

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

func (*Params) MarshalTo 

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

func (*Params) MarshalToSizedBuffer 

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

func (*Params) ParamSetPairs 

func (params *Params) ParamSetPairs() paramstypes.ParamSetPairs

ParamSetPairs implements ParamSet.

func (*Params) ProtoMessage 

func (*Params) ProtoMessage()

func (*Params) Reset 

func (m *Params) Reset()

func (*Params) Size 

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

func (*Params) String 

func (m *Params) String() string

func (*Params) Unmarshal 

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

func (Params) Validate 

func (p Params) Validate() error

Validate validates 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 QueryAvailableUsageIdentifiersRequest 

type QueryAvailableUsageIdentifiersRequest struct {
}

QueryAvailableUsageIdentifiersRequest is a request type for the Query/AvailableUsageIdentifiers RPC method.

func (*QueryAvailableUsageIdentifiersRequest) Descriptor 

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

func (*QueryAvailableUsageIdentifiersRequest) Marshal 

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

func (*QueryAvailableUsageIdentifiersRequest) MarshalTo 

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

func (*QueryAvailableUsageIdentifiersRequest) MarshalToSizedBuffer 

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

func (*QueryAvailableUsageIdentifiersRequest) ProtoMessage 

func (*QueryAvailableUsageIdentifiersRequest) ProtoMessage()

func (*QueryAvailableUsageIdentifiersRequest) Reset 

func (m *QueryAvailableUsageIdentifiersRequest) Reset()

func (*QueryAvailableUsageIdentifiersRequest) Size 

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

func (*QueryAvailableUsageIdentifiersRequest) String 

func (m *QueryAvailableUsageIdentifiersRequest) String() string

func (*QueryAvailableUsageIdentifiersRequest) Unmarshal 

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

func (*QueryAvailableUsageIdentifiersRequest) XXX_DiscardUnknown 

func (m *QueryAvailableUsageIdentifiersRequest) XXX_DiscardUnknown()

func (*QueryAvailableUsageIdentifiersRequest) XXX_Marshal 

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

func (*QueryAvailableUsageIdentifiersRequest) XXX_Merge 

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

func (*QueryAvailableUsageIdentifiersRequest) XXX_Size 

func (m *QueryAvailableUsageIdentifiersRequest) XXX_Size() int

func (*QueryAvailableUsageIdentifiersRequest) XXX_Unmarshal 

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

type QueryAvailableUsageIdentifiersResponse 

type QueryAvailableUsageIdentifiersResponse struct {
	UsageIdentifiers UsageIdentifiers `protobuf:"bytes,1,opt,name=usage_identifiers,json=usageIdentifiers,proto3" json:"usage_identifiers"`
}

QueryAvailableUsageIdentifiersResponse is a response type for the Query/AvailableUsageIdentifiers RPC method.

func (*QueryAvailableUsageIdentifiersResponse) Descriptor 

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

func (*QueryAvailableUsageIdentifiersResponse) GetUsageIdentifiers 

func (m *QueryAvailableUsageIdentifiersResponse) GetUsageIdentifiers() UsageIdentifiers

func (*QueryAvailableUsageIdentifiersResponse) Marshal 

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

func (*QueryAvailableUsageIdentifiersResponse) MarshalTo 

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

func (*QueryAvailableUsageIdentifiersResponse) MarshalToSizedBuffer 

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

func (*QueryAvailableUsageIdentifiersResponse) ProtoMessage 

func (*QueryAvailableUsageIdentifiersResponse) ProtoMessage()

func (*QueryAvailableUsageIdentifiersResponse) Reset 

func (m *QueryAvailableUsageIdentifiersResponse) Reset()

func (*QueryAvailableUsageIdentifiersResponse) Size 

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

func (*QueryAvailableUsageIdentifiersResponse) String 

func (m *QueryAvailableUsageIdentifiersResponse) String() string

func (*QueryAvailableUsageIdentifiersResponse) Unmarshal 

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

func (*QueryAvailableUsageIdentifiersResponse) XXX_DiscardUnknown 

func (m *QueryAvailableUsageIdentifiersResponse) XXX_DiscardUnknown()

func (*QueryAvailableUsageIdentifiersResponse) XXX_Marshal 

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

func (*QueryAvailableUsageIdentifiersResponse) XXX_Merge 

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

func (*QueryAvailableUsageIdentifiersResponse) XXX_Size 

func (m *QueryAvailableUsageIdentifiersResponse) XXX_Size() int

func (*QueryAvailableUsageIdentifiersResponse) XXX_Unmarshal 

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

type QueryClient 

type QueryClient interface {
	// Params returns parameters of the module.
	Params(ctx context.Context, in *QueryParamsRequest, opts ...grpc.CallOption) (*QueryParamsResponse, error)
	// AvailableUsageIdentifiers return all available usage identifiers
	AvailableUsageIdentifiers(ctx context.Context, in *QueryAvailableUsageIdentifiersRequest, opts ...grpc.CallOption) (*QueryAvailableUsageIdentifiersResponse, error)
	// GasTank returns gas tank details
	GasTank(ctx context.Context, in *QueryGasTankRequest, opts ...grpc.CallOption) (*QueryGasTankResponse, error)
	// GasTanks return details of all the gas tanks
	GasTanks(ctx context.Context, in *QueryGasTanksRequest, opts ...grpc.CallOption) (*QueryGasTanksResponse, error)
	// GasTanksByProvider return details of all the gas tanks for the given provider
	GasTanksByProvider(ctx context.Context, in *QueryGasTanksByProviderRequest, opts ...grpc.CallOption) (*QueryGasTanksByProviderResponse, error)
	// GasConsumer returns gas consumer details
	GasConsumer(ctx context.Context, in *QueryGasConsumerRequest, opts ...grpc.CallOption) (*QueryGasConsumerResponse, error)
	// GasConsumers return details of all the gas consumers
	GasConsumers(ctx context.Context, in *QueryGasConsumersRequest, opts ...grpc.CallOption) (*QueryGasConsumersResponse, error)
	// GasConsumersByGasTankID return details of all the gas consumers for the given tank ID
	GasConsumersByGasTankID(ctx context.Context, in *QueryGasConsumersByGasTankIDRequest, opts ...grpc.CallOption) (*QueryGasConsumersByGasTankIDResponse, error)
	// GasTankIdsForAllUsageIdentifiers returns gas tanks ids with all available usage identifiers
	GasTankIdsForAllUsageIdentifiers(ctx context.Context, in *QueryGasTankIdsForAllUsageIdentifiersRequest, opts ...grpc.CallOption) (*QueryGasTankIdsForAllUsageIdentifiersResponse, 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 QueryGasConsumerRequest 

type QueryGasConsumerRequest struct {
	// consumer specifies the bech32-encoded address of a consumer.
	Consumer string `protobuf:"bytes,1,opt,name=consumer,proto3" json:"consumer,omitempty"`
}

QueryGasConsumerRequest is a request type for the Query/GasConsumer RPC method.

func (*QueryGasConsumerRequest) Descriptor 

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

func (*QueryGasConsumerRequest) GetConsumer 

func (m *QueryGasConsumerRequest) GetConsumer() string

func (*QueryGasConsumerRequest) Marshal 

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

func (*QueryGasConsumerRequest) MarshalTo 

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

func (*QueryGasConsumerRequest) MarshalToSizedBuffer 

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

func (*QueryGasConsumerRequest) ProtoMessage 

func (*QueryGasConsumerRequest) ProtoMessage()

func (*QueryGasConsumerRequest) Reset 

func (m *QueryGasConsumerRequest) Reset()

func (*QueryGasConsumerRequest) Size 

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

func (*QueryGasConsumerRequest) String 

func (m *QueryGasConsumerRequest) String() string

func (*QueryGasConsumerRequest) Unmarshal 

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

func (*QueryGasConsumerRequest) XXX_DiscardUnknown 

func (m *QueryGasConsumerRequest) XXX_DiscardUnknown()

func (*QueryGasConsumerRequest) XXX_Marshal 

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

func (*QueryGasConsumerRequest) XXX_Merge 

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

func (*QueryGasConsumerRequest) XXX_Size 

func (m *QueryGasConsumerRequest) XXX_Size() int

func (*QueryGasConsumerRequest) XXX_Unmarshal 

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

type QueryGasConsumerResponse 

type QueryGasConsumerResponse struct {
	GasConsumer GasConsumer `protobuf:"bytes,1,opt,name=gas_consumer,json=gasConsumer,proto3" json:"gas_consumer"`
}

QueryGasConsumerResponse is a response type for the Query/GasConsumer RPC method.

func (*QueryGasConsumerResponse) Descriptor 

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

func (*QueryGasConsumerResponse) GetGasConsumer 

func (m *QueryGasConsumerResponse) GetGasConsumer() GasConsumer

func (*QueryGasConsumerResponse) Marshal 

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

func (*QueryGasConsumerResponse) MarshalTo 

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

func (*QueryGasConsumerResponse) MarshalToSizedBuffer 

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

func (*QueryGasConsumerResponse) ProtoMessage 

func (*QueryGasConsumerResponse) ProtoMessage()

func (*QueryGasConsumerResponse) Reset 

func (m *QueryGasConsumerResponse) Reset()

func (*QueryGasConsumerResponse) Size 

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

func (*QueryGasConsumerResponse) String 

func (m *QueryGasConsumerResponse) String() string

func (*QueryGasConsumerResponse) Unmarshal 

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

func (*QueryGasConsumerResponse) XXX_DiscardUnknown 

func (m *QueryGasConsumerResponse) XXX_DiscardUnknown()

func (*QueryGasConsumerResponse) XXX_Marshal 

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

func (*QueryGasConsumerResponse) XXX_Merge 

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

func (*QueryGasConsumerResponse) XXX_Size 

func (m *QueryGasConsumerResponse) XXX_Size() int

func (*QueryGasConsumerResponse) XXX_Unmarshal 

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

type QueryGasConsumersByGasTankIDRequest 

type QueryGasConsumersByGasTankIDRequest struct {
	GasTankId uint64 `protobuf:"varint,1,opt,name=gas_tank_id,json=gasTankId,proto3" json:"gas_tank_id,omitempty"`
}

QueryGasConsumersByGasTankIDRequest is a request type for the Query/GasConsumersByGasTankID RPC method.

func (*QueryGasConsumersByGasTankIDRequest) Descriptor 

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

func (*QueryGasConsumersByGasTankIDRequest) GetGasTankId 

func (m *QueryGasConsumersByGasTankIDRequest) GetGasTankId() uint64

func (*QueryGasConsumersByGasTankIDRequest) Marshal 

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

func (*QueryGasConsumersByGasTankIDRequest) MarshalTo 

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

func (*QueryGasConsumersByGasTankIDRequest) MarshalToSizedBuffer 

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

func (*QueryGasConsumersByGasTankIDRequest) ProtoMessage 

func (*QueryGasConsumersByGasTankIDRequest) ProtoMessage()

func (*QueryGasConsumersByGasTankIDRequest) Reset 

func (m *QueryGasConsumersByGasTankIDRequest) Reset()

func (*QueryGasConsumersByGasTankIDRequest) Size 

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

func (*QueryGasConsumersByGasTankIDRequest) String 

func (m *QueryGasConsumersByGasTankIDRequest) String() string

func (*QueryGasConsumersByGasTankIDRequest) Unmarshal 

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

func (*QueryGasConsumersByGasTankIDRequest) XXX_DiscardUnknown 

func (m *QueryGasConsumersByGasTankIDRequest) XXX_DiscardUnknown()

func (*QueryGasConsumersByGasTankIDRequest) XXX_Marshal 

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

func (*QueryGasConsumersByGasTankIDRequest) XXX_Merge 

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

func (*QueryGasConsumersByGasTankIDRequest) XXX_Size 

func (m *QueryGasConsumersByGasTankIDRequest) XXX_Size() int

func (*QueryGasConsumersByGasTankIDRequest) XXX_Unmarshal 

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

type QueryGasConsumersByGasTankIDResponse 

type QueryGasConsumersByGasTankIDResponse struct {
	GasTankId           uint64                            `protobuf:"varint,1,opt,name=gas_tank_id,json=gasTankId,proto3" json:"gas_tank_id,omitempty"`
	OverallFeesConsumed types.Coin                        `protobuf:"bytes,2,opt,name=overall_fees_consumed,json=overallFeesConsumed,proto3" json:"overall_fees_consumed"`
	GasConsumers        []GasConsumersByGasTankIDResponse `protobuf:"bytes,3,rep,name=gas_consumers,json=gasConsumers,proto3" json:"gas_consumers"`
}

QueryGasConsumersByGasTankIDResponse is a response type for the Query/GasConsumersByGasTankID RPC method.

func (*QueryGasConsumersByGasTankIDResponse) Descriptor 

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

func (*QueryGasConsumersByGasTankIDResponse) GetGasConsumers 

func (m *QueryGasConsumersByGasTankIDResponse) GetGasConsumers() []GasConsumersByGasTankIDResponse

func (*QueryGasConsumersByGasTankIDResponse) GetGasTankId 

func (m *QueryGasConsumersByGasTankIDResponse) GetGasTankId() uint64

func (*QueryGasConsumersByGasTankIDResponse) GetOverallFeesConsumed 

func (m *QueryGasConsumersByGasTankIDResponse) GetOverallFeesConsumed() types.Coin

func (*QueryGasConsumersByGasTankIDResponse) Marshal 

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

func (*QueryGasConsumersByGasTankIDResponse) MarshalTo 

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

func (*QueryGasConsumersByGasTankIDResponse) MarshalToSizedBuffer 

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

func (*QueryGasConsumersByGasTankIDResponse) ProtoMessage 

func (*QueryGasConsumersByGasTankIDResponse) ProtoMessage()

func (*QueryGasConsumersByGasTankIDResponse) Reset 

func (m *QueryGasConsumersByGasTankIDResponse) Reset()

func (*QueryGasConsumersByGasTankIDResponse) Size 

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

func (*QueryGasConsumersByGasTankIDResponse) String 

func (m *QueryGasConsumersByGasTankIDResponse) String() string

func (*QueryGasConsumersByGasTankIDResponse) Unmarshal 

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

func (*QueryGasConsumersByGasTankIDResponse) XXX_DiscardUnknown 

func (m *QueryGasConsumersByGasTankIDResponse) XXX_DiscardUnknown()

func (*QueryGasConsumersByGasTankIDResponse) XXX_Marshal 

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

func (*QueryGasConsumersByGasTankIDResponse) XXX_Merge 

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

func (*QueryGasConsumersByGasTankIDResponse) XXX_Size 

func (m *QueryGasConsumersByGasTankIDResponse) XXX_Size() int

func (*QueryGasConsumersByGasTankIDResponse) XXX_Unmarshal 

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

type QueryGasConsumersRequest 

type QueryGasConsumersRequest struct {
	Pagination *query.PageRequest `protobuf:"bytes,1,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryGasConsumersRequest is a request type for the Query/GasConsumers RPC method.

func (*QueryGasConsumersRequest) Descriptor 

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

func (*QueryGasConsumersRequest) GetPagination 

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

func (*QueryGasConsumersRequest) Marshal 

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

func (*QueryGasConsumersRequest) MarshalTo 

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

func (*QueryGasConsumersRequest) MarshalToSizedBuffer 

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

func (*QueryGasConsumersRequest) ProtoMessage 

func (*QueryGasConsumersRequest) ProtoMessage()

func (*QueryGasConsumersRequest) Reset 

func (m *QueryGasConsumersRequest) Reset()

func (*QueryGasConsumersRequest) Size 

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

func (*QueryGasConsumersRequest) String 

func (m *QueryGasConsumersRequest) String() string

func (*QueryGasConsumersRequest) Unmarshal 

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

func (*QueryGasConsumersRequest) XXX_DiscardUnknown 

func (m *QueryGasConsumersRequest) XXX_DiscardUnknown()

func (*QueryGasConsumersRequest) XXX_Marshal 

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

func (*QueryGasConsumersRequest) XXX_Merge 

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

func (*QueryGasConsumersRequest) XXX_Size 

func (m *QueryGasConsumersRequest) XXX_Size() int

func (*QueryGasConsumersRequest) XXX_Unmarshal 

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

type QueryGasConsumersResponse 

type QueryGasConsumersResponse struct {
	GasConsumers []GasConsumer       `protobuf:"bytes,1,rep,name=gas_consumers,json=gasConsumers,proto3" json:"gas_consumers"`
	Pagination   *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryGasConsumersResponse is a response type for the Query/GasConsumers RPC method.

func (*QueryGasConsumersResponse) Descriptor 

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

func (*QueryGasConsumersResponse) GetGasConsumers 

func (m *QueryGasConsumersResponse) GetGasConsumers() []GasConsumer

func (*QueryGasConsumersResponse) GetPagination 

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

func (*QueryGasConsumersResponse) Marshal 

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

func (*QueryGasConsumersResponse) MarshalTo 

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

func (*QueryGasConsumersResponse) MarshalToSizedBuffer 

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

func (*QueryGasConsumersResponse) ProtoMessage 

func (*QueryGasConsumersResponse) ProtoMessage()

func (*QueryGasConsumersResponse) Reset 

func (m *QueryGasConsumersResponse) Reset()

func (*QueryGasConsumersResponse) Size 

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

func (*QueryGasConsumersResponse) String 

func (m *QueryGasConsumersResponse) String() string

func (*QueryGasConsumersResponse) Unmarshal 

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

func (*QueryGasConsumersResponse) XXX_DiscardUnknown 

func (m *QueryGasConsumersResponse) XXX_DiscardUnknown()

func (*QueryGasConsumersResponse) XXX_Marshal 

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

func (*QueryGasConsumersResponse) XXX_Merge 

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

func (*QueryGasConsumersResponse) XXX_Size 

func (m *QueryGasConsumersResponse) XXX_Size() int

func (*QueryGasConsumersResponse) XXX_Unmarshal 

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

type QueryGasTankIdsForAllUsageIdentifiersRequest 

type QueryGasTankIdsForAllUsageIdentifiersRequest struct {
}

func (*QueryGasTankIdsForAllUsageIdentifiersRequest) Descriptor 

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

func (*QueryGasTankIdsForAllUsageIdentifiersRequest) Marshal 

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

func (*QueryGasTankIdsForAllUsageIdentifiersRequest) MarshalTo 

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

func (*QueryGasTankIdsForAllUsageIdentifiersRequest) MarshalToSizedBuffer 

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

func (*QueryGasTankIdsForAllUsageIdentifiersRequest) ProtoMessage 

func (*QueryGasTankIdsForAllUsageIdentifiersRequest) ProtoMessage()

func (*QueryGasTankIdsForAllUsageIdentifiersRequest) Reset 

func (m *QueryGasTankIdsForAllUsageIdentifiersRequest) Reset()

func (*QueryGasTankIdsForAllUsageIdentifiersRequest) Size 

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

func (*QueryGasTankIdsForAllUsageIdentifiersRequest) String 

func (m *QueryGasTankIdsForAllUsageIdentifiersRequest) String() string

func (*QueryGasTankIdsForAllUsageIdentifiersRequest) Unmarshal 

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

func (*QueryGasTankIdsForAllUsageIdentifiersRequest) XXX_DiscardUnknown 

func (m *QueryGasTankIdsForAllUsageIdentifiersRequest) XXX_DiscardUnknown()

func (*QueryGasTankIdsForAllUsageIdentifiersRequest) XXX_Marshal 

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

func (*QueryGasTankIdsForAllUsageIdentifiersRequest) XXX_Merge 

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

func (*QueryGasTankIdsForAllUsageIdentifiersRequest) XXX_Size 

func (m *QueryGasTankIdsForAllUsageIdentifiersRequest) XXX_Size() int

func (*QueryGasTankIdsForAllUsageIdentifiersRequest) XXX_Unmarshal 

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

type QueryGasTankIdsForAllUsageIdentifiersResponse 

type QueryGasTankIdsForAllUsageIdentifiersResponse struct {
	UsageIdentifierToGastankIds []*UsageIdentifierToGasTankIds `` /* 148-byte string literal not displayed */
}

func (*QueryGasTankIdsForAllUsageIdentifiersResponse) Descriptor 

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

func (*QueryGasTankIdsForAllUsageIdentifiersResponse) GetUsageIdentifierToGastankIds 

func (m *QueryGasTankIdsForAllUsageIdentifiersResponse) GetUsageIdentifierToGastankIds() []*UsageIdentifierToGasTankIds

func (*QueryGasTankIdsForAllUsageIdentifiersResponse) Marshal 

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

func (*QueryGasTankIdsForAllUsageIdentifiersResponse) MarshalTo 

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

func (*QueryGasTankIdsForAllUsageIdentifiersResponse) MarshalToSizedBuffer 

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

func (*QueryGasTankIdsForAllUsageIdentifiersResponse) ProtoMessage 

func (*QueryGasTankIdsForAllUsageIdentifiersResponse) ProtoMessage()

func (*QueryGasTankIdsForAllUsageIdentifiersResponse) Reset 

func (m *QueryGasTankIdsForAllUsageIdentifiersResponse) Reset()

func (*QueryGasTankIdsForAllUsageIdentifiersResponse) Size 

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

func (*QueryGasTankIdsForAllUsageIdentifiersResponse) String 

func (m *QueryGasTankIdsForAllUsageIdentifiersResponse) String() string

func (*QueryGasTankIdsForAllUsageIdentifiersResponse) Unmarshal 

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

func (*QueryGasTankIdsForAllUsageIdentifiersResponse) XXX_DiscardUnknown 

func (m *QueryGasTankIdsForAllUsageIdentifiersResponse) XXX_DiscardUnknown()

func (*QueryGasTankIdsForAllUsageIdentifiersResponse) XXX_Marshal 

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

func (*QueryGasTankIdsForAllUsageIdentifiersResponse) XXX_Merge 

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

func (*QueryGasTankIdsForAllUsageIdentifiersResponse) XXX_Size 

func (m *QueryGasTankIdsForAllUsageIdentifiersResponse) XXX_Size() int

func (*QueryGasTankIdsForAllUsageIdentifiersResponse) XXX_Unmarshal 

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

type QueryGasTankRequest 

type QueryGasTankRequest struct {
	GasTankId uint64 `protobuf:"varint,1,opt,name=gas_tank_id,json=gasTankId,proto3" json:"gas_tank_id,omitempty"`
}

QueryGasTankRequest is a request type for the Query/GasTank RPC method.

func (*QueryGasTankRequest) Descriptor 

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

func (*QueryGasTankRequest) GetGasTankId 

func (m *QueryGasTankRequest) GetGasTankId() uint64

func (*QueryGasTankRequest) Marshal 

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

func (*QueryGasTankRequest) MarshalTo 

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

func (*QueryGasTankRequest) MarshalToSizedBuffer 

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

func (*QueryGasTankRequest) ProtoMessage 

func (*QueryGasTankRequest) ProtoMessage()

func (*QueryGasTankRequest) Reset 

func (m *QueryGasTankRequest) Reset()

func (*QueryGasTankRequest) Size 

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

func (*QueryGasTankRequest) String 

func (m *QueryGasTankRequest) String() string

func (*QueryGasTankRequest) Unmarshal 

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

func (*QueryGasTankRequest) XXX_DiscardUnknown 

func (m *QueryGasTankRequest) XXX_DiscardUnknown()

func (*QueryGasTankRequest) XXX_Marshal 

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

func (*QueryGasTankRequest) XXX_Merge 

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

func (*QueryGasTankRequest) XXX_Size 

func (m *QueryGasTankRequest) XXX_Size() int

func (*QueryGasTankRequest) XXX_Unmarshal 

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

type QueryGasTankResponse 

type QueryGasTankResponse struct {
	GasTank GasTankResponse `protobuf:"bytes,1,opt,name=gas_tank,json=gasTank,proto3" json:"gas_tank"`
}

QueryGasTankResponse is a response type for the Query/GasTank RPC method.

func (*QueryGasTankResponse) Descriptor 

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

func (*QueryGasTankResponse) GetGasTank 

func (m *QueryGasTankResponse) GetGasTank() GasTankResponse

func (*QueryGasTankResponse) Marshal 

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

func (*QueryGasTankResponse) MarshalTo 

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

func (*QueryGasTankResponse) MarshalToSizedBuffer 

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

func (*QueryGasTankResponse) ProtoMessage 

func (*QueryGasTankResponse) ProtoMessage()

func (*QueryGasTankResponse) Reset 

func (m *QueryGasTankResponse) Reset()

func (*QueryGasTankResponse) Size 

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

func (*QueryGasTankResponse) String 

func (m *QueryGasTankResponse) String() string

func (*QueryGasTankResponse) Unmarshal 

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

func (*QueryGasTankResponse) XXX_DiscardUnknown 

func (m *QueryGasTankResponse) XXX_DiscardUnknown()

func (*QueryGasTankResponse) XXX_Marshal 

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

func (*QueryGasTankResponse) XXX_Merge 

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

func (*QueryGasTankResponse) XXX_Size 

func (m *QueryGasTankResponse) XXX_Size() int

func (*QueryGasTankResponse) XXX_Unmarshal 

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

type QueryGasTanksByProviderRequest 

type QueryGasTanksByProviderRequest struct {
	// provider specifies the bech32-encoded address that is the gas provider.
	Provider string `protobuf:"bytes,1,opt,name=provider,proto3" json:"provider,omitempty"`
}

QueryGasTanksByProviderRequest is a request type for the Query/GasTanksByProvider RPC method.

func (*QueryGasTanksByProviderRequest) Descriptor 

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

func (*QueryGasTanksByProviderRequest) GetProvider 

func (m *QueryGasTanksByProviderRequest) GetProvider() string

func (*QueryGasTanksByProviderRequest) Marshal 

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

func (*QueryGasTanksByProviderRequest) MarshalTo 

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

func (*QueryGasTanksByProviderRequest) MarshalToSizedBuffer 

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

func (*QueryGasTanksByProviderRequest) ProtoMessage 

func (*QueryGasTanksByProviderRequest) ProtoMessage()

func (*QueryGasTanksByProviderRequest) Reset 

func (m *QueryGasTanksByProviderRequest) Reset()

func (*QueryGasTanksByProviderRequest) Size 

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

func (*QueryGasTanksByProviderRequest) String 

func (m *QueryGasTanksByProviderRequest) String() string

func (*QueryGasTanksByProviderRequest) Unmarshal 

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

func (*QueryGasTanksByProviderRequest) XXX_DiscardUnknown 

func (m *QueryGasTanksByProviderRequest) XXX_DiscardUnknown()

func (*QueryGasTanksByProviderRequest) XXX_Marshal 

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

func (*QueryGasTanksByProviderRequest) XXX_Merge 

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

func (*QueryGasTanksByProviderRequest) XXX_Size 

func (m *QueryGasTanksByProviderRequest) XXX_Size() int

func (*QueryGasTanksByProviderRequest) XXX_Unmarshal 

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

type QueryGasTanksByProviderResponse 

type QueryGasTanksByProviderResponse struct {
	GasTanks []GasTankResponse `protobuf:"bytes,1,rep,name=gas_tanks,json=gasTanks,proto3" json:"gas_tanks"`
}

QueryGasTanksByProviderResponse is a response type for the Query/GasTanksByProvider RPC method.

func (*QueryGasTanksByProviderResponse) Descriptor 

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

func (*QueryGasTanksByProviderResponse) GetGasTanks 

func (m *QueryGasTanksByProviderResponse) GetGasTanks() []GasTankResponse

func (*QueryGasTanksByProviderResponse) Marshal 

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

func (*QueryGasTanksByProviderResponse) MarshalTo 

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

func (*QueryGasTanksByProviderResponse) MarshalToSizedBuffer 

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

func (*QueryGasTanksByProviderResponse) ProtoMessage 

func (*QueryGasTanksByProviderResponse) ProtoMessage()

func (*QueryGasTanksByProviderResponse) Reset 

func (m *QueryGasTanksByProviderResponse) Reset()

func (*QueryGasTanksByProviderResponse) Size 

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

func (*QueryGasTanksByProviderResponse) String 

func (m *QueryGasTanksByProviderResponse) String() string

func (*QueryGasTanksByProviderResponse) Unmarshal 

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

func (*QueryGasTanksByProviderResponse) XXX_DiscardUnknown 

func (m *QueryGasTanksByProviderResponse) XXX_DiscardUnknown()

func (*QueryGasTanksByProviderResponse) XXX_Marshal 

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

func (*QueryGasTanksByProviderResponse) XXX_Merge 

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

func (*QueryGasTanksByProviderResponse) XXX_Size 

func (m *QueryGasTanksByProviderResponse) XXX_Size() int

func (*QueryGasTanksByProviderResponse) XXX_Unmarshal 

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

type QueryGasTanksRequest 

type QueryGasTanksRequest struct {
	Pagination *query.PageRequest `protobuf:"bytes,1,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryGasTanksRequest is a request type for the Query/GasTanks RPC method.

func (*QueryGasTanksRequest) Descriptor 

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

func (*QueryGasTanksRequest) GetPagination 

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

func (*QueryGasTanksRequest) Marshal 

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

func (*QueryGasTanksRequest) MarshalTo 

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

func (*QueryGasTanksRequest) MarshalToSizedBuffer 

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

func (*QueryGasTanksRequest) ProtoMessage 

func (*QueryGasTanksRequest) ProtoMessage()

func (*QueryGasTanksRequest) Reset 

func (m *QueryGasTanksRequest) Reset()

func (*QueryGasTanksRequest) Size 

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

func (*QueryGasTanksRequest) String 

func (m *QueryGasTanksRequest) String() string

func (*QueryGasTanksRequest) Unmarshal 

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

func (*QueryGasTanksRequest) XXX_DiscardUnknown 

func (m *QueryGasTanksRequest) XXX_DiscardUnknown()

func (*QueryGasTanksRequest) XXX_Marshal 

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

func (*QueryGasTanksRequest) XXX_Merge 

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

func (*QueryGasTanksRequest) XXX_Size 

func (m *QueryGasTanksRequest) XXX_Size() int

func (*QueryGasTanksRequest) XXX_Unmarshal 

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

type QueryGasTanksResponse 

type QueryGasTanksResponse struct {
	GasTanks   []GasTankResponse   `protobuf:"bytes,1,rep,name=gas_tanks,json=gasTanks,proto3" json:"gas_tanks"`
	Pagination *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryGasTanksResponse is a response type for the Query/GasTanks RPC method.

func (*QueryGasTanksResponse) Descriptor 

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

func (*QueryGasTanksResponse) GetGasTanks 

func (m *QueryGasTanksResponse) GetGasTanks() []GasTankResponse

func (*QueryGasTanksResponse) GetPagination 

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

func (*QueryGasTanksResponse) Marshal 

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

func (*QueryGasTanksResponse) MarshalTo 

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

func (*QueryGasTanksResponse) MarshalToSizedBuffer 

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

func (*QueryGasTanksResponse) ProtoMessage 

func (*QueryGasTanksResponse) ProtoMessage()

func (*QueryGasTanksResponse) Reset 

func (m *QueryGasTanksResponse) Reset()

func (*QueryGasTanksResponse) Size 

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

func (*QueryGasTanksResponse) String 

func (m *QueryGasTanksResponse) String() string

func (*QueryGasTanksResponse) Unmarshal 

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

func (*QueryGasTanksResponse) XXX_DiscardUnknown 

func (m *QueryGasTanksResponse) XXX_DiscardUnknown()

func (*QueryGasTanksResponse) XXX_Marshal 

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

func (*QueryGasTanksResponse) XXX_Merge 

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

func (*QueryGasTanksResponse) XXX_Size 

func (m *QueryGasTanksResponse) XXX_Size() int

func (*QueryGasTanksResponse) XXX_Unmarshal 

func (m *QueryGasTanksResponse) 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 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 QueryServer 

type QueryServer interface {
	// Params returns parameters of the module.
	Params(context.Context, *QueryParamsRequest) (*QueryParamsResponse, error)
	// AvailableUsageIdentifiers return all available usage identifiers
	AvailableUsageIdentifiers(context.Context, *QueryAvailableUsageIdentifiersRequest) (*QueryAvailableUsageIdentifiersResponse, error)
	// GasTank returns gas tank details
	GasTank(context.Context, *QueryGasTankRequest) (*QueryGasTankResponse, error)
	// GasTanks return details of all the gas tanks
	GasTanks(context.Context, *QueryGasTanksRequest) (*QueryGasTanksResponse, error)
	// GasTanksByProvider return details of all the gas tanks for the given provider
	GasTanksByProvider(context.Context, *QueryGasTanksByProviderRequest) (*QueryGasTanksByProviderResponse, error)
	// GasConsumer returns gas consumer details
	GasConsumer(context.Context, *QueryGasConsumerRequest) (*QueryGasConsumerResponse, error)
	// GasConsumers return details of all the gas consumers
	GasConsumers(context.Context, *QueryGasConsumersRequest) (*QueryGasConsumersResponse, error)
	// GasConsumersByGasTankID return details of all the gas consumers for the given tank ID
	GasConsumersByGasTankID(context.Context, *QueryGasConsumersByGasTankIDRequest) (*QueryGasConsumersByGasTankIDResponse, error)
	// GasTankIdsForAllUsageIdentifiers returns gas tanks ids with all available usage identifiers
	GasTankIdsForAllUsageIdentifiers(context.Context, *QueryGasTankIdsForAllUsageIdentifiersRequest) (*QueryGasTankIdsForAllUsageIdentifiersResponse, 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) BlockConsumer 

func (*UnimplementedMsgServer) BlockConsumer(ctx context.Context, req *MsgBlockConsumer) (*MsgBlockConsumerResponse, error)

func (*UnimplementedMsgServer) CreateGasTank 

func (*UnimplementedMsgServer) CreateGasTank(ctx context.Context, req *MsgCreateGasTank) (*MsgCreateGasTankResponse, error)

func (*UnimplementedMsgServer) UnblockConsumer 

func (*UnimplementedMsgServer) UnblockConsumer(ctx context.Context, req *MsgUnblockConsumer) (*MsgUnblockConsumerResponse, error)

func (*UnimplementedMsgServer) UpdateGasConsumerLimit 

func (*UnimplementedMsgServer) UpdateGasConsumerLimit(ctx context.Context, req *MsgUpdateGasConsumerLimit) (*MsgUpdateGasConsumerLimitResponse, error)

func (*UnimplementedMsgServer) UpdateGasTankConfigs 

func (*UnimplementedMsgServer) UpdateGasTankConfigs(ctx context.Context, req *MsgUpdateGasTankConfig) (*MsgUpdateGasTankConfigResponse, error)

func (*UnimplementedMsgServer) UpdateGasTankStatus 

func (*UnimplementedMsgServer) UpdateGasTankStatus(ctx context.Context, req *MsgUpdateGasTankStatus) (*MsgUpdateGasTankStatusResponse, error)

type UnimplementedQueryServer 

type UnimplementedQueryServer struct {
}

UnimplementedQueryServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryServer) AvailableUsageIdentifiers 

func (*UnimplementedQueryServer) AvailableUsageIdentifiers(ctx context.Context, req *QueryAvailableUsageIdentifiersRequest) (*QueryAvailableUsageIdentifiersResponse, error)

func (*UnimplementedQueryServer) GasConsumer 

func (*UnimplementedQueryServer) GasConsumer(ctx context.Context, req *QueryGasConsumerRequest) (*QueryGasConsumerResponse, error)

func (*UnimplementedQueryServer) GasConsumers 

func (*UnimplementedQueryServer) GasConsumers(ctx context.Context, req *QueryGasConsumersRequest) (*QueryGasConsumersResponse, error)

func (*UnimplementedQueryServer) GasConsumersByGasTankID 

func (*UnimplementedQueryServer) GasConsumersByGasTankID(ctx context.Context, req *QueryGasConsumersByGasTankIDRequest) (*QueryGasConsumersByGasTankIDResponse, error)

func (*UnimplementedQueryServer) GasTank 

func (*UnimplementedQueryServer) GasTank(ctx context.Context, req *QueryGasTankRequest) (*QueryGasTankResponse, error)

func (*UnimplementedQueryServer) GasTankIdsForAllUsageIdentifiers 

func (*UnimplementedQueryServer) GasTankIdsForAllUsageIdentifiers(ctx context.Context, req *QueryGasTankIdsForAllUsageIdentifiersRequest) (*QueryGasTankIdsForAllUsageIdentifiersResponse, error)

func (*UnimplementedQueryServer) GasTanks 

func (*UnimplementedQueryServer) GasTanks(ctx context.Context, req *QueryGasTanksRequest) (*QueryGasTanksResponse, error)

func (*UnimplementedQueryServer) GasTanksByProvider 

func (*UnimplementedQueryServer) GasTanksByProvider(ctx context.Context, req *QueryGasTanksByProviderRequest) (*QueryGasTanksByProviderResponse, error)

func (*UnimplementedQueryServer) Params 

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

type Usage 

type Usage struct {
	// usage identifier defines the gas consumption/usage identifier of the tx, this identifier is responsible for consuming gas
	UsageIdentifier string `protobuf:"bytes,1,opt,name=usage_identifier,json=usageIdentifier,proto3" json:"usage_identifier,omitempty"`
	// details defines the list of usage details by the usage identifier along with fee amount and timestamp
	Details []*Detail `protobuf:"bytes,2,rep,name=details,proto3" json:"details,omitempty"`
}

GasConsumer > ConsumptionDetail > Usage defines the independent usage of gas by the individual usage identifier

func (*Usage) Descriptor 

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

func (*Usage) Marshal 

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

func (*Usage) MarshalTo 

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

func (*Usage) MarshalToSizedBuffer 

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

func (*Usage) ProtoMessage 

func (*Usage) ProtoMessage()

func (*Usage) Reset 

func (m *Usage) Reset()

func (*Usage) Size 

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

func (*Usage) String 

func (m *Usage) String() string

func (*Usage) Unmarshal 

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

func (*Usage) XXX_DiscardUnknown 

func (m *Usage) XXX_DiscardUnknown()

func (*Usage) XXX_Marshal 

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

func (*Usage) XXX_Merge 

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

func (*Usage) XXX_Size 

func (m *Usage) XXX_Size() int

func (*Usage) XXX_Unmarshal 

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

type UsageIdentifierToGasTankIds 

type UsageIdentifierToGasTankIds struct {
	// usage identifier defines the unique identifier for a tx
	UsageIdentifier string `protobuf:"bytes,1,opt,name=usage_identifier,json=usageIdentifier,proto3" json:"usage_identifier,omitempty"`
	// all the associated gas tank ids for the usage identifier
	GasTankIds []uint64 `protobuf:"varint,2,rep,packed,name=gas_tank_ids,json=gasTankIds,proto3" json:"gas_tank_ids,omitempty"`
}

UsageIdentifierToGasTankIds maps all the gas tank ids with the usage identifier results in faster query of gas tanks based on usage identifier

func MustUnmarshalUsageIdentifierToGastankIds 

func MustUnmarshalUsageIdentifierToGastankIds(cdc codec.BinaryCodec, value []byte) UsageIdentifierToGasTankIds

MustUnmarshalUsageIdentifierToGastankIds return the unmarshalled UsageIdentifierToGasTankIds from bytes. It throws panic if it fails.

func NewUsageIdentifierToGastankIds 

func NewUsageIdentifierToGastankIds(usageIdentifier string) UsageIdentifierToGasTankIds

func UnmarshalUsageIdentifierToGastankIds 

func UnmarshalUsageIdentifierToGastankIds(cdc codec.BinaryCodec, value []byte) (usageIdentifierToGastankIds UsageIdentifierToGasTankIds, err error)

UnmarshalUsageIdentifierToGastankIds returns the UsageIdentifierToGasTankIds from bytes.

func (*UsageIdentifierToGasTankIds) Descriptor 

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

func (*UsageIdentifierToGasTankIds) Marshal 

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

func (*UsageIdentifierToGasTankIds) MarshalTo 

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

func (*UsageIdentifierToGasTankIds) MarshalToSizedBuffer 

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

func (*UsageIdentifierToGasTankIds) ProtoMessage 

func (*UsageIdentifierToGasTankIds) ProtoMessage()

func (*UsageIdentifierToGasTankIds) Reset 

func (m *UsageIdentifierToGasTankIds) Reset()

func (*UsageIdentifierToGasTankIds) Size 

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

func (*UsageIdentifierToGasTankIds) String 

func (m *UsageIdentifierToGasTankIds) String() string

func (*UsageIdentifierToGasTankIds) Unmarshal 

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

func (UsageIdentifierToGasTankIds) Validate 

func (usageIdentifierToGasTankIds UsageIdentifierToGasTankIds) Validate() error

func (*UsageIdentifierToGasTankIds) XXX_DiscardUnknown 

func (m *UsageIdentifierToGasTankIds) XXX_DiscardUnknown()

func (*UsageIdentifierToGasTankIds) XXX_Marshal 

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

func (*UsageIdentifierToGasTankIds) XXX_Merge 

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

func (*UsageIdentifierToGasTankIds) XXX_Size 

func (m *UsageIdentifierToGasTankIds) XXX_Size() int

func (*UsageIdentifierToGasTankIds) XXX_Unmarshal 

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

type UsageIdentifiers 

type UsageIdentifiers struct {
	MessageTypes []string           `protobuf:"bytes,1,rep,name=message_types,json=messageTypes,proto3" json:"message_types,omitempty"`
	Contracts    []*ContractDetails `protobuf:"bytes,2,rep,name=contracts,proto3" json:"contracts,omitempty"`
}

UsageIdentifiers defines usage identifiers

func (*UsageIdentifiers) Descriptor 

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

func (*UsageIdentifiers) GetContracts 

func (m *UsageIdentifiers) GetContracts() []*ContractDetails

func (*UsageIdentifiers) GetMessageTypes 

func (m *UsageIdentifiers) GetMessageTypes() []string

func (*UsageIdentifiers) Marshal 

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

func (*UsageIdentifiers) MarshalTo 

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

func (*UsageIdentifiers) MarshalToSizedBuffer 

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

func (*UsageIdentifiers) ProtoMessage 

func (*UsageIdentifiers) ProtoMessage()

func (*UsageIdentifiers) Reset 

func (m *UsageIdentifiers) Reset()

func (*UsageIdentifiers) Size 

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

func (*UsageIdentifiers) String 

func (m *UsageIdentifiers) String() string

func (*UsageIdentifiers) Unmarshal 

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

func (*UsageIdentifiers) XXX_DiscardUnknown 

func (m *UsageIdentifiers) XXX_DiscardUnknown()

func (*UsageIdentifiers) XXX_Marshal 

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

func (*UsageIdentifiers) XXX_Merge 

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

func (*UsageIdentifiers) XXX_Size 

func (m *UsageIdentifiers) XXX_Size() int

func (*UsageIdentifiers) XXX_Unmarshal 

func (m *UsageIdentifiers) XXX_Unmarshal(b []byte) 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.