Skip to content

Commit

Permalink
Minor changes
Browse files Browse the repository at this point in the history
  • Loading branch information
heyphat committed Jan 24, 2022
1 parent dbba0a0 commit 26ff46c
Show file tree
Hide file tree
Showing 2 changed files with 1 addition and 3 deletions.
1 change: 0 additions & 1 deletion internal/cmd/market/communicator.go
Original file line number Diff line number Diff line change
Expand Up @@ -64,5 +64,4 @@ func (c *communicator) newPayloadWithID(id string, data interface{}) *payload {
when: time.Now(),
what: data,
}

}
3 changes: 1 addition & 2 deletions internal/cmd/market/market.go
Original file line number Diff line number Diff line change
Expand Up @@ -102,9 +102,8 @@ func NewMarket(configFilePath *string) (*MarketStruct, error) {
for {
time.Sleep(time.Minute)
// the duration must be the time period that the watcher is watching on.
duration := time.Minute * 5
ticker := "BTCUSDT"
if synced := Market.IsSynced(ticker, duration); !synced {
if synced := Market.IsSynced(ticker, time.Minute*5); !synced {
Market.notifier.notify(fmt.Sprintf("%s is out of sync for %s", ticker, duration.String()))
}
}
Expand Down

0 comments on commit 26ff46c

Please sign in to comment.