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

grid: use instance id for persistence

Browse Source
This commit is contained in:
c9s 2021-03-20 23:07:01 +08:00
parent ef8543db8a
commit ca27bf100d
1 changed files with 6 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
pkg/strategy/grid/strategy.go
View File

@ -499,10 +499,14 @@ func (s *Strategy) Run(ctx context.Context, orderExecutor bbgo.OrderExecutor, se
return fmt.Errorf("upperPrice (%f) should not be less than or equal to lowerPrice (%f)", s.UpperPrice.Float64(), s.LowerPrice.Float64()) return fmt.Errorf("upperPrice (%f) should not be less than or equal to lowerPrice (%f)", s.UpperPrice.Float64(), s.LowerPrice.Float64())
} }
instanceID := fmt.Sprintf("grid-%s-%d-%d-%d", s.Symbol, s.GridNum, s.UpperPrice, s.LowerPrice)
s.groupID = generateGroupID(instanceID)
log.Infof("using group id %d from fnv(%s)", s.groupID, instanceID)
var stateLoaded = false var stateLoaded = false
if s.Persistence != nil { if s.Persistence != nil {
var state State var state State
if err := s.Persistence.Load(&state, ID, s.Symbol, "state"); err != nil { if err := s.Persistence.Load(&state, ID, instanceID); err != nil {
if err != service.ErrPersistenceNotExists { if err != service.ErrPersistenceNotExists {
return errors.Wrapf(err, "state load error") return errors.Wrapf(err, "state load error")
} }
@ -533,9 +537,6 @@ func (s *Strategy) Run(ctx context.Context, orderExecutor bbgo.OrderExecutor, se
s.Notify("current position %+v", s.state.Position) s.Notify("current position %+v", s.state.Position)
instanceID := fmt.Sprintf("grid-%s-%d", s.Symbol, s.GridNum)
s.groupID = generateGroupID(instanceID)
log.Infof("using group id %d from fnv(%s)", s.groupID, instanceID)
s.orderStore = bbgo.NewOrderStore(s.Symbol) s.orderStore = bbgo.NewOrderStore(s.Symbol)
s.orderStore.BindStream(session.Stream) s.orderStore.BindStream(session.Stream)
@ -552,7 +553,7 @@ func (s *Strategy) Run(ctx context.Context, orderExecutor bbgo.OrderExecutor, se
log.Infof("backing up grid state...") log.Infof("backing up grid state...")
submitOrders := s.activeOrders.Backup() submitOrders := s.activeOrders.Backup()
s.state.Orders = submitOrders s.state.Orders = submitOrders
if err := s.Persistence.Save(s.state, ID, s.Symbol, "snapshot"); err != nil { if err := s.Persistence.Save(s.state, ID, instanceID); err != nil {
log.WithError(err).Error("can not save active order backups") log.WithError(err).Error("can not save active order backups")
} else { } else {
log.Infof("active order snapshot saved") log.Infof("active order snapshot saved")