updates

2026-09-19 06:31:57 +00:00 · 2022-06-13 20:48:00 -04:00
parent 851f404305
commit 631ac0050a
3 changed files with 36 additions and 0 deletions
@@ -0,0 +1,17 @@
+package kafka
+
+import (
+	"cloud.google.com/go/pubsub"
+
+	"github.com/tendermint/tendermint/state/indexer"
+	"github.com/tendermint/tendermint/state/txindex"
+)
+
+var (
+	_ indexer.BlockIndexer = (*EventSink)(nil)
+	_ txindex.TxIndexer    = (*EventSink)(nil)
+)
+
+type EventSink struct {
+	client *pubsub.Client
+}