|
7 | 7 | # ddev -x validate config -s <INTEGRATION_NAME> |
8 | 8 | # ddev -x validate models -s <INTEGRATION_NAME> |
9 | 9 |
|
| 10 | +from __future__ import annotations |
| 11 | + |
10 | 12 | from collections.abc import Iterator |
11 | 13 | from typing import Any |
12 | 14 |
|
13 | | -from datadog_checks.base.utils.discovery import Service, from_ports |
| 15 | +from datadog_checks.base.utils.discovery import Service, candidate_ports |
| 16 | +from datadog_checks.nginx.config_models import discovery_overrides |
| 17 | +from datadog_checks.nginx.config_models.instance import InstanceConfig |
| 18 | +from datadog_checks.nginx.config_models.shared import SharedConfig |
14 | 19 |
|
15 | 20 |
|
16 | | -def candidates(service: Service) -> Iterator[dict[str, Any]]: |
| 21 | +def _generated_candidates(service: Service) -> Iterator[dict[str, Any]]: |
| 22 | + shared = SharedConfig.model_validate({}, context={'configured_fields': frozenset()}).model_dump( |
| 23 | + by_alias=True, mode='json', exclude_none=True |
| 24 | + ) |
17 | 25 | # discovery[0]: from_ports |
18 | | - for ctx in from_ports(service, port_hints=[80]): |
19 | | - yield { |
20 | | - 'init_config': {}, |
21 | | - 'instances': [ |
22 | | - { |
23 | | - 'nginx_status_url': 'http://{service.host}:{port.number}/nginx_status'.format( |
24 | | - service=service, **ctx |
25 | | - ), |
26 | | - } |
27 | | - ], |
| 26 | + for port in candidate_ports(service, [80]): |
| 27 | + ctx = {'port': port} |
| 28 | + instance_data = { |
| 29 | + 'nginx_status_url': 'http://{service.host}:{port.number}/nginx_status'.format(service=service, **ctx), |
28 | 30 | } |
| 31 | + instance = InstanceConfig.model_validate( |
| 32 | + instance_data, context={'configured_fields': frozenset(instance_data)} |
| 33 | + ).model_dump(by_alias=True, mode='json', exclude_none=True) |
| 34 | + yield {'init_config': shared, 'instances': [instance]} |
| 35 | + |
| 36 | + |
| 37 | +def candidates(service: Service) -> Iterator[dict[str, Any]]: |
| 38 | + override = getattr(discovery_overrides, 'candidates', None) |
| 39 | + if override is None: |
| 40 | + yield from _generated_candidates(service) |
| 41 | + else: |
| 42 | + yield from override(service, default=_generated_candidates) |
0 commit comments