Add tests

Author: DylanTinianov

core/config/telemetry_config.go

@@ -18,6 +18,7 @@ type Telemetry interface {
 	EmitterExportTimeout() time.Duration
 	ChipIngressEndpoint() string
 	ChipIngressInsecureConnection() bool
+	DurableEmitterEnabled() bool
 	HeartbeatInterval() time.Duration
 	LogStreamingEnabled() bool
 	LogLevel() zapcore.Level

core/config/toml/types.go

@@ -2762,6 +2762,7 @@ type Telemetry struct {
 	AuthHeadersTTL                *commonconfig.Duration
 	ChipIngressEndpoint           *string
 	ChipIngressInsecureConnection *bool
+	DurableEmitterEnabled         *bool
 	HeartbeatInterval             *commonconfig.Duration
 	LogLevel                      *string
 	LogStreamingEnabled           *bool
@@ -2806,6 +2807,9 @@ func (b *Telemetry) setFrom(f *Telemetry) {
 	if v := f.ChipIngressInsecureConnection; v != nil {
 		b.ChipIngressInsecureConnection = v
 	}
+	if v := f.DurableEmitterEnabled; v != nil {
+		b.DurableEmitterEnabled = v
+	}
 	if v := f.HeartbeatInterval; v != nil {
 		b.HeartbeatInterval = v
 	}

core/scripts/go.mod

@@ -46,7 +46,7 @@ require (
 	github.com/shopspring/decimal v1.4.0
 	github.com/smartcontractkit/chainlink-automation v0.8.1
 	github.com/smartcontractkit/chainlink-ccip v0.1.1-solana.0.20260317185256-d5f7db87ae70
-	github.com/smartcontractkit/chainlink-common v0.10.1-0.20260317233127-178dd2eeaa87
+	github.com/smartcontractkit/chainlink-common v0.10.1-0.20260323153253-cc10b6d11a7e
 	github.com/smartcontractkit/chainlink-common/keystore v1.0.2
 	github.com/smartcontractkit/chainlink-data-streams v0.1.12
 	github.com/smartcontractkit/chainlink-deployments-framework v0.86.3

core/scripts/go.sum

@@ -0,0 +1,17 @@
+syntax = "proto3";
+
+// Matches atlas/chip-ingress/cmd/demo_client/pb/demo_client_payload.proto for schema subject
+// chip-demo-pb.DemoClientPayload (see atlas chip-ingress make create-schema).
+option go_package = "github.com/smartcontractkit/chainlink/v2/core/services/beholder;beholder";
+
+package pb;
+
+// Used for testing
+message DemoClientPayload {
+  string id = 1;
+  string domain = 2;
+  string entity = 3;
+  int64 batch_num = 4;
+  int64 message_num = 5;
+  int64 batch_position = 6;
+}