getSnowflakeNode returns a cached snowflake node, creating it once if needed.
()
| 420 | |
| 421 | // getSnowflakeNode returns a cached snowflake node, creating it once if needed. |
| 422 | func (db *DB) getSnowflakeNode() *snowflake.Node { |
| 423 | return db.snowflakeMgr.GetNode() |
| 424 | } |
| 425 | |
| 426 | func (db *DB) doWrites() { |
| 427 | defer db.statusMgr.Done() |