ADR-038 go-plugin system

.gitignore

@@ -45,6 +45,8 @@ vagrant
 # IDE
 .idea
 *.iml
+*.ipr
+*.iws
 .dir-locals.el
 .vscode
 

Makefile

@@ -264,6 +264,12 @@ test-sim-nondeterminism:
 	@go test -mod=readonly $(SIMAPP) -run TestAppStateDeterminism -Enabled=true \
 		-NumBlocks=100 -BlockSize=200 -Commit=true -Period=0 -v -timeout 24h
 
+test-sim-nondeterminism-streaming:
+	@echo "Running non-determinism-streaming test..."
+	@go test -mod=readonly $(SIMAPP) -run TestAppStateDeterminism -Enabled=true \
+		-NumBlocks=100 -BlockSize=200 -Commit=true -Period=0 -v -timeout 24h \
+		-EnableStreaming=true
+
 test-sim-custom-genesis-fast:
 	@echo "Running custom genesis simulation..."
 	@echo "By default, ${HOME}/.gaiad/config/genesis.json will be used."

baseapp/abci.go

@@ -189,10 +189,22 @@ func (app *BaseApp) BeginBlock(req abci.RequestBeginBlock) (res abci.ResponseBeg
 	// set the signed validators for addition to context in deliverTx
 	app.voteInfos = req.LastCommitInfo.GetVotes()
 
-	// call the hooks with the BeginBlock messages
-	for _, streamingListener := range app.abciListeners {
-		if err := streamingListener.ListenBeginBlock(app.deliverState.ctx, req, res); err != nil {
-			app.logger.Error("BeginBlock listening hook failed", "height", req.Header.Height, "err", err)
+	// call the streaming service hook with the BeginBlock messages
+	if app.abciListener != nil {
+		ctx := app.deliverState.ctx
+		blockHeight := ctx.BlockHeight()
+		if app.stopNodeOnStreamingErr {
+			if err := app.abciListener.ListenBeginBlock(ctx, req, res); err != nil {
+				app.logger.Error("BeginBlock listening hook failed", "height", blockHeight, "err", err)
+				os.Exit(1)
+			}
+		} else {
+			rek, rez := req, res
+			go func() {
+				if err := app.abciListener.ListenBeginBlock(ctx, rek, rez); err != nil {
+					app.logger.Error("BeginBlock listening hook failed", "height", blockHeight, "err", err)
+				}
+			}()
 		}
 	}
 
@@ -215,10 +227,22 @@ func (app *BaseApp) EndBlock(req abci.RequestEndBlock) (res abci.ResponseEndBloc
 		res.ConsensusParamUpdates = cp
 	}
 
-	// call the streaming service hooks with the EndBlock messages
-	for _, streamingListener := range app.abciListeners {
-		if err := streamingListener.ListenEndBlock(app.deliverState.ctx, req, res); err != nil {
-			app.logger.Error("EndBlock listening hook failed", "height", req.Height, "err", err)
+	// call the streaming service hook with the EndBlock messages
+	if app.abciListener != nil {
+		ctx := app.deliverState.ctx
+		blockHeight := ctx.BlockHeight()
+		if app.stopNodeOnStreamingErr {
+			if err := app.abciListener.ListenEndBlock(ctx, req, res); err != nil {
+				app.logger.Error("EndBlock listening hook failed", "height", blockHeight, "err", err)
+				os.Exit(1)
+			}
+		} else {
+			rek, rez := req, res
+			go func() {
+				if err := app.abciListener.ListenEndBlock(ctx, rek, rez); err != nil {
+					app.logger.Error("EndBlock listening hook failed", "height", blockHeight, "err", err)
+				}
+			}()
 		}
 	}
 
@@ -269,9 +293,22 @@ func (app *BaseApp) DeliverTx(req abci.RequestDeliverTx) abci.ResponseDeliverTx
 
 	var abciRes abci.ResponseDeliverTx
 	defer func() {
-		for _, streamingListener := range app.abciListeners {
-			if err := streamingListener.ListenDeliverTx(app.deliverState.ctx, req, abciRes); err != nil {
-				app.logger.Error("DeliverTx listening hook failed", "err", err)
+		// call the streaming service hook with the EndBlock messages
+		if app.abciListener != nil {
+			ctx := app.deliverState.ctx
+			blockHeight := ctx.BlockHeight()
+			if app.stopNodeOnStreamingErr {
+				if err := app.abciListener.ListenDeliverTx(ctx, req, abciRes); err != nil {
+					app.logger.Error("DeliverTx listening hook failed", "height", blockHeight, "err", err)
+					os.Exit(1)
+				}
+			} else {
+				rek, rez := req, abciRes
+				go func() {
+					if err := app.abciListener.ListenDeliverTx(ctx, rek, rez); err != nil {
+						app.logger.Error("DeliverTx listening hook failed", "height", blockHeight, "err", err)
+					}
+				}()
 			}
 		}
 	}()

baseapp/baseapp.go

@@ -125,9 +125,12 @@ type BaseApp struct { // nolint: maligned
 	// which informs Tendermint what to index. If empty, all events will be indexed.
 	indexEvents map[string]struct{}
 
-	// abciListeners for hooking into the ABCI message processing of the BaseApp
-	// and exposing the requests and responses to external consumers
-	abciListeners []ABCIListener
+	// abciListener for hooking into the ABCI message processing of the BaseApp
+	// and exposing the requests and responses through gRPC
+	abciListener ABCIListener
+
+	// stopNodeOnStreamingErr halts the node when ABCI streaming service listening results in an error
+	stopNodeOnStreamingErr bool
 }
 
 // NewBaseApp returns a reference to an initialized BaseApp. It accepts a

baseapp/options.go

@@ -238,10 +238,11 @@ func (app *BaseApp) SetInterfaceRegistry(registry types.InterfaceRegistry) {
 // SetStreamingService is used to set a streaming service into the BaseApp hooks and load the listeners into the multistore
 func (app *BaseApp) SetStreamingService(s StreamingService) {
 	// add the listeners for each StoreKey
-	for key, lis := range s.Listeners() {
+	for key, lis := range s.Listeners {
 		app.cms.AddListeners(key, lis)
 	}
 	// register the StreamingService within the BaseApp
 	// BaseApp will pass BeginBlock, DeliverTx, and EndBlock requests and responses to the streaming services to update their ABCI context
-	app.abciListeners = append(app.abciListeners, s)
+	app.abciListener = s.ABCIListener
+	app.stopNodeOnStreamingErr = s.StopNodeOnErr
 }

baseapp/streaming.go

@@ -1,16 +1,17 @@
 package baseapp
 
 import (
-	"io"
-	"sync"
-
-	abci "github.com/tendermint/tendermint/abci/types"
+	"fmt"
+	"github.com/spf13/cast"
+	"os"
 
+	servertypes "github.com/cosmos/cosmos-sdk/server/types"
 	store "github.com/cosmos/cosmos-sdk/store/types"
 	"github.com/cosmos/cosmos-sdk/types"
+	abci "github.com/tendermint/tendermint/abci/types"
 )
 
-// ABCIListener interface used to hook into the ABCI message processing of the BaseApp
+// ABCIListener is the interface that we're exposing as a streaming service.
 type ABCIListener interface {
 	// ListenBeginBlock updates the streaming service with the latest BeginBlock messages
 	ListenBeginBlock(ctx types.Context, req abci.RequestBeginBlock, res abci.ResponseBeginBlock) error
@@ -20,14 +21,142 @@ type ABCIListener interface {
 	ListenDeliverTx(ctx types.Context, req abci.RequestDeliverTx, res abci.ResponseDeliverTx) error
 }
 
-// StreamingService interface for registering WriteListeners with the BaseApp and updating the service with the ABCI messages using the hooks
-type StreamingService interface {
-	// Stream is the streaming service loop, awaits kv pairs and writes them to some destination stream or file
-	Stream(wg *sync.WaitGroup) error
+// StoreListener is the interface that we're exposing as a streaming service.
+type StoreListener interface {
+	// ListenStoreKVPair updates the streaming service with the latest state change message
+	ListenStoreKVPair(ctx types.Context, pair store.StoreKVPair) error
+}
+
+// StreamingService for registering WriteListeners with the BaseApp and updating the service with the ABCI messages using the hooks
+type StreamingService struct {
 	// Listeners returns the streaming service's listeners for the BaseApp to register
-	Listeners() map[store.StoreKey][]store.WriteListener
+	Listeners map[store.StoreKey][]store.WriteListener
 	// ABCIListener interface for hooking into the ABCI messages from inside the BaseApp
-	ABCIListener
-	// Closer interface
-	io.Closer
+	ABCIListener ABCIListener
+	// StopNodeOnErr stops the node when true
+	StopNodeOnErr bool
+}
+
+var (
+	_ store.WriteListener = (*WriteListener)(nil)
+)
+
+// WriteListener writes state changes out to listening service
+type WriteListener struct {
+	bApp          *BaseApp
+	listener      StoreListener
+	stopNodeOnErr bool
+}
+
+// NewWriteListener create an instance of an NewWriteListener that sends StoreKVPair data to listening service
+func NewWriteListener(
+	bApp *BaseApp,
+	listener StoreListener,
+	stopNodeOnErr bool,
+) *WriteListener {
+	return &WriteListener{
+		bApp:          bApp,
+		listener:      listener,
+		stopNodeOnErr: stopNodeOnErr,
+	}
+}
+
+// OnWrite satisfies WriteListener.Listen
+func (iw *WriteListener) OnWrite(storeKey store.StoreKey, key []byte, value []byte, delete bool) {
+	ctx := iw.bApp.deliverState.ctx
+	logger := iw.bApp.logger
+	kvPair := new(store.StoreKVPair)
+	kvPair.StoreKey = storeKey.Name()
+	kvPair.Delete = delete
+	kvPair.Key = key
+	kvPair.Value = value
+	if iw.stopNodeOnErr {
+		if err := iw.listener.ListenStoreKVPair(ctx, *kvPair); err != nil {
+			logger.Error(err.Error(), "storeKey", storeKey)
+			os.Exit(1)
+		}
+	} else {
+		go func() {
+			if err := iw.listener.ListenStoreKVPair(ctx, *kvPair); err != nil {
+				logger.Error(err.Error(), "storeKey", storeKey)
+			}
+		}()
+	}
+}
+
+const (
+	StreamingTomlKey              = "streaming"
+	StreamingEnableTomlKey        = "enable"
+	StreamingPluginTomlKey        = "plugin"
+	StreamingKeysTomlKey          = "keys"
+	StreamingStopNodeOnErrTomlKey = "stop-node-on-err"
+)
+
+// RegisterStreamingService registers the ABCI streaming service provided by the streaming plugin.
+func RegisterStreamingService(
+	bApp *BaseApp,
+	appOpts servertypes.AppOptions,
+	keys map[string]*store.KVStoreKey,
+	streamingService interface{},
+) error {
+	// type checking
+	abciListener, ok := streamingService.(ABCIListener)
+	if !ok {
+		return fmt.Errorf("failed to register streaming service: failed type check %v", streamingService)
+	}
+
+	// streaming service config
+	stopNodeOnErrKey := fmt.Sprintf("%s.%s", StreamingTomlKey, StreamingStopNodeOnErrTomlKey)
+	stopNodeOnErr := cast.ToBool(appOpts.Get(stopNodeOnErrKey))
+	var listeners map[store.StoreKey][]store.WriteListener
+
+	// streaming services can choose not to implement store listening
+	storeListener, ok := streamingService.(StoreListener)
+	if ok {
+		keysKey := fmt.Sprintf("%s.%s", StreamingTomlKey, StreamingKeysTomlKey)
+		exposeKeysStr := cast.ToStringSlice(appOpts.Get(keysKey))
+		exposeStoreKeys := exposeStoreKeys(exposeKeysStr, keys)
+		listeners = make(map[store.StoreKey][]store.WriteListener, len(exposeStoreKeys))
+		writeListener := NewWriteListener(bApp, storeListener, stopNodeOnErr)
+		for _, key := range exposeStoreKeys {
+			listeners[key] = append(listeners[key], writeListener)
+		}
+	}
+
+	// register service with the App
+	bApp.SetStreamingService(StreamingService{
+		Listeners:     listeners,
+		ABCIListener:  abciListener,
+		StopNodeOnErr: stopNodeOnErr,
+	})
+
+	return nil
+}
+
+func exposeAll(list []string) bool {
+	for _, ele := range list {
+		if ele == "*" {
+			return true
+		}
+	}
+	return false
+}
+
+func exposeStoreKeys(keysStr []string, keys map[string]*store.KVStoreKey) []store.StoreKey {
+	var exposeStoreKeys []store.StoreKey
+	if exposeAll(keysStr) {
+		exposeStoreKeys = make([]store.StoreKey, 0, len(keys))
+		for _, storeKey := range keys {
+			exposeStoreKeys = append(exposeStoreKeys, storeKey)
+		}
+	} else {
+		exposeStoreKeys = make([]store.StoreKey, 0, len(keysStr))
+		for _, keyStr := range keysStr {
+			if storeKey, ok := keys[keyStr]; ok {
+				exposeStoreKeys = append(exposeStoreKeys, storeKey)
+			}
+		}
+	}
+
+	return exposeStoreKeys
 }

go.mod

@@ -28,6 +28,8 @@ require (
 	github.com/grpc-ecosystem/go-grpc-middleware v1.3.0
 	github.com/grpc-ecosystem/grpc-gateway v1.16.0
 	github.com/hashicorp/go-getter v1.5.11
+	github.com/hashicorp/go-hclog v1.2.0
+	github.com/hashicorp/go-plugin v1.4.5
 	github.com/hashicorp/golang-lru v0.5.5-0.20210104140557-80c98217689d
 	github.com/hdevalence/ed25519consensus v0.0.0-20220222234857-c00d1f31bab3
 	github.com/improbable-eng/grpc-web v0.15.0
@@ -83,6 +85,7 @@ require (
 	github.com/dvsekhvalnov/jose2go v0.0.0-20200901110807-248326c1351b // indirect
 	github.com/facebookgo/ensure v0.0.0-20200202191622-63f1cf65ac4c // indirect
 	github.com/facebookgo/subset v0.0.0-20200203212716-c811ad88dec4 // indirect
+	github.com/fatih/color v1.13.0 // indirect
 	github.com/felixge/httpsnoop v1.0.1 // indirect
 	github.com/fsnotify/fsnotify v1.5.1 // indirect
 	github.com/go-kit/kit v0.12.0 // indirect
@@ -102,20 +105,23 @@ require (
 	github.com/hashicorp/go-safetemp v1.0.0 // indirect
 	github.com/hashicorp/go-version v1.4.0 // indirect
 	github.com/hashicorp/hcl v1.0.0 // indirect
+	github.com/hashicorp/yamux v0.0.0-20180604194846-3520598351bb // indirect
 	github.com/inconshreveable/mousetrap v1.0.0 // indirect
 	github.com/jmespath/go-jmespath v0.4.0 // indirect
 	github.com/jmhodges/levigo v1.0.0 // indirect
 	github.com/keybase/go-keychain v0.0.0-20190712205309-48d3d31d256d // indirect
 	github.com/klauspost/compress v1.13.6 // indirect
 	github.com/lib/pq v1.10.5 // indirect
 	github.com/libp2p/go-buffer-pool v0.0.2 // indirect
+	github.com/mattn/go-colorable v0.1.12 // indirect
 	github.com/matttproud/golang_protobuf_extensions v1.0.1 // indirect
 	github.com/minio/highwayhash v1.0.2 // indirect
 	github.com/mitchellh/go-homedir v1.1.0 // indirect
 	github.com/mitchellh/go-testing-interface v1.0.0 // indirect
 	github.com/mitchellh/mapstructure v1.4.3 // indirect
 	github.com/mtibben/percent v0.2.1 // indirect
 	github.com/oasisprotocol/curve25519-voi v0.0.0-20210609091139-0a56a4bca00b // indirect
+	github.com/oklog/run v1.0.0 // indirect
 	github.com/pelletier/go-toml v1.9.4 // indirect
 	github.com/pelletier/go-toml/v2 v2.0.0-beta.8 // indirect
 	github.com/petermattis/goid v0.0.0-20180202154549-b0b1615b78e5 // indirect

go.sum

@@ -329,6 +329,7 @@ github.com/fatih/color v1.7.0/go.mod h1:Zm6kSWBoL9eyXnKyktHP6abPY2pDugNf5Kwzbycv
 github.com/fatih/color v1.9.0/go.mod h1:eQcE1qtQxscV5RaZvpXrrb8Drkc3/DdQ+uUYCNjL+zU=
 github.com/fatih/color v1.10.0/go.mod h1:ELkj/draVOlAH/xkhN6mQ50Qd0MPOk5AAr3maGEBuJM=
 github.com/fatih/color v1.12.0/go.mod h1:ELkj/draVOlAH/xkhN6mQ50Qd0MPOk5AAr3maGEBuJM=
+github.com/fatih/color v1.13.0 h1:8LOYc1KYPPmyKMuN8QV2DNRWNbLo6LZ0iLs8+mlH53w=
 github.com/fatih/color v1.13.0/go.mod h1:kLAiJbzzSOZDVNGyDpeOxJ47H46qBXwg5ILebYFFOfk=
 github.com/fatih/structtag v1.2.0/go.mod h1:mBJUNpUnHmRKrKlQQlmCrh5PuhftFbNv8Ys4/aAZl94=
 github.com/felixge/httpsnoop v1.0.1 h1:lvB5Jl89CsZtGIWuTcDM1E/vkVs49/Ml7JJe07l8SPQ=
@@ -591,6 +592,7 @@ github.com/hashicorp/go-getter v1.5.11/go.mod h1:9i48BP6wpWweI/0/+FBjqLrp9S8XtwU
 github.com/hashicorp/go-hclog v0.12.0/go.mod h1:whpDNt7SSdeAju8AWKIWsul05p54N/39EeqMAyrmvFQ=
 github.com/hashicorp/go-hclog v0.16.2/go.mod h1:whpDNt7SSdeAju8AWKIWsul05p54N/39EeqMAyrmvFQ=
 github.com/hashicorp/go-hclog v1.0.0/go.mod h1:whpDNt7SSdeAju8AWKIWsul05p54N/39EeqMAyrmvFQ=
+github.com/hashicorp/go-hclog v1.2.0 h1:La19f8d7WIlm4ogzNHB0JGqs5AUDAZ2UfCY4sJXcJdM=
 github.com/hashicorp/go-hclog v1.2.0/go.mod h1:whpDNt7SSdeAju8AWKIWsul05p54N/39EeqMAyrmvFQ=
 github.com/hashicorp/go-immutable-radix v1.0.0/go.mod h1:0y9vanUI8NX6FsYoO3zeMjhV/C5i9g4Q3DwcSNZ4P60=
 github.com/hashicorp/go-immutable-radix v1.3.1 h1:DKHmCUm2hRBK510BaiZlwvpD40f8bJFeZnpfm2KLowc=
@@ -599,6 +601,8 @@ github.com/hashicorp/go-msgpack v0.5.3/go.mod h1:ahLV/dePpqEmjfWmKiqvPkv/twdG7iP
 github.com/hashicorp/go-multierror v1.0.0/go.mod h1:dHtQlpGsu+cZNNAkkCN/P3hoUDHhCYQXV3UM06sGGrk=
 github.com/hashicorp/go-multierror v1.1.0/go.mod h1:spPvp8C1qA32ftKqdAHm4hHTbPw+vmowP0z+KUhOZdA=
 github.com/hashicorp/go-multierror v1.1.1/go.mod h1:iw975J/qwKPdAO1clOe2L8331t/9/fmwbPZ6JB6eMoM=
+github.com/hashicorp/go-plugin v1.4.5 h1:oTE/oQR4eghggRg8VY7PAz3dr++VwDNBGCcOfIvHpBo=
+github.com/hashicorp/go-plugin v1.4.5/go.mod h1:viDMjcLJuDui6pXb8U4HVfb8AamCWhHGUjr2IrTF67s=
 github.com/hashicorp/go-retryablehttp v0.5.3/go.mod h1:9B5zBasrRhHXnJnui7y6sL7es7NDiJgTc6Er0maI1Xs=
 github.com/hashicorp/go-rootcerts v1.0.0/go.mod h1:K6zTfqpRlCUIjkwsN4Z+hiSfzSTQa6eBIzfwKfwNnHU=
 github.com/hashicorp/go-rootcerts v1.0.2/go.mod h1:pqUvnprVnM5bf7AOirdbb01K4ccR319Vf4pU3K5EGc8=
@@ -633,6 +637,8 @@ github.com/hashicorp/serf v0.8.2/go.mod h1:6hOLApaqBFA1NXqRQAsxw9QxuDEvNxSQRwA/J
 github.com/hashicorp/serf v0.9.5/go.mod h1:UWDWwZeL5cuWDJdl0C6wrvrUwEqtQ4ZKBKKENpqIUyk=
 github.com/hashicorp/serf v0.9.6/go.mod h1:TXZNMjZQijwlDvp+r0b63xZ45H7JmCmgg4gpTwn9UV4=
 github.com/hashicorp/serf v0.9.7/go.mod h1:TXZNMjZQijwlDvp+r0b63xZ45H7JmCmgg4gpTwn9UV4=
+github.com/hashicorp/yamux v0.0.0-20180604194846-3520598351bb h1:b5rjCoWHc7eqmAS4/qyk21ZsHyb6Mxv/jykxvNTkU4M=
+github.com/hashicorp/yamux v0.0.0-20180604194846-3520598351bb/go.mod h1:+NfK9FKeTrX5uv1uIXGdwYDTeHna2qgaIlx54MXqjAM=
 github.com/hdevalence/ed25519consensus v0.0.0-20220222234857-c00d1f31bab3 h1:aSVUgRRRtOrZOC1fYmY9gV0e9z/Iu+xNVSASWjsuyGU=
 github.com/hdevalence/ed25519consensus v0.0.0-20220222234857-c00d1f31bab3/go.mod h1:5PC6ZNPde8bBqU/ewGZig35+UIZtw9Ytxez8/q5ZyFE=
 github.com/hexops/gotextdiff v1.0.3/go.mod h1:pSWU5MAI3yDq+fZBTazCSJysOMbxWL1BSow5/V2vxeg=
@@ -760,6 +766,7 @@ github.com/mattn/go-colorable v0.1.4/go.mod h1:U0ppj6V5qS13XJ6of8GYAs25YV2eR4EVc
 github.com/mattn/go-colorable v0.1.6/go.mod h1:u6P/XSegPjTcexA+o6vUJrdnUu04hMope9wVRipJSqc=
 github.com/mattn/go-colorable v0.1.8/go.mod h1:u6P/XSegPjTcexA+o6vUJrdnUu04hMope9wVRipJSqc=
 github.com/mattn/go-colorable v0.1.9/go.mod h1:u6P/XSegPjTcexA+o6vUJrdnUu04hMope9wVRipJSqc=
+github.com/mattn/go-colorable v0.1.12 h1:jF+Du6AlPIjs2BiUiQlKOX0rt3SujHxPnksPKZbaA40=
 github.com/mattn/go-colorable v0.1.12/go.mod h1:u5H1YNBxpqRaxsYJYSkiCWKzEfiAb1Gb520KVy5xxl4=
 github.com/mattn/go-isatty v0.0.3/go.mod h1:M+lRXTBqGeGNdLjl/ufCoiOlB5xdOkqRJdNxMWT7Zi4=
 github.com/mattn/go-isatty v0.0.4/go.mod h1:M+lRXTBqGeGNdLjl/ufCoiOlB5xdOkqRJdNxMWT7Zi4=
@@ -857,6 +864,7 @@ github.com/nxadm/tail v1.4.8/go.mod h1:+ncqLTQzXmGhMZNUePPaPqPvBxHAIsmXswZKocGu+
 github.com/oasisprotocol/curve25519-voi v0.0.0-20210609091139-0a56a4bca00b h1:MKwruh+HeCSKWphkxuzvRzU4QzDkg7yiPkDVV0cDFgI=
 github.com/oasisprotocol/curve25519-voi v0.0.0-20210609091139-0a56a4bca00b/go.mod h1:TLJifjWF6eotcfzDjKZsDqWJ+73Uvj/N85MvVyrvynM=
 github.com/oklog/oklog v0.3.2/go.mod h1:FCV+B7mhrz4o+ueLpx+KqkyXRGMWOYEvfiXtdGtbWGs=
+github.com/oklog/run v1.0.0 h1:Ru7dDtJNOyC66gQ5dQmaCa0qIsAUFY3sFpK1Xk8igrw=
 github.com/oklog/run v1.0.0/go.mod h1:dlhp/R75TPv97u0XWUtDeV/lRKWPKSdTuV0TZvrmrQA=
 github.com/oklog/ulid v1.3.1/go.mod h1:CirwcVhetQ6Lv90oh/F+FBtV6XMibvdAFo93nm5qn4U=
 github.com/olekukonko/tablewriter v0.0.0-20170122224234-a0225b3f23b5/go.mod h1:vsDQFd/mU46D+Z4whnwzcISnGGzXWMclvtLoiIKAKIo=