Method getMessageCountAndLastID

common/persistence/sql/queue_v2.go:439–466

(
	ctx context.Context,
	row *sqlplugin.QueueV2MetadataRow,
)

}

func (q *queueV2) getMessageCountAndLastID(
	ctx context.Context,
	row *sqlplugin.QueueV2MetadataRow,
) (messageCount int64, lastMessageID int64, err error) {
	var ok bool
	lastMessageID, ok, err = q.getMaxMessageID(ctx, row.QueueType, row.QueueName, q.DB)
	if err != nil {
		return 0, 0, serviceerror.NewUnavailablef(
			"getLastMessageID operation failed for queue with type %v and name %v. Error: %v",
			row.QueueType,
			row.QueueName,
			err,
		)
	}
	if !ok {
		return 0, -1, nil // Empty queue
	}
	qm, err := q.extractQueueMetadata(row)
	if err != nil {
		return 0, 0, err
	}
	partition, err := persistence.GetPartitionForQueueV2(row.QueueType, row.QueueName, qm)
	if err != nil {
		return 0, 0, err
	}
	messageCount = lastMessageID - partition.MinMessageId + 1
	return messageCount, lastMessageID, nil
}