Function pickShard

packages/queue/src/queues.ts:22–27

(projectId: string)

  process.env.QUEUE_CLUSTER ? `{${name}}` : name;

function pickShard(projectId: string) {
  const h = createHash('sha1').update(projectId).digest(); // 20 bytes
  // take first 4 bytes as unsigned int
  const x = h.readUInt32BE(0);
  return x % EVENTS_GROUP_QUEUES_SHARDS; // 0..n-1
}

export const queueLogger = createLogger({ name: 'queue' });