(ctx context.Context, queueType persistence.QueueV2Type, queueName string, tc sqlplugin.TableCRUD)
| 371 | } |
| 372 | |
| 373 | func (q *queueV2) getMaxMessageID(ctx context.Context, queueType persistence.QueueV2Type, queueName string, tc sqlplugin.TableCRUD) (int64, bool, error) { |
| 374 | lastMessageID, err := tc.GetLastEnqueuedMessageIDForUpdateV2(ctx, sqlplugin.QueueV2Filter{ |
| 375 | QueueType: queueType, |
| 376 | QueueName: queueName, |
| 377 | Partition: defaultPartition, |
| 378 | }) |
| 379 | switch { |
| 380 | case err == nil: |
| 381 | return lastMessageID, true, nil |
| 382 | case errors.Is(err, sql.ErrNoRows): |
| 383 | return 0, false, nil |
| 384 | default: |
| 385 | return 0, false, err |
| 386 | } |
| 387 | } |
| 388 | |
| 389 | func (q *queueV2) ListQueues( |
| 390 | ctx context.Context, |
no test coverage detected