appbase-commit.go

func (a *Appbase) commitBulk(commitNow bool) {

	if a.bulkBodySize >= a.bulkSize || a.bulkService.NumberOfActions() >= APPBASE_BUFFER_LEN || commitNow {
		a.count += a.bulkService.NumberOfActions()
		_, err := a.bulkService.Do()
		if err != nil {
			a.pipe.Err <- NewError(CRITICAL, a.path, fmt.Sprintf("appbase error (%s)", err), nil)
			a.pipe.Stop()
		}
		a.bulkBodySize = 0
	}
}