| 330 | } |
| 331 | |
| 332 | func (cnf *Configuration) setTransactionDefaults() { |
| 333 | if cnf.Transaction.BatchSize == 0 { |
| 334 | cnf.Transaction.BatchSize = defaultTransaction.BatchSize |
| 335 | } |
| 336 | if cnf.Transaction.MaxQueueSize == 0 { |
| 337 | cnf.Transaction.MaxQueueSize = defaultTransaction.MaxQueueSize |
| 338 | } |
| 339 | if cnf.Transaction.MaxWorkers == 0 { |
| 340 | cnf.Transaction.MaxWorkers = defaultTransaction.MaxWorkers |
| 341 | } |
| 342 | if cnf.Transaction.LockDuration == 0 { |
| 343 | cnf.Transaction.LockDuration = defaultTransaction.LockDuration |
| 344 | } else { |
| 345 | cnf.Transaction.LockDuration = cnf.Transaction.LockDuration * time.Second |
| 346 | } |
| 347 | if cnf.Transaction.LockWaitTimeout == 0 { |
| 348 | cnf.Transaction.LockWaitTimeout = defaultTransaction.LockWaitTimeout |
| 349 | } else if cnf.Transaction.LockWaitTimeout > 0 && cnf.Transaction.LockWaitTimeout < time.Second { |
| 350 | cnf.Transaction.LockWaitTimeout = cnf.Transaction.LockWaitTimeout * time.Second |
| 351 | } |
| 352 | if !cnf.Transaction.EnableCoalescing { |
| 353 | cnf.Transaction.EnableCoalescing = defaultTransaction.EnableCoalescing |
| 354 | } |
| 355 | if cnf.Transaction.IndexQueuePrefix == "" { |
| 356 | cnf.Transaction.IndexQueuePrefix = defaultTransaction.IndexQueuePrefix |
| 357 | } |
| 358 | } |
| 359 | |
| 360 | func (cnf *Configuration) setReconciliationDefaults() { |
| 361 | if cnf.Reconciliation.DefaultStrategy == "" { |