event

type ChatRunConsumer ¶

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

ChatRunConsumer handles chat-run commands from notification-service: create a chat-linked agent run and execute it. Inbox-deduped so a redelivery doesn't create a duplicate run.

func NewChatRunConsumer(rabbitmq messaging.MessageBroker, inboxRepo messaging.InboxRepo, agentDefSvc domain.AgentDefinitionSvc) *ChatRunConsumer

func (c *ChatRunConsumer) Listen(ctx context.Context) error

type RunConsumer ¶

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

func NewRunConsumer(rabbitmq messaging.MessageBroker, inboxRepo messaging.InboxRepo, runner domain.RunnerSvc) *RunConsumer

func (c *RunConsumer) Listen(ctx context.Context) error

func (c *RunConsumer) ListenContinueRun(ctx context.Context) error