dm

func SessionArtifactDeclaredConsumer ¶

func SessionArtifactDeclaredConsumer() string

SessionArtifactDeclaredConsumer 构造会话产物声明处理器的持久化消费者名称。

func SessionCompletedConsumer ¶

func SessionCompletedConsumer() string

SessionCompletedConsumer 构造会话完成处理器的持久化消费者名称。

func SessionMessageCompletedSubject ¶

func SessionMessageCompletedSubject(orgid uint, sessionid string) (string, error)

SessionMessageCompletedSubject 构造会话完成 topic，格式为 "org.{org_id}.session.{session_id}.completed"。

func SessionMessageCompletedWildcardSubject ¶

func SessionMessageCompletedWildcardSubject() string

SessionMessageCompletedWildcardSubject 构造会话完成 topic 的通配符模式，格式为 "org.*.session.*.completed"。

func SessionMessageRequestSubject ¶

func SessionMessageRequestSubject(orgid uint, sessionid string) (string, error)

SessionMessageRequestSubject 构造会话请求 topic，格式为 "org.{org_id}.session.{session_id}.request"。

func SessionMessageRequestWildcardSubject ¶

func SessionMessageRequestWildcardSubject() string

SessionMessageRequestWildcardSubject 构造会话请求 topic 的通配符模式，格式为 "org.*.session.*.message.request"。

func SessionResultStreamSubject ¶

func SessionResultStreamSubject(orgid uint, sessionid string) (string, error)

SessionResultStreamSubject 构造会话结果流 topic，格式为 "org.{org_id}.session.{session_id}.stream"。

func SessionResultStreamWildcardSubject ¶

func SessionResultStreamWildcardSubject() string

SessionResultStreamWildcardSubject 构造会话结果流 topic 的通配符模式。 示例: org.*.session.*.message.stream

func SessionStream ¶

func SessionStream() string

func SessionTitleConsumer ¶

func SessionTitleConsumer() string

SessionTitleConsumer 构造会话标题处理器的持久化消费者名称。

func StreamNameFromTopic ¶

func StreamNameFromTopic(topic string) string

StreamNameFromTopic 根据 topic 返回 Stream 名称。

func WorkerApprovalSubject ¶

func WorkerApprovalSubject(orgid, workerid uint) (string, error)

WorkerApprovalSubject 构造 worker 审批 topic，格式为 "org.{org_id}.worker.{worker_id}.approval"。

func WorkerTaskConsumer ¶

func WorkerTaskConsumer() string

WorkerTaskConsumer 返回 worker 任务消费者的持久化消费者名称。 同一 topic 的多个实例共享同一个 durable consumer，由 NATS 做负载均衡。

func WorkerTaskSubject ¶

func WorkerTaskSubject(orgid, workerid uint) (string, error)

WorkerTaskSubject 构造 worker 任务 topic，格式为 "org.{org_id}.worker.{worker_id}.task"。