Versions in this module Expand all Collapse all v0 v0.60.1 Sep 27, 2024 Changes in this version + type IntermediateWriter struct + func NewIntermediateWriter(outChan chan<- []byte) *IntermediateWriter + func (iw *IntermediateWriter) Write(b []byte) (int, error) + type StreamingService struct + func NewStreamingService(writeDir, filePrefix string, storeKeys []types.StoreKey, c codec.BinaryCodec) (*StreamingService, error) + func (fss *StreamingService) Close() error + func (fss *StreamingService) ListenBeginBlock(ctx sdk.Context, req abci.RequestBeginBlock, res abci.ResponseBeginBlock) error + func (fss *StreamingService) ListenDeliverTx(ctx sdk.Context, req abci.RequestDeliverTx, res abci.ResponseDeliverTx) error + func (fss *StreamingService) ListenEndBlock(ctx sdk.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