aboutsummaryrefslogtreecommitdiffstats
path: root/indexer/config.go
diff options
context:
space:
mode:
authorMeng-Ying Yang <garfield@dexon.org>2018-12-27 19:22:41 +0800
committerWei-Ning Huang <w@byzantine-lab.io>2019-06-12 17:27:20 +0800
commit9da899a81e8c8e564fce464de77f6566dd818c2f (patch)
tree4fc1149be97de3c8a577247659d159a65f0fa921 /indexer/config.go
parent980e57e46f0c7b29357baf31447871abff8192d6 (diff)
downloadgo-tangerine-9da899a81e8c8e564fce464de77f6566dd818c2f.tar
go-tangerine-9da899a81e8c8e564fce464de77f6566dd818c2f.tar.gz
go-tangerine-9da899a81e8c8e564fce464de77f6566dd818c2f.tar.bz2
go-tangerine-9da899a81e8c8e564fce464de77f6566dd818c2f.tar.lz
go-tangerine-9da899a81e8c8e564fce464de77f6566dd818c2f.tar.xz
go-tangerine-9da899a81e8c8e564fce464de77f6566dd818c2f.tar.zst
go-tangerine-9da899a81e8c8e564fce464de77f6566dd818c2f.zip
indexer: support data exporting/forwarding (#103)
To support more effective and flexible blockchain info exploring, we add `indexer` package, defines the flow of indexer dameon, and integrate into dex.Dexon fullnode. For more export options, we use Golang built-in `plugin` package to support mulitple implementations.
Diffstat (limited to 'indexer/config.go')
-rw-r--r--indexer/config.go35
1 files changed, 35 insertions, 0 deletions
diff --git a/indexer/config.go b/indexer/config.go
new file mode 100644
index 000000000..3b626272a
--- /dev/null
+++ b/indexer/config.go
@@ -0,0 +1,35 @@
+package indexer
+
+import (
+ "plugin"
+)
+
+// Config is data sources related configs struct.
+type Config struct {
+ // Used by dex/backend init flow.
+ Enable bool
+
+ // Plugin path for building components.
+ Plugin string
+}
+
+// NewIndexerFromConfig initialize exporter according to given config.
+func NewIndexerFromConfig(bc ReadOnlyBlockChain, c Config) (idx Indexer) {
+ if c.Plugin == "" {
+ // default
+ return
+ }
+
+ plug, err := plugin.Open(c.Plugin)
+ if err != nil {
+ panic(err)
+ }
+
+ symbol, err := plug.Lookup(NewIndexerFuncName)
+ if err != nil {
+ panic(err)
+ }
+
+ idx = symbol.(NewIndexerFunc)(bc, c)
+ return
+}