lychiyu/bbgo_origin
1
0
Fork 0
mirror of https://github.com/c9s/bbgo.git synced 2024-11-25 16:25:16 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

notify transfer states

Browse Source
This commit is contained in:
c9s 2021-05-16 00:51:12 +08:00
parent 40b5baeda7
commit 16fbbd0e4b
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
pkg/strategy/xbalance/strategy.go
View File

@ -45,7 +45,7 @@ func (s *State) SlackAttachment() slack.Attachment {
{Title: "Total Number of Transfers", Value: fmt.Sprintf("%d", s.DailyNumberOfTransfers), Short: true}, {Title: "Total Number of Transfers", Value: fmt.Sprintf("%d", s.DailyNumberOfTransfers), Short: true},
{Title: "Total Amount of Transfers", Value: util.FormatFloat(s.DailyAmountOfTransfers.Float64(), 4), Short: true}, {Title: "Total Amount of Transfers", Value: util.FormatFloat(s.DailyAmountOfTransfers.Float64(), 4), Short: true},
}, },
Footer: util.Render("since {{ . }}", time.Unix(s.Since, 0).Format(time.RFC822)), Footer: util.Render("Since {{ . }}", time.Unix(s.Since, 0).Format(time.RFC822)),
} }
} }
@ -97,7 +97,7 @@ func (r *WithdrawalRequest) SlackAttachment() slack.Attachment {
{Title: "From", Value: r.FromSession}, {Title: "From", Value: r.FromSession},
{Title: "To", Value: r.ToSession}, {Title: "To", Value: r.ToSession},
}, },
Footer: util.Render("time {{ . }}", time.Now().Format(time.RFC822)), Footer: util.Render("Time {{ . }}", time.Now().Format(time.RFC822)),
// FooterIcon: "", // FooterIcon: "",
} }
} }
@ -221,6 +221,7 @@ func (s *Strategy) checkBalance(ctx context.Context, sessions map[string]*bbgo.E
s.state.DailyNumberOfTransfers += 1 s.state.DailyNumberOfTransfers += 1
s.state.DailyAmountOfTransfers += requiredAmount s.state.DailyAmountOfTransfers += requiredAmount
s.SaveState() s.SaveState()
s.Notifiability.Notify(s.state)
} }
} }