Versions in this module Expand all Collapse all v1 v1.0.0 Jun 14, 2023 Changes in this version + const HISTORICAL_BLOCK_FLUSH_EACH + const LIVE_BLOCK_FLUSH_EACH + var FlushCount = metrics.NewCounter("substreams_sink_clickhouse_store_flush_count", ...) + var FlushDuration = metrics.NewCounter("substreams_sink_clickhouse_store_flush_duration", ...) + var FlushedEntriesCount = metrics.NewGauge("substreams_sink_clickhouse_flushed_entries_count", ...) + func RegisterMetrics() + type ClickhouseSinker struct + func New(sink *sink.Sinker, loader *db.Loader, logger *zap.Logger, ...) (*ClickhouseSinker, error) + func (s *ClickhouseSinker) HandleBlockScopedData(ctx context.Context, data *pbsubstreamsrpc.BlockScopedData, isLive *bool, ...) error + func (s *ClickhouseSinker) HandleBlockUndoSignal(ctx context.Context, data *pbsubstreamsrpc.BlockUndoSignal, ...) error + func (s *ClickhouseSinker) Run(ctx context.Context) + type Stats struct + func NewStats(logger *zap.Logger) *Stats + func (s *Stats) Close() + func (s *Stats) LogNow() + func (s *Stats) RecordBlock(block bstream.BlockRef) + func (s *Stats) Start(each time.Duration, cursor *sink.Cursor)