[INFOPLAT-19425] Send legacy telemetry via a dedicated chip-ingress batch client

.mockery.yaml

@@ -215,6 +215,7 @@ packages:
   github.com/smartcontractkit/chainlink/v2/core/services/synchronization:
     interfaces:
       TelemetryService:
+      ChipIngressService:
   github.com/smartcontractkit/chainlink/v2/core/services/synchronization/telem:
     config:
       dir: "{{ .InterfaceDir }}/../mocks"

core/config/docs/core.toml

@@ -104,18 +104,36 @@ LeaseRefreshInterval = '1s' # Default
 UniConn = false # Default
 # Logging toggles verbose logging of the raw telemetry messages being sent.
 Logging = false # Default
-# BufferSize is the number of telemetry messages to buffer before dropping new ones.
+# BufferSize is the number of telemetry messages to buffer before dropping new ones. Ignored when ChipIngressEnabled is true.
 BufferSize = 100 # Default
-# MaxBatchSize is the maximum number of messages to batch into one telemetry request.
+# MaxBatchSize is the maximum number of messages to batch into one telemetry request. Ignored when ChipIngressEnabled is true.
 MaxBatchSize = 50 # Default
 # SendInterval determines how often batched telemetry is sent to the ingress server.
 SendInterval = '500ms' # Default
 # SendTimeout is the max duration to wait for the request to complete when sending batch telemetry.
 SendTimeout = '10s' # Default
 # UseBatchSend toggles sending telemetry to the ingress server using the batch client.
 UseBatchSend = true # Default
-# ChipIngressEnabled enables sending telemetry to CHIP Ingress.
+# ChipIngressEnabled sends all telemetry to ChipIngressEndpoint instead of the WSRPC Endpoints. Endpoints entries are still required and select which chains send telemetry; in this mode only their Network and ChainID are used.
 ChipIngressEnabled = false # Default
+# ChipIngressEndpoint is the host:port of the chip-ingress legacy telemetry endpoint. Required when ChipIngressEnabled is true. Separate from Telemetry.ChipIngressEndpoint, which is Beholder's endpoint.
+ChipIngressEndpoint = '' # Default
+# ChipIngressInsecureConnection disables TLS to ChipIngressEndpoint. Only for local/test setups; not allowed for chain.link hosts.
+ChipIngressInsecureConnection = false # Default
+# ChipIngressBufferSize is the number of telemetry messages buffered for chip-ingress across all jobs; new messages are dropped when it is full. Between 1 and 100000.
+ChipIngressBufferSize = 10000 # Default
+# ChipIngressMaxBatchSize is the max number of messages per chip-ingress PublishBatch request. Between 1 and 500.
+ChipIngressMaxBatchSize = 100 # Default
+# ChipIngressMaxConcurrentSends limits parallel chip-ingress PublishBatch requests. Between 1 and 32.
+ChipIngressMaxConcurrentSends = 10 # Default
+# ChipIngressSendInterval is the max wait before flushing an incomplete chip-ingress batch. Between 50ms and 10s.
+ChipIngressSendInterval = '500ms' # Default
+# ChipIngressSendTimeout is the per-request timeout for chip-ingress PublishBatch. Between 1s and 1m.
+ChipIngressSendTimeout = '10s' # Default
+# ChipIngressMaxGRPCRequestSize is the max serialized PublishBatch request size in bytes; larger batches are split. Between 1 MiB and 10 MiB, and must not exceed the server's receive limit.
+ChipIngressMaxGRPCRequestSize = 10485760 # Default
+# ChipIngressDrainTimeout is the max time shutdown waits to publish buffered chip-ingress telemetry. Messages not sent by then count as send errors. With ChipIngressEnabled, must be less than half of ShutdownGracePeriod.
+ChipIngressDrainTimeout = '1s' # Default
 
 [[TelemetryIngress.Endpoints]] # Example
 # Network aka EVM, Solana, Starknet