From ef8f7a2d8e710788824e6f4b7fdb4d88659c39f5 Mon Sep 17 00:00:00 2001 From: Christopher Ryan Date: Tue, 26 Jun 2018 15:25:04 -0700 Subject: [PATCH] set polygon api settings --- contrib/polygon/polygon.go | 8 ++++++++ 1 file changed, 8 insertions(+) diff --git a/contrib/polygon/polygon.go b/contrib/polygon/polygon.go index 38778ca45..d039e2ad9 100644 --- a/contrib/polygon/polygon.go +++ b/contrib/polygon/polygon.go @@ -57,6 +57,14 @@ func NewBgWorker(conf map[string]interface{}) (bgworker.BgWorker, error) { func (pf *PolygonFetcher) Run() { api.SetAPIKey(pf.config.APIKey) + if pf.config.BaseURL != "" { + api.SetBaseURL(pf.config.BaseURL) + } + + if pf.config.NatsServers != "" { + api.SetNatsServers(pf.config.NatsServers) + } + go pf.workBackfill() if err := api.Stream(pf.streamHandler, pf.config.Symbols); err != nil {