queueType persistence.QueueV2Type,
queueName string,
filter := sqlplugin.QueueV2MetadataFilter{
QueueType: queueType,
QueueName: queueName,
}
var (
metadata *sqlplugin.QueueV2MetadataRow
err error
)
switch tc.(type) {
case sqlplugin.Tx:
metadata, err = tc.SelectFromQueueV2MetadataForUpdate(ctx, filter)