The highest tagged major version is
Documentation
¶
Index ¶
- Variables
- type Hook
- func (h *Hook) AddAccountsInBlock(accs ...sdk.AccAddress)
- func (h *Hook) AddAccountsInTx(accs ...sdk.AccAddress)
- func (h *Hook) AfterBeginBlock(ctx sdk.Context, req abci.RequestBeginBlock, res abci.ResponseBeginBlock)
- func (h *Hook) AfterDeliverTx(ctx sdk.Context, req abci.RequestDeliverTx, res abci.ResponseDeliverTx)
- func (h *Hook) AfterEndBlock(ctx sdk.Context, req abci.RequestEndBlock, res abci.ResponseEndBlock)
- func (h *Hook) AfterInitChain(ctx sdk.Context, req abci.RequestInitChain, res abci.ResponseInitChain)
- func (h *Hook) ApplyQuery(req abci.RequestQuery) (res abci.ResponseQuery, stop bool)
- func (h *Hook) BeforeCommit()
- func (h *Hook) FlushMessages()
- func (h *Hook) Write(key string, val common.JsDict)
Constants ¶
This section is empty.
Variables ¶
var ( EventTypeInactiveProposal = types.EventTypeInactiveProposal EventTypeActiveProposal = types.EventTypeActiveProposal StatusInactive = 6 )
var ( EventTypeCompleteUnbonding = types.EventTypeCompleteUnbonding EventTypeCompleteRedelegation = types.EventTypeCompleteRedelegation )
Functions ¶
This section is empty.
Types ¶
type Hook ¶
type Hook struct {
// contains filtered or unexported fields
}
Hook uses Kafka functionality to act as an event producer for all events in the blockchains.
func NewHook ¶
func NewHook( cdc *codec.Codec, accountKeeper auth.AccountKeeper, bankKeeper bank.Keeper, supplyKeeper supply.Keeper, stakingKeeper staking.Keeper, mintKeeper mint.Keeper, distrKeeper distr.Keeper, govKeeper gov.Keeper, oracleKeeper keeper.Keeper, kafkaURI string, emitStartState bool, ) *Hook
NewHook creates an emitter hook instance that will be added in Band App.
func (*Hook) AddAccountsInBlock ¶
func (h *Hook) AddAccountsInBlock(accs ...sdk.AccAddress)
AddAccountsInBlock adds the given accounts to the list of accounts to update balances end-of-block.
func (*Hook) AddAccountsInTx ¶
func (h *Hook) AddAccountsInTx(accs ...sdk.AccAddress)
AddAccountsInTx adds the given accounts to the list of accounts to track related account in transaction.
func (*Hook) AfterBeginBlock ¶
func (h *Hook) AfterBeginBlock(ctx sdk.Context, req abci.RequestBeginBlock, res abci.ResponseBeginBlock)
AfterBeginBlock specify actions need to do after begin block period (app.Hook interface).
func (*Hook) AfterDeliverTx ¶
func (h *Hook) AfterDeliverTx(ctx sdk.Context, req abci.RequestDeliverTx, res abci.ResponseDeliverTx)
AfterDeliverTx specify actions need to do after transaction has been processed (app.Hook interface).
func (*Hook) AfterEndBlock ¶
func (h *Hook) AfterEndBlock(ctx sdk.Context, req abci.RequestEndBlock, res abci.ResponseEndBlock)
AfterEndBlock specify actions need to do after end block period (app.Hook interface).
func (*Hook) AfterInitChain ¶
func (h *Hook) AfterInitChain(ctx sdk.Context, req abci.RequestInitChain, res abci.ResponseInitChain)
AfterInitChain specify actions need to do after chain initialization (app.Hook interface).
func (*Hook) ApplyQuery ¶
func (h *Hook) ApplyQuery(req abci.RequestQuery) (res abci.ResponseQuery, stop bool)
ApplyQuery catch the custom query that matches specific paths (app.Hook interface).
func (*Hook) BeforeCommit ¶
func (h *Hook) BeforeCommit()
BeforeCommit specify actions need to do before commit block (app.Hook interface).
func (*Hook) FlushMessages ¶
func (h *Hook) FlushMessages()
FlushMessages publishes all pending messages to Kafka. Blocks until completion.
Source Files