Documentation ¶
Index ¶
- Constants
- Variables
- func EndBlocker(ctx sdk.Context, keeper Keeper)
- func InitGenesis(ctx sdk.Context, keeper Keeper, data GenesisState) []abci.ValidatorUpdate
- func NewHandler(keeper Keeper) sdk.Handler
- func NewQuerier(keeper Keeper) sdk.Querier
- func ParamKeyTable() params.KeyTable
- func ValidateGenesis(data GenesisState) error
- type AppModule
- func (am AppModule) BeginBlock(ctx sdk.Context, _ abci.RequestBeginBlock)
- func (am AppModule) EndBlock(ctx sdk.Context, _ abci.RequestEndBlock) []abci.ValidatorUpdate
- func (am AppModule) ExportGenesis(ctx sdk.Context) json.RawMessage
- func (am AppModule) InitGenesis(ctx sdk.Context, data json.RawMessage) []abci.ValidatorUpdate
- func (AppModule) Name() string
- func (am AppModule) NewHandler() sdk.Handler
- func (am AppModule) NewQuerierHandler() sdk.Querier
- func (am AppModule) QuerierRoute() string
- func (am AppModule) RegisterInvariants(ir sdk.InvariantRegistry)
- func (am AppModule) Route() string
- type AppModuleBasic
- func (AppModuleBasic) DefaultGenesis() json.RawMessage
- func (AppModuleBasic) GetQueryCmd(cdc *codec.Codec) *cobra.Command
- func (AppModuleBasic) GetTxCmd(cdc *codec.Codec) *cobra.Command
- func (AppModuleBasic) Name() string
- func (AppModuleBasic) RegisterCodec(cdc *codec.Codec)
- func (AppModuleBasic) RegisterRESTRoutes(ctx context.CLIContext, rtr *mux.Router)
- func (AppModuleBasic) ValidateGenesis(bz json.RawMessage) error
- type GenesisState
- type Keeper
- func (k Keeper) ChargeRequestFee(ctx sdk.Context, ethAddr string) error
- func (k Keeper) GetParams(ctx sdk.Context) types.Params
- func (k Keeper) GetRequest(ctx sdk.Context, channelId []byte, peerFrom string) (Request, bool)
- func (k Keeper) GetRequestGuardId(ctx sdk.Context) uint8
- func (k Keeper) GetSubscription(ctx sdk.Context, ethAddress string) (subscription Subscription, found bool)
- func (k Keeper) IterateSubscriptions(ctx sdk.Context, handler func(subscription Subscription) (stop bool))
- func (k Keeper) RequestCost(ctx sdk.Context) (res sdk.Int)
- func (k Keeper) RequestGuardCount(ctx sdk.Context) (res uint64)
- func (k Keeper) SetParams(ctx sdk.Context, params types.Params)
- func (k Keeper) SetRequest(ctx sdk.Context, request Request)
- func (k Keeper) SetRequestGuardId(ctx sdk.Context, request uint8)
- func (k Keeper) SetSubscription(ctx sdk.Context, subscription Subscription)
- type MsgGuardProof
- type MsgIntendSettle
- type MsgRequestGuard
- type MsgSubscribe
- type Params
- type QueryRequestParams
- type QuerySubscriptionParams
- type Request
- type Subscription
Constants ¶
const ( ModuleName = types.ModuleName RouterKey = types.RouterKey StoreKey = types.StoreKey QuerySubscription = types.QuerySubscription QueryRequest = types.QueryRequest QueryParameters = types.QueryParameters )
const (
DefaultParamspace = types.ModuleName
)
Default parameter namespace
Variables ¶
var ( NewMsgSubscribe = types.NewMsgSubscribe NewMsgRequestGuard = types.NewMsgRequestGuard NewMsgIntendSettle = types.NewMsgIntendSettle NewMsgGuardProof = types.NewMsgGuardProof ModuleCdc = types.ModuleCdc RegisterCodec = types.RegisterCodec NewSubscription = types.NewSubscription NewRequest = types.NewRequest NewQuerySubscriptionParams = types.NewQuerySubscriptionParams NewQueryRequestParams = types.NewQueryRequestParams GetSubscriptionKey = types.GetSubscriptionKey GetRequestKey = types.GetRequestKey SubscriptionKeyPrefix = types.SubscriptionKeyPrefix RequestGuardIdKey = types.RequestGuardIdKey CLIQuerySubscription = cli.QuerySubscription CLIQueryRequest = cli.QueryRequest CLIQueryParams = cli.QueryParams DefaultParams = types.DefaultParams )
Functions ¶
func EndBlocker ¶
EndBlocker called every block, process inflation, update validator set.
func InitGenesis ¶
func InitGenesis(ctx sdk.Context, keeper Keeper, data GenesisState) []abci.ValidatorUpdate
func NewHandler ¶
NewHandler returns a handler for "subscribe" type messages.
func NewQuerier ¶
NewQuerier is the module level router for state queries
func ValidateGenesis ¶
func ValidateGenesis(data GenesisState) error
Types ¶
type AppModule ¶
type AppModule struct { AppModuleBasic // contains filtered or unexported fields }
func NewAppModule ¶
NewAppModule creates a new AppModule Object
func (AppModule) BeginBlock ¶
func (am AppModule) BeginBlock(ctx sdk.Context, _ abci.RequestBeginBlock)
func (AppModule) EndBlock ¶
func (am AppModule) EndBlock(ctx sdk.Context, _ abci.RequestEndBlock) []abci.ValidatorUpdate
func (AppModule) ExportGenesis ¶
func (am AppModule) ExportGenesis(ctx sdk.Context) json.RawMessage
func (AppModule) InitGenesis ¶
func (am AppModule) InitGenesis(ctx sdk.Context, data json.RawMessage) []abci.ValidatorUpdate
func (AppModule) NewHandler ¶
func (AppModule) NewQuerierHandler ¶
func (AppModule) QuerierRoute ¶
func (AppModule) RegisterInvariants ¶
func (am AppModule) RegisterInvariants(ir sdk.InvariantRegistry)
type AppModuleBasic ¶
type AppModuleBasic struct{}
app module Basics object
func (AppModuleBasic) DefaultGenesis ¶
func (AppModuleBasic) DefaultGenesis() json.RawMessage
func (AppModuleBasic) GetQueryCmd ¶
func (AppModuleBasic) GetQueryCmd(cdc *codec.Codec) *cobra.Command
Get the root query command of this module
func (AppModuleBasic) GetTxCmd ¶
func (AppModuleBasic) GetTxCmd(cdc *codec.Codec) *cobra.Command
Get the root tx command of this module
func (AppModuleBasic) Name ¶
func (AppModuleBasic) Name() string
func (AppModuleBasic) RegisterCodec ¶
func (AppModuleBasic) RegisterCodec(cdc *codec.Codec)
func (AppModuleBasic) RegisterRESTRoutes ¶
func (AppModuleBasic) RegisterRESTRoutes(ctx context.CLIContext, rtr *mux.Router)
Register rest routes
func (AppModuleBasic) ValidateGenesis ¶
func (AppModuleBasic) ValidateGenesis(bz json.RawMessage) error
Validation check of the Genesis
type GenesisState ¶
type GenesisState struct {
Params Params `json:"params" yaml:"params"`
}
func DefaultGenesisState ¶
func DefaultGenesisState() GenesisState
func ExportGenesis ¶
func ExportGenesis(ctx sdk.Context, keeper Keeper) GenesisState
func NewGenesisState ¶
func NewGenesisState(params Params) GenesisState
type Keeper ¶
type Keeper struct {
// contains filtered or unexported fields
}
Keeper maintains the link to data storage and exposes getter/setter methods for the various parts of the state machine
func NewKeeper ¶
func NewKeeper(storeKey sdk.StoreKey, cdc *codec.Codec, ethClient *mainchain.EthClient, globalKeeper global.Keeper, slashKeeper slash.Keeper, validatorKeeper validator.Keeper, paramstore params.Subspace) Keeper
NewKeeper creates new instances of the subscribe Keeper
func (Keeper) ChargeRequestFee ¶
Charge the fee for request
func (Keeper) GetRequest ¶
Gets the entire Request metadata for a channelId
func (Keeper) GetRequestGuardId ¶
Gets the request guard id
func (Keeper) GetSubscription ¶
func (k Keeper) GetSubscription(ctx sdk.Context, ethAddress string) (subscription Subscription, found bool)
Gets the entire Subscription metadata for a ethAddress
func (Keeper) IterateSubscriptions ¶
func (k Keeper) IterateSubscriptions(ctx sdk.Context, handler func(subscription Subscription) (stop bool))
IterateSubscriptions iterates over the stored ValidatorSigningInfo
func (Keeper) RequestCost ¶
RequestCost - cost per request
func (Keeper) RequestGuardCount ¶
RequestGuardCount - number of guards to handle the request
func (Keeper) SetRequest ¶
Sets the entire Request metadata for a channelId
func (Keeper) SetRequestGuardId ¶
Sets the request guard id
func (Keeper) SetSubscription ¶
func (k Keeper) SetSubscription(ctx sdk.Context, subscription Subscription)
Sets the entire Subscription metadata for a ethAddress
type MsgGuardProof ¶
type MsgGuardProof = types.MsgGuardProof
type MsgIntendSettle ¶
type MsgIntendSettle = types.MsgIntendSettle
type MsgRequestGuard ¶
type MsgRequestGuard = types.MsgRequestGuard
type MsgSubscribe ¶
type MsgSubscribe = types.MsgSubscribe
type QueryRequestParams ¶
type QueryRequestParams = types.QueryRequestParams
type QuerySubscriptionParams ¶
type QuerySubscriptionParams = types.QuerySubscriptionParams
type Subscription ¶
type Subscription = types.Subscription