Versions in this module Expand all Collapse all v0 v0.48.86 Oct 24, 2023 v0.48.84 Oct 24, 2023 Changes in this version + type StreamingService struct + func NewStreamingService(writeDir, filePrefix string, storeKeys []types.StoreKey, cdc types.Codec, ...) (*StreamingService, error) + func (fss *StreamingService) Close() error + func (fss *StreamingService) ListenBeginBlock(ctx context.Context, req abci.RequestBeginBlock, res abci.ResponseBeginBlock) error + func (fss *StreamingService) ListenCommit(ctx context.Context, res abci.ResponseCommit) error + func (fss *StreamingService) ListenDeliverTx(ctx context.Context, req abci.RequestDeliverTx, res abci.ResponseDeliverTx) error + func (fss *StreamingService) ListenEndBlock(ctx context.Context, req abci.RequestEndBlock, res abci.ResponseEndBlock) error + func (fss *StreamingService) Listeners() map[types.StoreKey][]types.WriteListener + func (fss *StreamingService) Stream(wg *sync.WaitGroup) error
Go to main page