MCPcopy
hub / github.com/msgbyte/tianji / sendBuildSurveyClassifyMessageQueue

Function sendBuildSurveyClassifyMessageQueue

src/server/mq/producer.ts:30–35  ·  view source on GitHub ↗
(
  options: z.infer<typeof classifySurveyMQSchema>
)

Source from the content-addressed store, hash-verified

28}
29
30export async function sendBuildSurveyClassifyMessageQueue(
31 options: z.infer<typeof classifySurveyMQSchema>
32) {
33 promMQProduceCounter.inc({ type: 'surveyClassify' });
34 await sock.send(['surveyClassify', JSON.stringify(options)]);
35}
36
37export async function sendBuildSurveyTranslationMessageQueue(
38 options: z.infer<typeof translateSurveyMQSchema>

Callers 1

ai.tsFile · 0.85

Calls 1

sendMethod · 0.65

Tested by

no test coverage detected