Function DefaultExecutor

internal/controller/executor/executor.go:43–49

(eventLog EventLog, registry map[string]agent.Agent)

}

func DefaultExecutor(eventLog EventLog, registry map[string]agent.Agent) agent.Executor {
	return &defaultExecutor{
		execID:   "",
		eventLog: eventLog,
		registry: registry,
	}
}

func (de *defaultExecutor) Exec(ctx context.Context, conversationID string, execID string, start *proto.AgentStart, o agent.OutputHandler) (proto.State, error) {
	execID = newExecID(de.execID, execID)