command

type Config ¶

type Config struct {
	OrgID    uint
	WorkerID uint
}

Config 是 Dispatcher 的配置。

type ControlHandler ¶

type ControlHandler interface {
	HandleControlCommand(ctx context.Context, cmd messaging.WorkerCommand) error
}

ControlHandler 处理 cmd.control lane 的 cancel 命令。

type Dispatcher ¶

type Dispatcher struct {
	// contains filtered or unexported fields
}

Dispatcher 是统一的 worker 命令分发器。

func New(cfg Config, sub Subscriber, handlers Handlers) (*Dispatcher, error)

func (d *Dispatcher) Run(ctx context.Context) error

type Handlers ¶

type Handlers struct {
	Run         RunHandler
	Control     ControlHandler
	Interaction InteractionHandler
	Skill       SkillHandler
}

Handlers 显式包含四类 handler，构造时一次性校验。

type InteractionHandler ¶

type InteractionHandler interface {
	HandleInteractionCommand(ctx context.Context, cmd messaging.WorkerCommand) error
}

InteractionHandler 处理 cmd.interaction lane 的 approval/question 命令。

type RunHandler ¶

type RunHandler interface {
	HandleRunCommand(ctx context.Context, cmd messaging.WorkerCommand, delivery eventbus.ManualDelivery) error
}

RunHandler 处理 cmd.run lane 的 agent run 命令。 delivery 提供手动 Ack 控制（Term/Nak/Ack/NakWithDelay/InProgress）， handler 根据处理阶段决定确认方式：

• 永久错误 → Term（不再重试）
• 临时错误 → NakWithDelay（延迟重试）
• 成功持久化后 → Ack（异步执行）

type SkillHandler ¶

type SkillHandler interface {
	HandleSkillCommand(ctx context.Context, cmd messaging.WorkerCommand, msg *nats.Msg) error
}

SkillHandler 处理 cmd.skill lane 的 skill 管理命令。

type Subscriber ¶

type Subscriber interface {
	Subscribe(ctx context.Context, topic string, consumer string, handler func(msg *nats.Msg)) error
	SubscribeManualDurable(ctx context.Context, topic string, consumer string, handler func(msg *nats.Msg)) error
}

Subscriber 是 Dispatcher 所需的最小订阅接口。 包含自动确认和手动确认两种订阅方式。