diff --git a/core/cmd/cosmos_node_commands_test.go b/core/cmd/cosmos_node_commands_test.go
index 9ac7dfb2ba0..1dadee6bfd4 100644
--- a/core/cmd/cosmos_node_commands_test.go
+++ b/core/cmd/cosmos_node_commands_test.go
@@ -11,7 +11,7 @@ import (
 
 	"github.com/smartcontractkit/chainlink-cosmos/pkg/cosmos/config"
 	coscfg "github.com/smartcontractkit/chainlink-cosmos/pkg/cosmos/config"
-	"github.com/smartcontractkit/chainlink-relay/pkg/utils"
+	relayconfig "github.com/smartcontractkit/chainlink-relay/pkg/config"
 
 	"github.com/smartcontractkit/chainlink/v2/core/cmd"
 	"github.com/smartcontractkit/chainlink/v2/core/internal/cltest"
@@ -35,7 +35,7 @@ func TestShell_IndexCosmosNodes(t *testing.T) {
 	chainID := cosmostest.RandomChainID()
 	node := config.Node{
 		Name:          ptr("second"),
-		TendermintURL: utils.MustParseURL("http://tender.mint.test/bombay-12"),
+		TendermintURL: relayconfig.MustParseURL("http://tender.mint.test/bombay-12"),
 	}
 	chain := config.TOMLConfig{
 		ChainID: ptr(chainID),
diff --git a/core/cmd/cosmos_transaction_commands_test.go b/core/cmd/cosmos_transaction_commands_test.go
index 67b014af2c1..2621c229f55 100644
--- a/core/cmd/cosmos_transaction_commands_test.go
+++ b/core/cmd/cosmos_transaction_commands_test.go
@@ -18,11 +18,11 @@ import (
 	cosmosdb "github.com/smartcontractkit/chainlink-cosmos/pkg/cosmos/db"
 	"github.com/smartcontractkit/chainlink-cosmos/pkg/cosmos/denom"
 	"github.com/smartcontractkit/chainlink-cosmos/pkg/cosmos/params"
-	"github.com/smartcontractkit/chainlink-relay/pkg/utils"
-	"github.com/smartcontractkit/chainlink/v2/core/internal/testutils"
+	"github.com/smartcontractkit/chainlink-relay/pkg/config"
 
 	"github.com/smartcontractkit/chainlink/v2/core/cmd"
 	"github.com/smartcontractkit/chainlink/v2/core/internal/cltest"
+	"github.com/smartcontractkit/chainlink/v2/core/internal/testutils"
 	"github.com/smartcontractkit/chainlink/v2/core/internal/testutils/cosmostest"
 	"github.com/smartcontractkit/chainlink/v2/core/services/keystore/keys/cosmoskey"
 )
@@ -50,7 +50,7 @@ func TestShell_SendCosmosCoins(t *testing.T) {
 	nodes := coscfg.Nodes{
 		&coscfg.Node{
 			Name:          ptr("random"),
-			TendermintURL: utils.MustParseURL(url),
+			TendermintURL: config.MustParseURL(url),
 		},
 	}
 	chainConfig := coscfg.TOMLConfig{ChainID: &chainID, Enabled: ptr(true), Chain: cosmosChain, Nodes: nodes}
diff --git a/core/cmd/solana_node_commands_test.go b/core/cmd/solana_node_commands_test.go
index 3f95ebc0d84..7c88557c6de 100644
--- a/core/cmd/solana_node_commands_test.go
+++ b/core/cmd/solana_node_commands_test.go
@@ -9,7 +9,7 @@ import (
 	"github.com/stretchr/testify/assert"
 	"github.com/stretchr/testify/require"
 
-	"github.com/smartcontractkit/chainlink-relay/pkg/utils"
+	"github.com/smartcontractkit/chainlink-relay/pkg/config"
 	solcfg "github.com/smartcontractkit/chainlink-solana/pkg/solana/config"
 
 	"github.com/smartcontractkit/chainlink-solana/pkg/solana"
@@ -35,11 +35,11 @@ func TestShell_IndexSolanaNodes(t *testing.T) {
 	id := solanatest.RandomChainID()
 	node1 := solcfg.Node{
 		Name: ptr("first"),
-		URL:  utils.MustParseURL("https://solana1.example"),
+		URL:  config.MustParseURL("https://solana1.example"),
 	}
 	node2 := solcfg.Node{
 		Name: ptr("second"),
-		URL:  utils.MustParseURL("https://solana2.example"),
+		URL:  config.MustParseURL("https://solana2.example"),
 	}
 	chain := solana.TOMLConfig{
 		ChainID: &id,
diff --git a/core/cmd/solana_transaction_commands_test.go b/core/cmd/solana_transaction_commands_test.go
index cdb182cba41..66347c25204 100644
--- a/core/cmd/solana_transaction_commands_test.go
+++ b/core/cmd/solana_transaction_commands_test.go
@@ -15,7 +15,7 @@ import (
 	"github.com/stretchr/testify/require"
 	"github.com/urfave/cli"
 
-	"github.com/smartcontractkit/chainlink-relay/pkg/utils"
+	"github.com/smartcontractkit/chainlink-relay/pkg/config"
 	solanaClient "github.com/smartcontractkit/chainlink-solana/pkg/solana/client"
 	solcfg "github.com/smartcontractkit/chainlink-solana/pkg/solana/config"
 
@@ -29,7 +29,7 @@ func TestShell_SolanaSendSol(t *testing.T) {
 	url := solanaClient.SetupLocalSolNode(t)
 	node := solcfg.Node{
 		Name: ptr(t.Name()),
-		URL:  utils.MustParseURL(url),
+		URL:  config.MustParseURL(url),
 	}
 	cfg := solana.TOMLConfig{
 		ChainID: &chainID,
diff --git a/core/cmd/starknet_node_commands_test.go b/core/cmd/starknet_node_commands_test.go
index e799e5aac07..2a6dd132100 100644
--- a/core/cmd/starknet_node_commands_test.go
+++ b/core/cmd/starknet_node_commands_test.go
@@ -9,7 +9,7 @@ import (
 	"github.com/stretchr/testify/assert"
 	"github.com/stretchr/testify/require"
 
-	"github.com/smartcontractkit/chainlink-relay/pkg/utils"
+	relayconfig "github.com/smartcontractkit/chainlink-relay/pkg/config"
 	"github.com/smartcontractkit/chainlink-starknet/relayer/pkg/chainlink/config"
 
 	"github.com/smartcontractkit/chainlink/v2/core/cmd"
@@ -34,11 +34,11 @@ func TestShell_IndexStarkNetNodes(t *testing.T) {
 	id := "starknet chain ID"
 	node1 := config.Node{
 		Name: ptr("first"),
-		URL:  utils.MustParseURL("https://starknet1.example"),
+		URL:  relayconfig.MustParseURL("https://starknet1.example"),
 	}
 	node2 := config.Node{
 		Name: ptr("second"),
-		URL:  utils.MustParseURL("https://starknet2.example"),
+		URL:  relayconfig.MustParseURL("https://starknet2.example"),
 	}
 	chain := config.TOMLConfig{
 		ChainID: &id,
diff --git a/core/scripts/go.mod b/core/scripts/go.mod
index eb41312a6ab..afee0c83f64 100644
--- a/core/scripts/go.mod
+++ b/core/scripts/go.mod
@@ -1,6 +1,6 @@
 module github.com/smartcontractkit/chainlink/core/scripts
 
-go 1.21
+go 1.21.3
 
 // Make sure we're working with the latest chainlink libs
 replace github.com/smartcontractkit/chainlink/v2 => ../../
@@ -304,7 +304,8 @@ require (
 	github.com/sirupsen/logrus v1.9.3 // indirect
 	github.com/smartcontractkit/caigo v0.0.0-20230621050857-b29a4ca8c704 // indirect
 	github.com/smartcontractkit/chainlink-cosmos v0.4.1-0.20231109141932-cb1ea9020255 // indirect
-	github.com/smartcontractkit/chainlink-relay v0.1.7-0.20231113174149-046d4ddaca1a // indirect
+	github.com/smartcontractkit/chainlink-llo v0.0.0-20231115154526-abefc17cc332 // indirect
+	github.com/smartcontractkit/chainlink-relay v0.1.7-0.20231115153227-c2e71a404d2f // indirect
 	github.com/smartcontractkit/chainlink-solana v1.0.3-0.20231023133638-72f4e799ab05 // indirect
 	github.com/smartcontractkit/chainlink-starknet/relayer v0.0.1-beta-test.0.20231024133459-1ef3a11319eb // indirect
 	github.com/smartcontractkit/tdh2/go/ocr2/decryptionplugin v0.0.0-20230906073235-9e478e5e19f1 // indirect
diff --git a/core/scripts/go.sum b/core/scripts/go.sum
index 35e85fe2c97..2d1a2981862 100644
--- a/core/scripts/go.sum
+++ b/core/scripts/go.sum
@@ -1464,8 +1464,10 @@ github.com/smartcontractkit/caigo v0.0.0-20230621050857-b29a4ca8c704 h1:T3lFWumv
 github.com/smartcontractkit/caigo v0.0.0-20230621050857-b29a4ca8c704/go.mod h1:2QuJdEouTWjh5BDy5o/vgGXQtR4Gz8yH1IYB5eT7u4M=
 github.com/smartcontractkit/chainlink-cosmos v0.4.1-0.20231109141932-cb1ea9020255 h1:Pt6c7bJU9wIN6PQQnmN8UmYYH6lpfiQ6U/B8yEC2s5s=
 github.com/smartcontractkit/chainlink-cosmos v0.4.1-0.20231109141932-cb1ea9020255/go.mod h1:EHppaccd/LTlTMI2o4dmBHe4BknEgEFFDjDGMNuGb3k=
-github.com/smartcontractkit/chainlink-relay v0.1.7-0.20231113174149-046d4ddaca1a h1:G/pD8uI1PULRJU8Y3eLLzjqQBp9ruG9hj+wWxtyrgTo=
-github.com/smartcontractkit/chainlink-relay v0.1.7-0.20231113174149-046d4ddaca1a/go.mod h1:M9U1JV7IQi8Sfj4JR1qSi1tIh6omgW78W/8SHN/8BUQ=
+github.com/smartcontractkit/chainlink-llo v0.0.0-20231115154526-abefc17cc332 h1:md6WwVyfC5jTR6jXZrs1X0TmxOA8jWTeK+3ZAIw2ch0=
+github.com/smartcontractkit/chainlink-llo v0.0.0-20231115154526-abefc17cc332/go.mod h1:iyWCEOiRl87OCJbAecsVTqE8Qv47aHWLX8KbCKay7XQ=
+github.com/smartcontractkit/chainlink-relay v0.1.7-0.20231115153227-c2e71a404d2f h1:6MsxL2XyzR5BKI8sQv7X2ruNS0l0Jf8OGv7SVSx3WJI=
+github.com/smartcontractkit/chainlink-relay v0.1.7-0.20231115153227-c2e71a404d2f/go.mod h1:rOayi690YxLlkQy959PD8INhOAIAUi9LoN0G+J/CEf4=
 github.com/smartcontractkit/chainlink-solana v1.0.3-0.20231023133638-72f4e799ab05 h1:DaPSVnxe7oz1QJ+AVIhQWs1W3ubQvwvGo9NbHpMs1OQ=
 github.com/smartcontractkit/chainlink-solana v1.0.3-0.20231023133638-72f4e799ab05/go.mod h1:o0Pn1pbaUluboaK6/yhf8xf7TiFCkyFl6WUOdwqamuU=
 github.com/smartcontractkit/chainlink-starknet/relayer v0.0.1-beta-test.0.20231024133459-1ef3a11319eb h1:HiluOfEVGOQTM6BTDImOqYdMZZ7qq7fkZ3TJdmItNr8=
diff --git a/core/services/chainlink/config_test.go b/core/services/chainlink/config_test.go
index 34fcc4bbe91..1376d080699 100644
--- a/core/services/chainlink/config_test.go
+++ b/core/services/chainlink/config_test.go
@@ -17,7 +17,7 @@ import (
 	ocrcommontypes "github.com/smartcontractkit/libocr/commontypes"
 
 	coscfg "github.com/smartcontractkit/chainlink-cosmos/pkg/cosmos/config"
-	relayutils "github.com/smartcontractkit/chainlink-relay/pkg/utils"
+	relayconfig "github.com/smartcontractkit/chainlink-relay/pkg/config"
 	"github.com/smartcontractkit/chainlink-solana/pkg/solana"
 	solcfg "github.com/smartcontractkit/chainlink-solana/pkg/solana/config"
 	stkcfg "github.com/smartcontractkit/chainlink-starknet/relayer/pkg/chainlink/config"
@@ -144,7 +144,7 @@ var (
 					MaxMsgsPerBatch: ptr[int64](13),
 				},
 				Nodes: []*coscfg.Node{
-					{Name: ptr("primary"), TendermintURL: relayutils.MustParseURL("http://columbus.cosmos.com")},
+					{Name: ptr("primary"), TendermintURL: relayconfig.MustParseURL("http://columbus.cosmos.com")},
 				}},
 			{
 				ChainID: ptr("Malaga-420"),
@@ -152,7 +152,7 @@ var (
 					BlocksUntilTxTimeout: ptr[int64](20),
 				},
 				Nodes: []*coscfg.Node{
-					{Name: ptr("secondary"), TendermintURL: relayutils.MustParseURL("http://bombay.cosmos.com")},
+					{Name: ptr("secondary"), TendermintURL: relayconfig.MustParseURL("http://bombay.cosmos.com")},
 				}},
 		},
 		Solana: []*solana.TOMLConfig{
@@ -162,16 +162,16 @@ var (
 					MaxRetries: ptr[int64](12),
 				},
 				Nodes: []*solcfg.Node{
-					{Name: ptr("primary"), URL: relayutils.MustParseURL("http://mainnet.solana.com")},
+					{Name: ptr("primary"), URL: relayconfig.MustParseURL("http://mainnet.solana.com")},
 				},
 			},
 			{
 				ChainID: ptr("testnet"),
 				Chain: solcfg.Chain{
-					OCR2CachePollPeriod: relayutils.MustNewDuration(time.Minute),
+					OCR2CachePollPeriod: relayconfig.MustNewDuration(time.Minute),
 				},
 				Nodes: []*solcfg.Node{
-					{Name: ptr("secondary"), URL: relayutils.MustParseURL("http://testnet.solana.com")},
+					{Name: ptr("secondary"), URL: relayconfig.MustParseURL("http://testnet.solana.com")},
 				},
 			},
 		},
@@ -179,10 +179,10 @@ var (
 			{
 				ChainID: ptr("foobar"),
 				Chain: stkcfg.Chain{
-					ConfirmationPoll: relayutils.MustNewDuration(time.Hour),
+					ConfirmationPoll: relayconfig.MustNewDuration(time.Hour),
 				},
 				Nodes: []*stkcfg.Node{
-					{Name: ptr("primary"), URL: relayutils.MustParseURL("http://stark.node")},
+					{Name: ptr("primary"), URL: relayconfig.MustParseURL("http://stark.node")},
 				},
 			},
 		},
@@ -602,13 +602,13 @@ func TestConfig_Marshal(t *testing.T) {
 			ChainID: ptr("mainnet"),
 			Enabled: ptr(false),
 			Chain: solcfg.Chain{
-				BalancePollPeriod:       relayutils.MustNewDuration(time.Minute),
-				ConfirmPollPeriod:       relayutils.MustNewDuration(time.Second),
-				OCR2CachePollPeriod:     relayutils.MustNewDuration(time.Minute),
-				OCR2CacheTTL:            relayutils.MustNewDuration(time.Hour),
-				TxTimeout:               relayutils.MustNewDuration(time.Hour),
-				TxRetryTimeout:          relayutils.MustNewDuration(time.Minute),
-				TxConfirmTimeout:        relayutils.MustNewDuration(time.Second),
+				BalancePollPeriod:       relayconfig.MustNewDuration(time.Minute),
+				ConfirmPollPeriod:       relayconfig.MustNewDuration(time.Second),
+				OCR2CachePollPeriod:     relayconfig.MustNewDuration(time.Minute),
+				OCR2CacheTTL:            relayconfig.MustNewDuration(time.Hour),
+				TxTimeout:               relayconfig.MustNewDuration(time.Hour),
+				TxRetryTimeout:          relayconfig.MustNewDuration(time.Minute),
+				TxConfirmTimeout:        relayconfig.MustNewDuration(time.Second),
 				SkipPreflight:           ptr(true),
 				Commitment:              ptr("banana"),
 				MaxRetries:              ptr[int64](7),
@@ -616,12 +616,12 @@ func TestConfig_Marshal(t *testing.T) {
 				ComputeUnitPriceMax:     ptr[uint64](1000),
 				ComputeUnitPriceMin:     ptr[uint64](10),
 				ComputeUnitPriceDefault: ptr[uint64](100),
-				FeeBumpPeriod:           relayutils.MustNewDuration(time.Minute),
+				FeeBumpPeriod:           relayconfig.MustNewDuration(time.Minute),
 			},
 			Nodes: []*solcfg.Node{
-				{Name: ptr("primary"), URL: relayutils.MustParseURL("http://solana.web")},
-				{Name: ptr("foo"), URL: relayutils.MustParseURL("http://solana.foo")},
-				{Name: ptr("bar"), URL: relayutils.MustParseURL("http://solana.bar")},
+				{Name: ptr("primary"), URL: relayconfig.MustParseURL("http://solana.web")},
+				{Name: ptr("foo"), URL: relayconfig.MustParseURL("http://solana.foo")},
+				{Name: ptr("bar"), URL: relayconfig.MustParseURL("http://solana.bar")},
 			},
 		},
 	}
@@ -630,14 +630,14 @@ func TestConfig_Marshal(t *testing.T) {
 			ChainID: ptr("foobar"),
 			Enabled: ptr(true),
 			Chain: stkcfg.Chain{
-				OCR2CachePollPeriod: relayutils.MustNewDuration(6 * time.Hour),
-				OCR2CacheTTL:        relayutils.MustNewDuration(3 * time.Minute),
-				RequestTimeout:      relayutils.MustNewDuration(time.Minute + 3*time.Second),
-				TxTimeout:           relayutils.MustNewDuration(13 * time.Second),
-				ConfirmationPoll:    relayutils.MustNewDuration(42 * time.Second),
+				OCR2CachePollPeriod: relayconfig.MustNewDuration(6 * time.Hour),
+				OCR2CacheTTL:        relayconfig.MustNewDuration(3 * time.Minute),
+				RequestTimeout:      relayconfig.MustNewDuration(time.Minute + 3*time.Second),
+				TxTimeout:           relayconfig.MustNewDuration(13 * time.Second),
+				ConfirmationPoll:    relayconfig.MustNewDuration(42 * time.Second),
 			},
 			Nodes: []*stkcfg.Node{
-				{Name: ptr("primary"), URL: relayutils.MustParseURL("http://stark.node")},
+				{Name: ptr("primary"), URL: relayconfig.MustParseURL("http://stark.node")},
 			},
 		},
 	}
@@ -647,21 +647,21 @@ func TestConfig_Marshal(t *testing.T) {
 			Enabled: ptr(true),
 			Chain: coscfg.Chain{
 				Bech32Prefix:         ptr("wasm"),
-				BlockRate:            relayutils.MustNewDuration(time.Minute),
+				BlockRate:            relayconfig.MustNewDuration(time.Minute),
 				BlocksUntilTxTimeout: ptr[int64](12),
-				ConfirmPollPeriod:    relayutils.MustNewDuration(time.Second),
+				ConfirmPollPeriod:    relayconfig.MustNewDuration(time.Second),
 				FallbackGasPrice:     mustDecimal("0.001"),
 				GasToken:             ptr("ucosm"),
 				GasLimitMultiplier:   mustDecimal("1.2"),
 				MaxMsgsPerBatch:      ptr[int64](17),
-				OCR2CachePollPeriod:  relayutils.MustNewDuration(time.Minute),
-				OCR2CacheTTL:         relayutils.MustNewDuration(time.Hour),
-				TxMsgTimeout:         relayutils.MustNewDuration(time.Second),
+				OCR2CachePollPeriod:  relayconfig.MustNewDuration(time.Minute),
+				OCR2CacheTTL:         relayconfig.MustNewDuration(time.Hour),
+				TxMsgTimeout:         relayconfig.MustNewDuration(time.Second),
 			},
 			Nodes: []*coscfg.Node{
-				{Name: ptr("primary"), TendermintURL: relayutils.MustParseURL("http://tender.mint")},
-				{Name: ptr("foo"), TendermintURL: relayutils.MustParseURL("http://foo.url")},
-				{Name: ptr("bar"), TendermintURL: relayutils.MustParseURL("http://bar.web")},
+				{Name: ptr("primary"), TendermintURL: relayconfig.MustParseURL("http://tender.mint")},
+				{Name: ptr("foo"), TendermintURL: relayconfig.MustParseURL("http://foo.url")},
+				{Name: ptr("bar"), TendermintURL: relayconfig.MustParseURL("http://bar.web")},
 			},
 		},
 	}
diff --git a/core/services/chainlink/relayer_chain_interoperators_test.go b/core/services/chainlink/relayer_chain_interoperators_test.go
index 87293069646..1d4768c5dbd 100644
--- a/core/services/chainlink/relayer_chain_interoperators_test.go
+++ b/core/services/chainlink/relayer_chain_interoperators_test.go
@@ -10,8 +10,8 @@ import (
 	"github.com/stretchr/testify/require"
 
 	coscfg "github.com/smartcontractkit/chainlink-cosmos/pkg/cosmos/config"
+	relayconfig "github.com/smartcontractkit/chainlink-relay/pkg/config"
 	"github.com/smartcontractkit/chainlink-relay/pkg/loop"
-	relayutils "github.com/smartcontractkit/chainlink-relay/pkg/utils"
 	solcfg "github.com/smartcontractkit/chainlink-solana/pkg/solana/config"
 	stkcfg "github.com/smartcontractkit/chainlink-starknet/relayer/pkg/chainlink/config"
 
@@ -84,7 +84,7 @@ func TestCoreRelayerChainInteroperators(t *testing.T) {
 				Chain:   solcfg.Chain{},
 				Nodes: []*solcfg.Node{{
 					Name: ptr("solana chain 1 node 1"),
-					URL:  ((*relayutils.URL)(models.MustParseURL("http://localhost:8547").URL())),
+					URL:  (*relayconfig.URL)(models.MustParseURL("http://localhost:8547").URL()),
 				}},
 			},
 			&solana.TOMLConfig{
@@ -93,7 +93,7 @@ func TestCoreRelayerChainInteroperators(t *testing.T) {
 				Chain:   solcfg.Chain{},
 				Nodes: []*solcfg.Node{{
 					Name: ptr("solana chain 2 node 1"),
-					URL:  ((*relayutils.URL)(models.MustParseURL("http://localhost:8527").URL())),
+					URL:  (*relayconfig.URL)(models.MustParseURL("http://localhost:8527").URL()),
 				}},
 			},
 		}
@@ -106,15 +106,15 @@ func TestCoreRelayerChainInteroperators(t *testing.T) {
 				Nodes: []*stkcfg.Node{
 					{
 						Name: ptr("starknet chain 1 node 1"),
-						URL:  ((*relayutils.URL)(models.MustParseURL("http://localhost:8547").URL())),
+						URL:  (*relayconfig.URL)(models.MustParseURL("http://localhost:8547").URL()),
 					},
 					{
 						Name: ptr("starknet chain 1 node 2"),
-						URL:  ((*relayutils.URL)(models.MustParseURL("http://localhost:8548").URL())),
+						URL:  (*relayconfig.URL)(models.MustParseURL("http://localhost:8548").URL()),
 					},
 					{
 						Name: ptr("starknet chain 1 node 3"),
-						URL:  ((*relayutils.URL)(models.MustParseURL("http://localhost:8549").URL())),
+						URL:  (*relayconfig.URL)(models.MustParseURL("http://localhost:8549").URL()),
 					},
 				},
 			},
@@ -125,7 +125,7 @@ func TestCoreRelayerChainInteroperators(t *testing.T) {
 				Nodes: []*stkcfg.Node{
 					{
 						Name: ptr("starknet chain 2 node 1"),
-						URL:  ((*relayutils.URL)(models.MustParseURL("http://localhost:3547").URL())),
+						URL:  (*relayconfig.URL)(models.MustParseURL("http://localhost:3547").URL()),
 					},
 				},
 			},
@@ -143,7 +143,7 @@ func TestCoreRelayerChainInteroperators(t *testing.T) {
 				Nodes: coscfg.Nodes{
 					&coscfg.Node{
 						Name:          ptr("cosmos chain 1 node 1"),
-						TendermintURL: (*relayutils.URL)(models.MustParseURL("http://localhost:9548").URL()),
+						TendermintURL: (*relayconfig.URL)(models.MustParseURL("http://localhost:9548").URL()),
 					},
 				},
 			},
@@ -158,7 +158,7 @@ func TestCoreRelayerChainInteroperators(t *testing.T) {
 				Nodes: coscfg.Nodes{
 					&coscfg.Node{
 						Name:          ptr("cosmos chain 2 node 1"),
-						TendermintURL: (*relayutils.URL)(models.MustParseURL("http://localhost:9598").URL()),
+						TendermintURL: (*relayconfig.URL)(models.MustParseURL("http://localhost:9598").URL()),
 					},
 				},
 			},
diff --git a/core/services/ocr2/plugins/mercury/integration_test.go b/core/services/ocr2/plugins/mercury/integration_test.go
index e7e059289a2..00dc370598e 100644
--- a/core/services/ocr2/plugins/mercury/integration_test.go
+++ b/core/services/ocr2/plugins/mercury/integration_test.go
@@ -34,10 +34,11 @@ import (
 	ocr2types "github.com/smartcontractkit/libocr/offchainreporting2plus/types"
 	"github.com/smartcontractkit/wsrpc/credentials"
 
-	relaymercury "github.com/smartcontractkit/chainlink-relay/pkg/reportingplugins/mercury"
-	relaycodecv1 "github.com/smartcontractkit/chainlink-relay/pkg/reportingplugins/mercury/v1"
-	relaycodecv2 "github.com/smartcontractkit/chainlink-relay/pkg/reportingplugins/mercury/v2"
-	relaycodecv3 "github.com/smartcontractkit/chainlink-relay/pkg/reportingplugins/mercury/v3"
+	relaymercury "github.com/smartcontractkit/chainlink-llo/mercury"
+	mercurytypes "github.com/smartcontractkit/chainlink-relay/pkg/types/mercury"
+	v1 "github.com/smartcontractkit/chainlink-relay/pkg/types/mercury/v1"
+	v2 "github.com/smartcontractkit/chainlink-relay/pkg/types/mercury/v2"
+	v3 "github.com/smartcontractkit/chainlink-relay/pkg/types/mercury/v3"
 
 	"github.com/smartcontractkit/chainlink/v2/core/assets"
 	"github.com/smartcontractkit/chainlink/v2/core/bridges"
@@ -62,7 +63,7 @@ var (
 	f                      = uint8(1)
 	n                      = 4 // number of nodes
 	multiplier       int64 = 100000000
-	rawOnchainConfig       = relaymercury.OnchainConfig{
+	rawOnchainConfig       = mercurytypes.OnchainConfig{
 		Min: big.NewInt(0),
 		Max: big.NewInt(math.MaxInt64),
 	}
@@ -154,7 +155,7 @@ func TestIntegration_MercuryV1(t *testing.T) {
 	serverKey := csakey.MustNewV2XXXTestingOnly(big.NewInt(-1))
 	serverPubKey := serverKey.PublicKey
 	srv := NewMercuryServer(t, ed25519.PrivateKey(serverKey.Raw()), reqs, func() []byte {
-		report, err := (&reportcodecv1.ReportCodec{}).BuildReport(relaycodecv1.ReportFields{BenchmarkPrice: big.NewInt(234567), Bid: big.NewInt(1), Ask: big.NewInt(1), CurrentBlockHash: make([]byte, 32)})
+		report, err := (&reportcodecv1.ReportCodec{}).BuildReport(v1.ReportFields{BenchmarkPrice: big.NewInt(234567), Bid: big.NewInt(1), Ask: big.NewInt(1), CurrentBlockHash: make([]byte, 32)})
 		if err != nil {
 			panic(err)
 		}
@@ -503,7 +504,7 @@ func TestIntegration_MercuryV2(t *testing.T) {
 	serverKey := csakey.MustNewV2XXXTestingOnly(big.NewInt(-1))
 	serverPubKey := serverKey.PublicKey
 	srv := NewMercuryServer(t, ed25519.PrivateKey(serverKey.Raw()), reqs, func() []byte {
-		report, err := (&reportcodecv2.ReportCodec{}).BuildReport(relaycodecv2.ReportFields{BenchmarkPrice: big.NewInt(234567), LinkFee: big.NewInt(1), NativeFee: big.NewInt(1)})
+		report, err := (&reportcodecv2.ReportCodec{}).BuildReport(v2.ReportFields{BenchmarkPrice: big.NewInt(234567), LinkFee: big.NewInt(1), NativeFee: big.NewInt(1)})
 		if err != nil {
 			panic(err)
 		}
@@ -779,7 +780,7 @@ func TestIntegration_MercuryV3(t *testing.T) {
 	serverKey := csakey.MustNewV2XXXTestingOnly(big.NewInt(-1))
 	serverPubKey := serverKey.PublicKey
 	srv := NewMercuryServer(t, ed25519.PrivateKey(serverKey.Raw()), reqs, func() []byte {
-		report, err := (&reportcodecv3.ReportCodec{}).BuildReport(relaycodecv3.ReportFields{BenchmarkPrice: big.NewInt(234567), Bid: big.NewInt(1), Ask: big.NewInt(1), LinkFee: big.NewInt(1), NativeFee: big.NewInt(1)})
+		report, err := (&reportcodecv3.ReportCodec{}).BuildReport(v3.ReportFields{BenchmarkPrice: big.NewInt(234567), Bid: big.NewInt(1), Ask: big.NewInt(1), LinkFee: big.NewInt(1), NativeFee: big.NewInt(1)})
 		if err != nil {
 			panic(err)
 		}
diff --git a/core/services/ocr2/plugins/mercury/plugin.go b/core/services/ocr2/plugins/mercury/plugin.go
index ddef1374a4c..25ca8ac14ef 100644
--- a/core/services/ocr2/plugins/mercury/plugin.go
+++ b/core/services/ocr2/plugins/mercury/plugin.go
@@ -7,9 +7,9 @@ import (
 
 	libocr2 "github.com/smartcontractkit/libocr/offchainreporting2plus"
 
-	relaymercuryv1 "github.com/smartcontractkit/chainlink-relay/pkg/reportingplugins/mercury/v1"
-	relaymercuryv2 "github.com/smartcontractkit/chainlink-relay/pkg/reportingplugins/mercury/v2"
-	relaymercuryv3 "github.com/smartcontractkit/chainlink-relay/pkg/reportingplugins/mercury/v3"
+	relaymercuryv1 "github.com/smartcontractkit/chainlink-llo/mercury/v1"
+	relaymercuryv2 "github.com/smartcontractkit/chainlink-llo/mercury/v2"
+	relaymercuryv3 "github.com/smartcontractkit/chainlink-llo/mercury/v3"
 	relaytypes "github.com/smartcontractkit/chainlink-relay/pkg/types"
 
 	"github.com/smartcontractkit/chainlink/v2/core/logger"
diff --git a/core/services/ocrcommon/telemetry.go b/core/services/ocrcommon/telemetry.go
index be139723ef2..f130a589256 100644
--- a/core/services/ocrcommon/telemetry.go
+++ b/core/services/ocrcommon/telemetry.go
@@ -21,9 +21,9 @@ import (
 	"github.com/smartcontractkit/chainlink/v2/core/services/synchronization/telem"
 	"github.com/smartcontractkit/chainlink/v2/core/utils"
 
-	relaymercuryv1 "github.com/smartcontractkit/chainlink-relay/pkg/reportingplugins/mercury/v1"
-	relaymercuryv2 "github.com/smartcontractkit/chainlink-relay/pkg/reportingplugins/mercury/v2"
-	relaymercuryv3 "github.com/smartcontractkit/chainlink-relay/pkg/reportingplugins/mercury/v3"
+	v1types "github.com/smartcontractkit/chainlink-relay/pkg/types/mercury/v1"
+	v2types "github.com/smartcontractkit/chainlink-relay/pkg/types/mercury/v2"
+	v3types "github.com/smartcontractkit/chainlink-relay/pkg/types/mercury/v3"
 )
 
 type eaTelemetry struct {
@@ -41,9 +41,9 @@ type EnhancedTelemetryData struct {
 }
 
 type EnhancedTelemetryMercuryData struct {
-	V1Observation              *relaymercuryv1.Observation
-	V2Observation              *relaymercuryv2.Observation
-	V3Observation              *relaymercuryv3.Observation
+	V1Observation              *v1types.Observation
+	V2Observation              *v2types.Observation
+	V3Observation              *v3types.Observation
 	TaskRunResults             pipeline.TaskRunResults
 	RepTimestamp               ocrtypes.ReportTimestamp
 	FeedVersion                mercuryutils.FeedVersion
diff --git a/core/services/ocrcommon/telemetry_test.go b/core/services/ocrcommon/telemetry_test.go
index 9e3dedce8a8..07f859fa638 100644
--- a/core/services/ocrcommon/telemetry_test.go
+++ b/core/services/ocrcommon/telemetry_test.go
@@ -6,16 +6,17 @@ import (
 	"testing"
 
 	"github.com/ethereum/go-ethereum/common"
-	"github.com/smartcontractkit/libocr/offchainreporting2plus/types"
 	"github.com/stretchr/testify/assert"
 	"github.com/stretchr/testify/mock"
 	"github.com/stretchr/testify/require"
 	"go.uber.org/zap"
 	"google.golang.org/protobuf/proto"
 
-	"github.com/smartcontractkit/chainlink-relay/pkg/reportingplugins/mercury"
-	mercuryv1 "github.com/smartcontractkit/chainlink-relay/pkg/reportingplugins/mercury/v1"
-	mercury_v2 "github.com/smartcontractkit/chainlink-relay/pkg/reportingplugins/mercury/v2"
+	"github.com/smartcontractkit/libocr/offchainreporting2plus/types"
+
+	"github.com/smartcontractkit/chainlink-relay/pkg/types/mercury"
+	mercuryv1 "github.com/smartcontractkit/chainlink-relay/pkg/types/mercury/v1"
+	mercuryv2 "github.com/smartcontractkit/chainlink-relay/pkg/types/mercury/v2"
 
 	"github.com/smartcontractkit/chainlink/v2/core/internal/testutils"
 	"github.com/smartcontractkit/chainlink/v2/core/logger"
@@ -695,7 +696,7 @@ func TestCollectMercuryEnhancedTelemetryV2(t *testing.T) {
 
 	chTelem <- EnhancedTelemetryMercuryData{
 		TaskRunResults: trrsMercuryV2,
-		V2Observation: &mercury_v2.Observation{
+		V2Observation: &mercuryv2.Observation{
 			BenchmarkPrice:        mercury.ObsResult[*big.Int]{Val: big.NewInt(111111)},
 			MaxFinalizedTimestamp: mercury.ObsResult[int64]{Val: 321},
 			LinkPrice:             mercury.ObsResult[*big.Int]{Val: big.NewInt(4321)},
@@ -748,7 +749,7 @@ func TestCollectMercuryEnhancedTelemetryV2(t *testing.T) {
 					Value: nil,
 				}},
 		},
-		V2Observation: &mercury_v2.Observation{},
+		V2Observation: &mercuryv2.Observation{},
 		RepTimestamp: types.ReportTimestamp{
 			ConfigDigest: types.ConfigDigest{2},
 			Epoch:        11,
@@ -759,7 +760,7 @@ func TestCollectMercuryEnhancedTelemetryV2(t *testing.T) {
 	trrsMercuryV2[0].Result.Value = ""
 	chTelem <- EnhancedTelemetryMercuryData{
 		TaskRunResults: trrsMercuryV2,
-		V2Observation:  &mercury_v2.Observation{},
+		V2Observation:  &mercuryv2.Observation{},
 		RepTimestamp: types.ReportTimestamp{
 			ConfigDigest: types.ConfigDigest{2},
 			Epoch:        11,
diff --git a/core/services/relay/evm/mercury/transmitter.go b/core/services/relay/evm/mercury/transmitter.go
index 269f28b122d..7af0ae2f6ef 100644
--- a/core/services/relay/evm/mercury/transmitter.go
+++ b/core/services/relay/evm/mercury/transmitter.go
@@ -17,11 +17,12 @@ import (
 	"github.com/prometheus/client_golang/prometheus/promauto"
 
 	"github.com/jmoiron/sqlx"
+
 	"github.com/smartcontractkit/libocr/offchainreporting2plus/chains/evmutil"
 	ocrtypes "github.com/smartcontractkit/libocr/offchainreporting2plus/types"
 
-	relaymercury "github.com/smartcontractkit/chainlink-relay/pkg/reportingplugins/mercury"
 	"github.com/smartcontractkit/chainlink-relay/pkg/services"
+	"github.com/smartcontractkit/chainlink-relay/pkg/types/mercury"
 
 	"github.com/smartcontractkit/chainlink/v2/core/logger"
 	"github.com/smartcontractkit/chainlink/v2/core/services/pg"
@@ -88,7 +89,7 @@ var (
 )
 
 type Transmitter interface {
-	relaymercury.Transmitter
+	mercury.Transmitter
 	services.Service
 }
 
diff --git a/core/services/relay/evm/mercury/v1/data_source.go b/core/services/relay/evm/mercury/v1/data_source.go
index 0bdfb67de78..eaff7b8358e 100644
--- a/core/services/relay/evm/mercury/v1/data_source.go
+++ b/core/services/relay/evm/mercury/v1/data_source.go
@@ -1,4 +1,4 @@
-package mercury_v1
+package v1
 
 import (
 	"context"
@@ -13,8 +13,9 @@ import (
 
 	ocrtypes "github.com/smartcontractkit/libocr/offchainreporting2plus/types"
 
-	relaymercury "github.com/smartcontractkit/chainlink-relay/pkg/reportingplugins/mercury"
-	relaymercuryv1 "github.com/smartcontractkit/chainlink-relay/pkg/reportingplugins/mercury/v1"
+	v1 "github.com/smartcontractkit/chainlink-llo/mercury/v1"
+	"github.com/smartcontractkit/chainlink-relay/pkg/types/mercury"
+	v1types "github.com/smartcontractkit/chainlink-relay/pkg/types/mercury/v1"
 
 	"github.com/smartcontractkit/chainlink/v2/core/logger"
 	"github.com/smartcontractkit/chainlink/v2/core/services/job"
@@ -41,7 +42,7 @@ var (
 	)
 )
 
-const nBlocksObservation int = relaymercuryv1.MaxAllowedBlocks
+const nBlocksObservation int = v1.MaxAllowedBlocks
 
 type Runner interface {
 	ExecuteRun(ctx context.Context, spec pipeline.Spec, vars pipeline.Vars, l logger.Logger) (run *pipeline.Run, trrs pipeline.TaskRunResults, err error)
@@ -66,7 +67,7 @@ type datasource struct {
 	mu sync.RWMutex
 
 	chEnhancedTelem    chan<- ocrcommon.EnhancedTelemetryMercuryData
-	chainReader        relaymercury.ChainReader
+	chainReader        mercury.ChainReader
 	fetcher            Fetcher
 	initialBlockNumber *int64
 
@@ -74,9 +75,9 @@ type datasource struct {
 	zeroBlocksCounter         prometheus.Counter
 }
 
-var _ relaymercuryv1.DataSource = &datasource{}
+var _ v1.DataSource = &datasource{}
 
-func NewDataSource(orm types.DataSourceORM, pr pipeline.Runner, jb job.Job, spec pipeline.Spec, lggr logger.Logger, rr chan *pipeline.Run, enhancedTelemChan chan ocrcommon.EnhancedTelemetryMercuryData, chainReader relaymercury.ChainReader, fetcher Fetcher, initialBlockNumber *int64, feedID mercuryutils.FeedID) *datasource {
+func NewDataSource(orm types.DataSourceORM, pr pipeline.Runner, jb job.Job, spec pipeline.Spec, lggr logger.Logger, rr chan *pipeline.Run, enhancedTelemChan chan ocrcommon.EnhancedTelemetryMercuryData, chainReader mercury.ChainReader, fetcher Fetcher, initialBlockNumber *int64, feedID mercuryutils.FeedID) *datasource {
 	return &datasource{pr, jb, spec, lggr, rr, orm, reportcodec.ReportCodec{}, feedID, sync.RWMutex{}, enhancedTelemChan, chainReader, fetcher, initialBlockNumber, insufficientBlocksCount.WithLabelValues(feedID.String()), zeroBlocksCount.WithLabelValues(feedID.String())}
 }
 
@@ -90,7 +91,7 @@ func (e ErrEmptyLatestReport) Error() string {
 	return fmt.Sprintf("FetchInitialMaxFinalizedBlockNumber returned empty LatestReport; this is a new feed. No initialBlockNumber was set, tried to use current block number to determine maxFinalizedBlockNumber but got error: %v", e.Err)
 }
 
-func (ds *datasource) Observe(ctx context.Context, repts ocrtypes.ReportTimestamp, fetchMaxFinalizedBlockNum bool) (obs relaymercuryv1.Observation, pipelineExecutionErr error) {
+func (ds *datasource) Observe(ctx context.Context, repts ocrtypes.ReportTimestamp, fetchMaxFinalizedBlockNum bool) (obs v1types.Observation, pipelineExecutionErr error) {
 	// setLatestBlocks must come chronologically before observations, along
 	// with observationTimestamp, to avoid front-running
 
@@ -207,9 +208,9 @@ func toBigInt(val interface{}) (*big.Int, error) {
 }
 
 type parseOutput struct {
-	benchmarkPrice relaymercury.ObsResult[*big.Int]
-	bid            relaymercury.ObsResult[*big.Int]
-	ask            relaymercury.ObsResult[*big.Int]
+	benchmarkPrice mercury.ObsResult[*big.Int]
+	bid            mercury.ObsResult[*big.Int]
+	ask            mercury.ObsResult[*big.Int]
 }
 
 // parse expects the output of observe to be three values, in the following order:
@@ -293,7 +294,7 @@ func (ds *datasource) executeRun(ctx context.Context) (*pipeline.Run, pipeline.T
 	return run, trrs, err
 }
 
-func (ds *datasource) setLatestBlocks(ctx context.Context, obs *relaymercuryv1.Observation) error {
+func (ds *datasource) setLatestBlocks(ctx context.Context, obs *v1types.Observation) error {
 	latestBlocks, err := ds.chainReader.LatestHeads(ctx, nBlocksObservation)
 	if err != nil {
 		ds.lggr.Errorw("failed to read latest blocks", "error", err)
@@ -321,7 +322,7 @@ func (ds *datasource) setLatestBlocks(ctx context.Context, obs *relaymercuryv1.O
 	for _, block := range latestBlocks {
 		obs.LatestBlocks = append(
 			obs.LatestBlocks,
-			relaymercuryv1.NewBlock(int64(block.Number), block.Hash, block.Timestamp))
+			v1types.NewBlock(int64(block.Number), block.Hash, block.Timestamp))
 	}
 
 	return nil
diff --git a/core/services/relay/evm/mercury/v1/data_source_test.go b/core/services/relay/evm/mercury/v1/data_source_test.go
index 40542c2631a..f81cb3be43e 100644
--- a/core/services/relay/evm/mercury/v1/data_source_test.go
+++ b/core/services/relay/evm/mercury/v1/data_source_test.go
@@ -1,4 +1,4 @@
-package mercury_v1
+package v1
 
 import (
 	"context"
@@ -15,8 +15,9 @@ import (
 
 	ocrtypes "github.com/smartcontractkit/libocr/offchainreporting2plus/types"
 
-	relaymercury "github.com/smartcontractkit/chainlink-relay/pkg/reportingplugins/mercury"
-	relaymercuryv1 "github.com/smartcontractkit/chainlink-relay/pkg/reportingplugins/mercury/v1"
+	"github.com/smartcontractkit/chainlink-relay/pkg/types/mercury"
+	v1 "github.com/smartcontractkit/chainlink-relay/pkg/types/mercury/v1"
+
 	commonmocks "github.com/smartcontractkit/chainlink/v2/common/mocks"
 	"github.com/smartcontractkit/chainlink/v2/core/assets"
 	evmtypes "github.com/smartcontractkit/chainlink/v2/core/chains/evm/types"
@@ -25,7 +26,6 @@ import (
 	"github.com/smartcontractkit/chainlink/v2/core/services/job"
 	"github.com/smartcontractkit/chainlink/v2/core/services/pg"
 	"github.com/smartcontractkit/chainlink/v2/core/services/pipeline"
-
 	"github.com/smartcontractkit/chainlink/v2/core/services/relay/evm"
 	mercurymocks "github.com/smartcontractkit/chainlink/v2/core/services/relay/evm/mercury/mocks"
 	mercuryutils "github.com/smartcontractkit/chainlink/v2/core/services/relay/evm/mercury/utils"
@@ -33,7 +33,7 @@ import (
 	"github.com/smartcontractkit/chainlink/v2/core/utils"
 )
 
-var _ relaymercury.MercuryServerFetcher = &mockFetcher{}
+var _ mercury.ServerFetcher = &mockFetcher{}
 
 type mockFetcher struct {
 	num *int64
@@ -63,10 +63,10 @@ func (m *mockORM) LatestReport(ctx context.Context, feedID [32]byte, qopts ...pg
 
 type mockChainReader struct {
 	err error
-	obs []relaymercury.Head
+	obs []mercury.Head
 }
 
-func (m *mockChainReader) LatestHeads(context.Context, int) ([]relaymercury.Head, error) {
+func (m *mockChainReader) LatestHeads(context.Context, int) ([]mercury.Head, error) {
 	return m.obs, m.err
 }
 
@@ -406,7 +406,7 @@ func TestMercury_Observe(t *testing.T) {
 
 			obs, err := ds.Observe(ctx, repts, true)
 			assert.Error(t, err)
-			assert.Equal(t, obs, relaymercuryv1.Observation{})
+			assert.Equal(t, obs, v1.Observation{})
 		})
 	})
 }
@@ -431,7 +431,7 @@ func TestMercury_SetLatestBlocks(t *testing.T) {
 		headTracker.On("LatestChain").Return(&h, nil)
 		ds.chainReader = evm.NewChainReader(headTracker)
 
-		obs := relaymercuryv1.Observation{}
+		obs := v1.Observation{}
 		err := ds.setLatestBlocks(context.Background(), &obs)
 
 		assert.NoError(t, err)
@@ -449,7 +449,7 @@ func TestMercury_SetLatestBlocks(t *testing.T) {
 		headTracker.On("LatestChain").Return((*evmtypes.Head)(nil))
 
 		ds.chainReader = evm.NewChainReader(headTracker)
-		obs := relaymercuryv1.Observation{}
+		obs := v1.Observation{}
 		err := ds.setLatestBlocks(context.Background(), &obs)
 
 		assert.NoError(t, err)
diff --git a/core/services/relay/evm/mercury/v1/reportcodec/report_codec.go b/core/services/relay/evm/mercury/v1/reportcodec/report_codec.go
index fefddd6395b..a1d470db4bb 100644
--- a/core/services/relay/evm/mercury/v1/reportcodec/report_codec.go
+++ b/core/services/relay/evm/mercury/v1/reportcodec/report_codec.go
@@ -8,10 +8,10 @@ import (
 
 	"github.com/ethereum/go-ethereum/common"
 	pkgerrors "github.com/pkg/errors"
-	ocrtypes "github.com/smartcontractkit/libocr/offchainreporting2plus/types"
 
-	reportcodec "github.com/smartcontractkit/chainlink-relay/pkg/reportingplugins/mercury/v1"
+	ocrtypes "github.com/smartcontractkit/libocr/offchainreporting2plus/types"
 
+	v1 "github.com/smartcontractkit/chainlink-relay/pkg/types/mercury/v1"
 	"github.com/smartcontractkit/chainlink/v2/core/logger"
 	"github.com/smartcontractkit/chainlink/v2/core/services/relay/evm/mercury/utils"
 	reporttypes "github.com/smartcontractkit/chainlink/v2/core/services/relay/evm/mercury/v1/types"
@@ -24,7 +24,7 @@ import (
 var ReportTypes = reporttypes.GetSchema()
 var maxReportLength = 32 * len(ReportTypes) // each arg is 256 bit EVM word
 
-var _ reportcodec.ReportCodec = &ReportCodec{}
+var _ v1.ReportCodec = &ReportCodec{}
 
 type ReportCodec struct {
 	logger logger.Logger
@@ -35,7 +35,7 @@ func NewReportCodec(feedID [32]byte, lggr logger.Logger) *ReportCodec {
 	return &ReportCodec{lggr, feedID}
 }
 
-func (r *ReportCodec) BuildReport(rf reportcodec.ReportFields) (ocrtypes.Report, error) {
+func (r *ReportCodec) BuildReport(rf v1.ReportFields) (ocrtypes.Report, error) {
 	var merr error
 	if rf.BenchmarkPrice == nil {
 		merr = errors.Join(merr, errors.New("benchmarkPrice may not be nil"))
diff --git a/core/services/relay/evm/mercury/v1/reportcodec/report_codec_test.go b/core/services/relay/evm/mercury/v1/reportcodec/report_codec_test.go
index 3f4838c3e7c..74736e86db3 100644
--- a/core/services/relay/evm/mercury/v1/reportcodec/report_codec_test.go
+++ b/core/services/relay/evm/mercury/v1/reportcodec/report_codec_test.go
@@ -11,15 +11,14 @@ import (
 
 	"github.com/smartcontractkit/libocr/offchainreporting2plus/types"
 
-	relaymercuryv1 "github.com/smartcontractkit/chainlink-relay/pkg/reportingplugins/mercury/v1"
-
+	v1 "github.com/smartcontractkit/chainlink-relay/pkg/types/mercury/v1"
 	"github.com/smartcontractkit/chainlink/v2/core/utils"
 )
 
 var hash = hexutil.MustDecode("0x552c2cea3ab43bae137d89ee6142a01db3ae2b5678bc3c9bd5f509f537bea57b")
 
-func newValidReportFields() relaymercuryv1.ReportFields {
-	return relaymercuryv1.ReportFields{
+func newValidReportFields() v1.ReportFields {
+	return v1.ReportFields{
 		Timestamp:             242,
 		BenchmarkPrice:        big.NewInt(243),
 		Bid:                   big.NewInt(244),
@@ -35,7 +34,7 @@ func Test_ReportCodec(t *testing.T) {
 	r := ReportCodec{}
 
 	t.Run("BuildReport errors on zero fields", func(t *testing.T) {
-		_, err := r.BuildReport(relaymercuryv1.ReportFields{})
+		_, err := r.BuildReport(v1.ReportFields{})
 		require.Error(t, err)
 		assert.Contains(t, err.Error(), "benchmarkPrice may not be nil")
 		assert.Contains(t, err.Error(), "bid may not be nil")
diff --git a/core/services/relay/evm/mercury/v2/data_source.go b/core/services/relay/evm/mercury/v2/data_source.go
index 17bc4a6670c..77aec008b71 100644
--- a/core/services/relay/evm/mercury/v2/data_source.go
+++ b/core/services/relay/evm/mercury/v2/data_source.go
@@ -1,4 +1,4 @@
-package mercury_v2
+package v2
 
 import (
 	"context"
@@ -10,8 +10,9 @@ import (
 
 	ocrtypes "github.com/smartcontractkit/libocr/offchainreporting2plus/types"
 
-	relaymercury "github.com/smartcontractkit/chainlink-relay/pkg/reportingplugins/mercury"
-	relaymercuryv2 "github.com/smartcontractkit/chainlink-relay/pkg/reportingplugins/mercury/v2"
+	v2 "github.com/smartcontractkit/chainlink-llo/mercury/v2"
+	"github.com/smartcontractkit/chainlink-relay/pkg/types/mercury"
+	v2types "github.com/smartcontractkit/chainlink-relay/pkg/types/mercury/v2"
 
 	"github.com/smartcontractkit/chainlink/v2/core/logger"
 	"github.com/smartcontractkit/chainlink/v2/core/services/job"
@@ -52,13 +53,13 @@ type datasource struct {
 	chEnhancedTelem chan<- ocrcommon.EnhancedTelemetryMercuryData
 }
 
-var _ relaymercuryv2.DataSource = &datasource{}
+var _ v2.DataSource = &datasource{}
 
 func NewDataSource(orm types.DataSourceORM, pr pipeline.Runner, jb job.Job, spec pipeline.Spec, feedID mercuryutils.FeedID, lggr logger.Logger, rr chan *pipeline.Run, enhancedTelemChan chan ocrcommon.EnhancedTelemetryMercuryData, fetcher LatestReportFetcher, linkFeedID, nativeFeedID mercuryutils.FeedID) *datasource {
 	return &datasource{pr, jb, spec, feedID, lggr, rr, orm, reportcodec.ReportCodec{}, fetcher, linkFeedID, nativeFeedID, sync.RWMutex{}, enhancedTelemChan}
 }
 
-func (ds *datasource) Observe(ctx context.Context, repts ocrtypes.ReportTimestamp, fetchMaxFinalizedTimestamp bool) (obs relaymercuryv2.Observation, pipelineExecutionErr error) {
+func (ds *datasource) Observe(ctx context.Context, repts ocrtypes.ReportTimestamp, fetchMaxFinalizedTimestamp bool) (obs v2types.Observation, pipelineExecutionErr error) {
 	var wg sync.WaitGroup
 	ctx, cancel := context.WithCancel(ctx)
 
@@ -119,8 +120,8 @@ func (ds *datasource) Observe(ctx context.Context, repts ocrtypes.ReportTimestam
 			obs.LinkPrice.Val, obs.LinkPrice.Err = ds.fetcher.LatestPrice(ctx, ds.linkFeedID)
 			if obs.LinkPrice.Val == nil && obs.LinkPrice.Err == nil {
 				mercurytypes.PriceFeedMissingCount.WithLabelValues(ds.linkFeedID.String()).Inc()
-				ds.lggr.Warnw(fmt.Sprintf("Mercury server was missing LINK feed, using sentinel value of %s", relaymercuryv2.MissingPrice), "linkFeedID", ds.linkFeedID)
-				obs.LinkPrice.Val = relaymercuryv2.MissingPrice
+				ds.lggr.Warnw(fmt.Sprintf("Mercury server was missing LINK feed, using sentinel value of %s", v2.MissingPrice), "linkFeedID", ds.linkFeedID)
+				obs.LinkPrice.Val = v2.MissingPrice
 			} else if obs.LinkPrice.Err != nil {
 				mercurytypes.PriceFeedErrorCount.WithLabelValues(ds.linkFeedID.String()).Inc()
 				ds.lggr.Errorw("Mercury server returned error querying LINK price feed", "err", obs.LinkPrice.Err, "linkFeedID", ds.linkFeedID)
@@ -137,8 +138,8 @@ func (ds *datasource) Observe(ctx context.Context, repts ocrtypes.ReportTimestam
 			obs.NativePrice.Val, obs.NativePrice.Err = ds.fetcher.LatestPrice(ctx, ds.nativeFeedID)
 			if obs.NativePrice.Val == nil && obs.NativePrice.Err == nil {
 				mercurytypes.PriceFeedMissingCount.WithLabelValues(ds.nativeFeedID.String()).Inc()
-				ds.lggr.Warnw(fmt.Sprintf("Mercury server was missing native feed, using sentinel value of %s", relaymercuryv2.MissingPrice), "nativeFeedID", ds.nativeFeedID)
-				obs.NativePrice.Val = relaymercuryv2.MissingPrice
+				ds.lggr.Warnw(fmt.Sprintf("Mercury server was missing native feed, using sentinel value of %s", v2.MissingPrice), "nativeFeedID", ds.nativeFeedID)
+				obs.NativePrice.Val = v2.MissingPrice
 			} else if obs.NativePrice.Err != nil {
 				mercurytypes.PriceFeedErrorCount.WithLabelValues(ds.nativeFeedID.String()).Inc()
 				ds.lggr.Errorw("Mercury server returned error querying native price feed", "err", obs.NativePrice.Err, "nativeFeedID", ds.nativeFeedID)
@@ -187,7 +188,7 @@ func toBigInt(val interface{}) (*big.Int, error) {
 }
 
 type parseOutput struct {
-	benchmarkPrice relaymercury.ObsResult[*big.Int]
+	benchmarkPrice mercury.ObsResult[*big.Int]
 }
 
 func (ds *datasource) parse(trrs pipeline.TaskRunResults) (o parseOutput, merr error) {
diff --git a/core/services/relay/evm/mercury/v2/data_source_test.go b/core/services/relay/evm/mercury/v2/data_source_test.go
index b66355ac7fb..f9139fdb55b 100644
--- a/core/services/relay/evm/mercury/v2/data_source_test.go
+++ b/core/services/relay/evm/mercury/v2/data_source_test.go
@@ -1,4 +1,4 @@
-package mercury_v2
+package v2
 
 import (
 	"context"
@@ -8,11 +8,11 @@ import (
 	"github.com/pkg/errors"
 	"github.com/stretchr/testify/assert"
 
-	relaymercury "github.com/smartcontractkit/chainlink-relay/pkg/reportingplugins/mercury"
-	relaymercuryv2 "github.com/smartcontractkit/chainlink-relay/pkg/reportingplugins/mercury/v2"
-
 	ocrtypes "github.com/smartcontractkit/libocr/offchainreporting2plus/types"
 
+	v2 "github.com/smartcontractkit/chainlink-llo/mercury/v2"
+	"github.com/smartcontractkit/chainlink-relay/pkg/types/mercury"
+
 	"github.com/smartcontractkit/chainlink/v2/core/internal/testutils"
 	"github.com/smartcontractkit/chainlink/v2/core/logger"
 	"github.com/smartcontractkit/chainlink/v2/core/services/pg"
@@ -22,7 +22,7 @@ import (
 	reportcodecv2 "github.com/smartcontractkit/chainlink/v2/core/services/relay/evm/mercury/v2/reportcodec"
 )
 
-var _ relaymercury.MercuryServerFetcher = &mockFetcher{}
+var _ mercury.ServerFetcher = &mockFetcher{}
 
 type mockFetcher struct {
 	ts             int64
@@ -268,9 +268,9 @@ func Test_Datasource(t *testing.T) {
 				obs, err := ds.Observe(ctx, repts, false)
 				assert.NoError(t, err)
 
-				assert.Equal(t, obs.LinkPrice.Val, relaymercuryv2.MissingPrice)
+				assert.Equal(t, obs.LinkPrice.Val, v2.MissingPrice)
 				assert.Nil(t, obs.LinkPrice.Err)
-				assert.Equal(t, obs.NativePrice.Val, relaymercuryv2.MissingPrice)
+				assert.Equal(t, obs.NativePrice.Val, v2.MissingPrice)
 				assert.Nil(t, obs.NativePrice.Err)
 			})
 		})
diff --git a/core/services/relay/evm/mercury/v2/reportcodec/report_codec.go b/core/services/relay/evm/mercury/v2/reportcodec/report_codec.go
index 0e1dfe9c46f..bcd3f1bb640 100644
--- a/core/services/relay/evm/mercury/v2/reportcodec/report_codec.go
+++ b/core/services/relay/evm/mercury/v2/reportcodec/report_codec.go
@@ -6,9 +6,10 @@ import (
 	"math/big"
 
 	pkgerrors "github.com/pkg/errors"
+
 	ocrtypes "github.com/smartcontractkit/libocr/offchainreporting2plus/types"
 
-	reportcodec "github.com/smartcontractkit/chainlink-relay/pkg/reportingplugins/mercury/v2"
+	v2 "github.com/smartcontractkit/chainlink-relay/pkg/types/mercury/v2"
 
 	"github.com/smartcontractkit/chainlink/v2/core/logger"
 	"github.com/smartcontractkit/chainlink/v2/core/services/relay/evm/mercury/utils"
@@ -19,7 +20,7 @@ var ReportTypes = reporttypes.GetSchema()
 var maxReportLength = 32 * len(ReportTypes) // each arg is 256 bit EVM word
 var zero = big.NewInt(0)
 
-var _ reportcodec.ReportCodec = &ReportCodec{}
+var _ v2.ReportCodec = &ReportCodec{}
 
 type ReportCodec struct {
 	logger logger.Logger
@@ -30,7 +31,7 @@ func NewReportCodec(feedID [32]byte, lggr logger.Logger) *ReportCodec {
 	return &ReportCodec{lggr, feedID}
 }
 
-func (r *ReportCodec) BuildReport(rf reportcodec.ReportFields) (ocrtypes.Report, error) {
+func (r *ReportCodec) BuildReport(rf v2.ReportFields) (ocrtypes.Report, error) {
 	var merr error
 	if rf.BenchmarkPrice == nil {
 		merr = errors.Join(merr, errors.New("benchmarkPrice may not be nil"))
diff --git a/core/services/relay/evm/mercury/v2/reportcodec/report_codec_test.go b/core/services/relay/evm/mercury/v2/reportcodec/report_codec_test.go
index 8cf16a5dab4..0a4f88b9a1e 100644
--- a/core/services/relay/evm/mercury/v2/reportcodec/report_codec_test.go
+++ b/core/services/relay/evm/mercury/v2/reportcodec/report_codec_test.go
@@ -9,11 +9,11 @@ import (
 
 	"github.com/smartcontractkit/libocr/offchainreporting2plus/types"
 
-	relaymercuryv2 "github.com/smartcontractkit/chainlink-relay/pkg/reportingplugins/mercury/v2"
+	v2 "github.com/smartcontractkit/chainlink-relay/pkg/types/mercury/v2"
 )
 
-func newValidReportFields() relaymercuryv2.ReportFields {
-	return relaymercuryv2.ReportFields{
+func newValidReportFields() v2.ReportFields {
+	return v2.ReportFields{
 		Timestamp:          242,
 		BenchmarkPrice:     big.NewInt(243),
 		ValidFromTimestamp: 123,
@@ -27,7 +27,7 @@ func Test_ReportCodec_BuildReport(t *testing.T) {
 	r := ReportCodec{}
 
 	t.Run("BuildReport errors on zero values", func(t *testing.T) {
-		_, err := r.BuildReport(relaymercuryv2.ReportFields{})
+		_, err := r.BuildReport(v2.ReportFields{})
 		require.Error(t, err)
 		assert.Contains(t, err.Error(), "benchmarkPrice may not be nil")
 		assert.Contains(t, err.Error(), "linkFee may not be nil")
diff --git a/core/services/relay/evm/mercury/v3/data_source.go b/core/services/relay/evm/mercury/v3/data_source.go
index 6f2b2eb6bde..86bae53aa3f 100644
--- a/core/services/relay/evm/mercury/v3/data_source.go
+++ b/core/services/relay/evm/mercury/v3/data_source.go
@@ -1,4 +1,4 @@
-package mercury_v3
+package v3
 
 import (
 	"context"
@@ -11,8 +11,9 @@ import (
 
 	ocrtypes "github.com/smartcontractkit/libocr/offchainreporting2plus/types"
 
-	relaymercury "github.com/smartcontractkit/chainlink-relay/pkg/reportingplugins/mercury"
-	relaymercuryv3 "github.com/smartcontractkit/chainlink-relay/pkg/reportingplugins/mercury/v3"
+	v3 "github.com/smartcontractkit/chainlink-llo/mercury/v3"
+	"github.com/smartcontractkit/chainlink-relay/pkg/types/mercury"
+	v3types "github.com/smartcontractkit/chainlink-relay/pkg/types/mercury/v3"
 
 	"github.com/smartcontractkit/chainlink/v2/core/logger"
 	"github.com/smartcontractkit/chainlink/v2/core/services/job"
@@ -53,13 +54,13 @@ type datasource struct {
 	chEnhancedTelem chan<- ocrcommon.EnhancedTelemetryMercuryData
 }
 
-var _ relaymercuryv3.DataSource = &datasource{}
+var _ v3.DataSource = &datasource{}
 
 func NewDataSource(orm types.DataSourceORM, pr pipeline.Runner, jb job.Job, spec pipeline.Spec, feedID mercuryutils.FeedID, lggr logger.Logger, rr chan *pipeline.Run, enhancedTelemChan chan ocrcommon.EnhancedTelemetryMercuryData, fetcher LatestReportFetcher, linkFeedID, nativeFeedID mercuryutils.FeedID) *datasource {
 	return &datasource{pr, jb, spec, feedID, lggr, rr, orm, reportcodec.ReportCodec{}, fetcher, linkFeedID, nativeFeedID, sync.RWMutex{}, enhancedTelemChan}
 }
 
-func (ds *datasource) Observe(ctx context.Context, repts ocrtypes.ReportTimestamp, fetchMaxFinalizedTimestamp bool) (obs relaymercuryv3.Observation, pipelineExecutionErr error) {
+func (ds *datasource) Observe(ctx context.Context, repts ocrtypes.ReportTimestamp, fetchMaxFinalizedTimestamp bool) (obs v3types.Observation, pipelineExecutionErr error) {
 	var wg sync.WaitGroup
 	ctx, cancel := context.WithCancel(ctx)
 
@@ -122,8 +123,8 @@ func (ds *datasource) Observe(ctx context.Context, repts ocrtypes.ReportTimestam
 			obs.LinkPrice.Val, obs.LinkPrice.Err = ds.fetcher.LatestPrice(ctx, ds.linkFeedID)
 			if obs.LinkPrice.Val == nil && obs.LinkPrice.Err == nil {
 				mercurytypes.PriceFeedMissingCount.WithLabelValues(ds.linkFeedID.String()).Inc()
-				ds.lggr.Warnw(fmt.Sprintf("Mercury server was missing LINK feed, using sentinel value of %s", relaymercuryv3.MissingPrice), "linkFeedID", ds.linkFeedID)
-				obs.LinkPrice.Val = relaymercuryv3.MissingPrice
+				ds.lggr.Warnw(fmt.Sprintf("Mercury server was missing LINK feed, using sentinel value of %s", v3.MissingPrice), "linkFeedID", ds.linkFeedID)
+				obs.LinkPrice.Val = v3.MissingPrice
 			} else if obs.LinkPrice.Err != nil {
 				mercurytypes.PriceFeedErrorCount.WithLabelValues(ds.linkFeedID.String()).Inc()
 				ds.lggr.Errorw("Mercury server returned error querying LINK price feed", "err", obs.LinkPrice.Err, "linkFeedID", ds.linkFeedID)
@@ -140,8 +141,8 @@ func (ds *datasource) Observe(ctx context.Context, repts ocrtypes.ReportTimestam
 			obs.NativePrice.Val, obs.NativePrice.Err = ds.fetcher.LatestPrice(ctx, ds.nativeFeedID)
 			if obs.NativePrice.Val == nil && obs.NativePrice.Err == nil {
 				mercurytypes.PriceFeedMissingCount.WithLabelValues(ds.nativeFeedID.String()).Inc()
-				ds.lggr.Warnw(fmt.Sprintf("Mercury server was missing native feed, using sentinel value of %s", relaymercuryv3.MissingPrice), "nativeFeedID", ds.nativeFeedID)
-				obs.NativePrice.Val = relaymercuryv3.MissingPrice
+				ds.lggr.Warnw(fmt.Sprintf("Mercury server was missing native feed, using sentinel value of %s", v3.MissingPrice), "nativeFeedID", ds.nativeFeedID)
+				obs.NativePrice.Val = v3.MissingPrice
 			} else if obs.NativePrice.Err != nil {
 				mercurytypes.PriceFeedErrorCount.WithLabelValues(ds.nativeFeedID.String()).Inc()
 				ds.lggr.Errorw("Mercury server returned error querying native price feed", "err", obs.NativePrice.Err, "nativeFeedID", ds.nativeFeedID)
@@ -190,9 +191,9 @@ func toBigInt(val interface{}) (*big.Int, error) {
 }
 
 type parseOutput struct {
-	benchmarkPrice relaymercury.ObsResult[*big.Int]
-	bid            relaymercury.ObsResult[*big.Int]
-	ask            relaymercury.ObsResult[*big.Int]
+	benchmarkPrice mercury.ObsResult[*big.Int]
+	bid            mercury.ObsResult[*big.Int]
+	ask            mercury.ObsResult[*big.Int]
 }
 
 func (ds *datasource) parse(trrs pipeline.TaskRunResults) (o parseOutput, merr error) {
diff --git a/core/services/relay/evm/mercury/v3/data_source_test.go b/core/services/relay/evm/mercury/v3/data_source_test.go
index aefc766996e..82d8e5c605d 100644
--- a/core/services/relay/evm/mercury/v3/data_source_test.go
+++ b/core/services/relay/evm/mercury/v3/data_source_test.go
@@ -1,4 +1,4 @@
-package mercury_v3
+package v3
 
 import (
 	"context"
@@ -8,8 +8,8 @@ import (
 	"github.com/pkg/errors"
 	"github.com/stretchr/testify/assert"
 
-	relaymercury "github.com/smartcontractkit/chainlink-relay/pkg/reportingplugins/mercury"
-	relaymercuryv3 "github.com/smartcontractkit/chainlink-relay/pkg/reportingplugins/mercury/v3"
+	relaymercuryv3 "github.com/smartcontractkit/chainlink-llo/mercury/v3"
+	mercurytypes "github.com/smartcontractkit/chainlink-relay/pkg/types/mercury"
 
 	ocrtypes "github.com/smartcontractkit/libocr/offchainreporting2plus/types"
 
@@ -22,7 +22,7 @@ import (
 	reportcodecv3 "github.com/smartcontractkit/chainlink/v2/core/services/relay/evm/mercury/v3/reportcodec"
 )
 
-var _ relaymercury.MercuryServerFetcher = &mockFetcher{}
+var _ mercurytypes.ServerFetcher = &mockFetcher{}
 
 type mockFetcher struct {
 	ts             int64
diff --git a/core/services/relay/evm/mercury/v3/reportcodec/report_codec.go b/core/services/relay/evm/mercury/v3/reportcodec/report_codec.go
index 4c0b3756d7b..5998a328b53 100644
--- a/core/services/relay/evm/mercury/v3/reportcodec/report_codec.go
+++ b/core/services/relay/evm/mercury/v3/reportcodec/report_codec.go
@@ -3,13 +3,13 @@ package reportcodec
 import (
 	"errors"
 	"fmt"
-
 	"math/big"
 
 	pkgerrors "github.com/pkg/errors"
+
 	ocrtypes "github.com/smartcontractkit/libocr/offchainreporting2plus/types"
 
-	reportcodec "github.com/smartcontractkit/chainlink-relay/pkg/reportingplugins/mercury/v3"
+	v3 "github.com/smartcontractkit/chainlink-relay/pkg/types/mercury/v3"
 
 	"github.com/smartcontractkit/chainlink/v2/core/logger"
 	"github.com/smartcontractkit/chainlink/v2/core/services/relay/evm/mercury/utils"
@@ -20,7 +20,7 @@ var ReportTypes = reporttypes.GetSchema()
 var maxReportLength = 32 * len(ReportTypes) // each arg is 256 bit EVM word
 var zero = big.NewInt(0)
 
-var _ reportcodec.ReportCodec = &ReportCodec{}
+var _ v3.ReportCodec = &ReportCodec{}
 
 type ReportCodec struct {
 	logger logger.Logger
@@ -31,7 +31,7 @@ func NewReportCodec(feedID [32]byte, lggr logger.Logger) *ReportCodec {
 	return &ReportCodec{lggr, feedID}
 }
 
-func (r *ReportCodec) BuildReport(rf reportcodec.ReportFields) (ocrtypes.Report, error) {
+func (r *ReportCodec) BuildReport(rf v3.ReportFields) (ocrtypes.Report, error) {
 	var merr error
 	if rf.BenchmarkPrice == nil {
 		merr = errors.Join(merr, errors.New("benchmarkPrice may not be nil"))
diff --git a/core/services/relay/evm/mercury/v3/reportcodec/report_codec_test.go b/core/services/relay/evm/mercury/v3/reportcodec/report_codec_test.go
index 98b81edb002..a021bfb8955 100644
--- a/core/services/relay/evm/mercury/v3/reportcodec/report_codec_test.go
+++ b/core/services/relay/evm/mercury/v3/reportcodec/report_codec_test.go
@@ -9,11 +9,11 @@ import (
 
 	"github.com/smartcontractkit/libocr/offchainreporting2plus/types"
 
-	relaymercuryv3 "github.com/smartcontractkit/chainlink-relay/pkg/reportingplugins/mercury/v3"
+	v3 "github.com/smartcontractkit/chainlink-relay/pkg/types/mercury/v3"
 )
 
-func newValidReportFields() relaymercuryv3.ReportFields {
-	return relaymercuryv3.ReportFields{
+func newValidReportFields() v3.ReportFields {
+	return v3.ReportFields{
 		Timestamp:          242,
 		BenchmarkPrice:     big.NewInt(243),
 		Bid:                big.NewInt(244),
@@ -29,7 +29,7 @@ func Test_ReportCodec_BuildReport(t *testing.T) {
 	r := ReportCodec{}
 
 	t.Run("BuildReport errors on zero values", func(t *testing.T) {
-		_, err := r.BuildReport(relaymercuryv3.ReportFields{})
+		_, err := r.BuildReport(v3.ReportFields{})
 		require.Error(t, err)
 		assert.Contains(t, err.Error(), "benchmarkPrice may not be nil")
 		assert.Contains(t, err.Error(), "linkFee may not be nil")
diff --git a/core/services/relay/evm/mercury_provider.go b/core/services/relay/evm/mercury_provider.go
index bba5e699bc6..19ce4548ff5 100644
--- a/core/services/relay/evm/mercury_provider.go
+++ b/core/services/relay/evm/mercury_provider.go
@@ -6,27 +6,28 @@ import (
 
 	ocrtypes "github.com/smartcontractkit/libocr/offchainreporting2plus/types"
 
-	relaymercury "github.com/smartcontractkit/chainlink-relay/pkg/reportingplugins/mercury"
-	relaymercuryv1 "github.com/smartcontractkit/chainlink-relay/pkg/reportingplugins/mercury/v1"
-	relaymercuryv2 "github.com/smartcontractkit/chainlink-relay/pkg/reportingplugins/mercury/v2"
-	relaymercuryv3 "github.com/smartcontractkit/chainlink-relay/pkg/reportingplugins/mercury/v3"
+	relaymercury "github.com/smartcontractkit/chainlink-llo/mercury"
 	"github.com/smartcontractkit/chainlink-relay/pkg/services"
-	relaytypes "github.com/smartcontractkit/chainlink-relay/pkg/types"
-	httypes "github.com/smartcontractkit/chainlink/v2/core/chains/evm/headtracker/types"
+	"github.com/smartcontractkit/chainlink-relay/pkg/types"
+	mercurytypes "github.com/smartcontractkit/chainlink-relay/pkg/types/mercury"
+	v1 "github.com/smartcontractkit/chainlink-relay/pkg/types/mercury/v1"
+	v2 "github.com/smartcontractkit/chainlink-relay/pkg/types/mercury/v2"
+	v3 "github.com/smartcontractkit/chainlink-relay/pkg/types/mercury/v3"
 
+	httypes "github.com/smartcontractkit/chainlink/v2/core/chains/evm/headtracker/types"
 	"github.com/smartcontractkit/chainlink/v2/core/logger"
 	"github.com/smartcontractkit/chainlink/v2/core/services/relay/evm/mercury"
 )
 
-var _ relaytypes.MercuryProvider = (*mercuryProvider)(nil)
+var _ types.MercuryProvider = (*mercuryProvider)(nil)
 
 type mercuryProvider struct {
 	configWatcher *configWatcher
 	transmitter   mercury.Transmitter
-	reportCodecV1 relaymercuryv1.ReportCodec
-	reportCodecV2 relaymercuryv2.ReportCodec
-	reportCodecV3 relaymercuryv3.ReportCodec
-	chainReader   relaymercury.ChainReader
+	reportCodecV1 v1.ReportCodec
+	reportCodecV2 v2.ReportCodec
+	reportCodecV3 v3.ReportCodec
+	chainReader   mercurytypes.ChainReader
 	logger        logger.Logger
 
 	ms services.MultiStart
@@ -35,10 +36,10 @@ type mercuryProvider struct {
 func NewMercuryProvider(
 	configWatcher *configWatcher,
 	transmitter mercury.Transmitter,
-	reportCodecV1 relaymercuryv1.ReportCodec,
-	reportCodecV2 relaymercuryv2.ReportCodec,
-	reportCodecV3 relaymercuryv3.ReportCodec,
-	chainReader relaymercury.ChainReader,
+	reportCodecV1 v1.ReportCodec,
+	reportCodecV2 v2.ReportCodec,
+	reportCodecV3 v3.ReportCodec,
+	chainReader mercurytypes.ChainReader,
 	lggr logger.Logger,
 ) *mercuryProvider {
 	return &mercuryProvider{
@@ -84,19 +85,19 @@ func (p *mercuryProvider) OffchainConfigDigester() ocrtypes.OffchainConfigDigest
 	return p.configWatcher.OffchainConfigDigester()
 }
 
-func (p *mercuryProvider) OnchainConfigCodec() relaymercury.OnchainConfigCodec {
+func (p *mercuryProvider) OnchainConfigCodec() mercurytypes.OnchainConfigCodec {
 	return relaymercury.StandardOnchainConfigCodec{}
 }
 
-func (p *mercuryProvider) ReportCodecV1() relaymercuryv1.ReportCodec {
+func (p *mercuryProvider) ReportCodecV1() v1.ReportCodec {
 	return p.reportCodecV1
 }
 
-func (p *mercuryProvider) ReportCodecV2() relaymercuryv2.ReportCodec {
+func (p *mercuryProvider) ReportCodecV2() v2.ReportCodec {
 	return p.reportCodecV2
 }
 
-func (p *mercuryProvider) ReportCodecV3() relaymercuryv3.ReportCodec {
+func (p *mercuryProvider) ReportCodecV3() v3.ReportCodec {
 	return p.reportCodecV3
 }
 
@@ -104,35 +105,35 @@ func (p *mercuryProvider) ContractTransmitter() ocrtypes.ContractTransmitter {
 	return p.transmitter
 }
 
-func (p *mercuryProvider) MercuryServerFetcher() relaymercury.MercuryServerFetcher {
+func (p *mercuryProvider) MercuryServerFetcher() mercurytypes.ServerFetcher {
 	return p.transmitter
 }
 
-func (p *mercuryProvider) ChainReader() relaymercury.ChainReader {
+func (p *mercuryProvider) ChainReader() mercurytypes.ChainReader {
 	return p.chainReader
 }
 
-var _ relaymercury.ChainReader = (*chainReader)(nil)
+var _ mercurytypes.ChainReader = (*chainReader)(nil)
 
 type chainReader struct {
 	tracker httypes.HeadTracker
 }
 
-func NewChainReader(h httypes.HeadTracker) relaymercury.ChainReader {
+func NewChainReader(h httypes.HeadTracker) mercurytypes.ChainReader {
 	return &chainReader{
 		tracker: h,
 	}
 }
 
-func (r *chainReader) LatestHeads(ctx context.Context, k int) ([]relaymercury.Head, error) {
+func (r *chainReader) LatestHeads(ctx context.Context, k int) ([]mercurytypes.Head, error) {
 	evmBlocks := r.tracker.LatestChain().AsSlice(k)
 	if len(evmBlocks) == 0 {
 		return nil, nil
 	}
 
-	blocks := make([]relaymercury.Head, len(evmBlocks))
+	blocks := make([]mercurytypes.Head, len(evmBlocks))
 	for x := 0; x < len(evmBlocks); x++ {
-		blocks[x] = relaymercury.Head{
+		blocks[x] = mercurytypes.Head{
 			Number:    uint64(evmBlocks[x].BlockNumber()),
 			Hash:      evmBlocks[x].Hash.Bytes(),
 			Timestamp: uint64(evmBlocks[x].Timestamp.Unix()),
diff --git a/core/web/solana_chains_controller_test.go b/core/web/solana_chains_controller_test.go
index 724d5cd2c3d..36080b717f6 100644
--- a/core/web/solana_chains_controller_test.go
+++ b/core/web/solana_chains_controller_test.go
@@ -11,8 +11,8 @@ import (
 	"github.com/stretchr/testify/assert"
 	"github.com/stretchr/testify/require"
 
+	relayconfig "github.com/smartcontractkit/chainlink-relay/pkg/config"
 	"github.com/smartcontractkit/chainlink-relay/pkg/types"
-	"github.com/smartcontractkit/chainlink-relay/pkg/utils"
 	"github.com/smartcontractkit/chainlink-solana/pkg/solana/config"
 
 	"github.com/smartcontractkit/chainlink-solana/pkg/solana"
@@ -84,7 +84,7 @@ Nodes = []
 				ChainID: ptr(validId),
 				Chain: config.Chain{
 					SkipPreflight: ptr(false),
-					TxTimeout:     utils.MustNewDuration(time.Hour),
+					TxTimeout:     relayconfig.MustNewDuration(time.Hour),
 				},
 			})
 
@@ -114,7 +114,7 @@ func Test_SolanaChainsController_Index(t *testing.T) {
 	chainA := &solana.TOMLConfig{
 		ChainID: ptr(fmt.Sprintf("ChainlinktestA-%d", rand.Int31n(999999))),
 		Chain: config.Chain{
-			TxTimeout: utils.MustNewDuration(time.Hour),
+			TxTimeout: relayconfig.MustNewDuration(time.Hour),
 		},
 	}
 	chainB := &solana.TOMLConfig{
diff --git a/go.mod b/go.mod
index 0a85fe7f488..0989debc585 100644
--- a/go.mod
+++ b/go.mod
@@ -1,6 +1,6 @@
 module github.com/smartcontractkit/chainlink/v2
 
-go 1.21
+go 1.21.3
 
 require (
 	github.com/Depado/ginprom v1.7.11
@@ -66,7 +66,8 @@ require (
 	github.com/shopspring/decimal v1.3.1
 	github.com/smartcontractkit/caigo v0.0.0-20230621050857-b29a4ca8c704
 	github.com/smartcontractkit/chainlink-cosmos v0.4.1-0.20231109141932-cb1ea9020255
-	github.com/smartcontractkit/chainlink-relay v0.1.7-0.20231113174149-046d4ddaca1a
+	github.com/smartcontractkit/chainlink-llo v0.0.0-20231115154526-abefc17cc332
+	github.com/smartcontractkit/chainlink-relay v0.1.7-0.20231115153227-c2e71a404d2f
 	github.com/smartcontractkit/chainlink-solana v1.0.3-0.20231023133638-72f4e799ab05
 	github.com/smartcontractkit/chainlink-starknet/relayer v0.0.1-beta-test.0.20231024133459-1ef3a11319eb
 	github.com/smartcontractkit/libocr v0.0.0-20231107151413-13e0202ae8d7
diff --git a/go.sum b/go.sum
index 7fe91a6b123..4aae8197b77 100644
--- a/go.sum
+++ b/go.sum
@@ -1465,8 +1465,10 @@ github.com/smartcontractkit/caigo v0.0.0-20230621050857-b29a4ca8c704 h1:T3lFWumv
 github.com/smartcontractkit/caigo v0.0.0-20230621050857-b29a4ca8c704/go.mod h1:2QuJdEouTWjh5BDy5o/vgGXQtR4Gz8yH1IYB5eT7u4M=
 github.com/smartcontractkit/chainlink-cosmos v0.4.1-0.20231109141932-cb1ea9020255 h1:Pt6c7bJU9wIN6PQQnmN8UmYYH6lpfiQ6U/B8yEC2s5s=
 github.com/smartcontractkit/chainlink-cosmos v0.4.1-0.20231109141932-cb1ea9020255/go.mod h1:EHppaccd/LTlTMI2o4dmBHe4BknEgEFFDjDGMNuGb3k=
-github.com/smartcontractkit/chainlink-relay v0.1.7-0.20231113174149-046d4ddaca1a h1:G/pD8uI1PULRJU8Y3eLLzjqQBp9ruG9hj+wWxtyrgTo=
-github.com/smartcontractkit/chainlink-relay v0.1.7-0.20231113174149-046d4ddaca1a/go.mod h1:M9U1JV7IQi8Sfj4JR1qSi1tIh6omgW78W/8SHN/8BUQ=
+github.com/smartcontractkit/chainlink-llo v0.0.0-20231115154526-abefc17cc332 h1:md6WwVyfC5jTR6jXZrs1X0TmxOA8jWTeK+3ZAIw2ch0=
+github.com/smartcontractkit/chainlink-llo v0.0.0-20231115154526-abefc17cc332/go.mod h1:iyWCEOiRl87OCJbAecsVTqE8Qv47aHWLX8KbCKay7XQ=
+github.com/smartcontractkit/chainlink-relay v0.1.7-0.20231115153227-c2e71a404d2f h1:6MsxL2XyzR5BKI8sQv7X2ruNS0l0Jf8OGv7SVSx3WJI=
+github.com/smartcontractkit/chainlink-relay v0.1.7-0.20231115153227-c2e71a404d2f/go.mod h1:rOayi690YxLlkQy959PD8INhOAIAUi9LoN0G+J/CEf4=
 github.com/smartcontractkit/chainlink-solana v1.0.3-0.20231023133638-72f4e799ab05 h1:DaPSVnxe7oz1QJ+AVIhQWs1W3ubQvwvGo9NbHpMs1OQ=
 github.com/smartcontractkit/chainlink-solana v1.0.3-0.20231023133638-72f4e799ab05/go.mod h1:o0Pn1pbaUluboaK6/yhf8xf7TiFCkyFl6WUOdwqamuU=
 github.com/smartcontractkit/chainlink-starknet/relayer v0.0.1-beta-test.0.20231024133459-1ef3a11319eb h1:HiluOfEVGOQTM6BTDImOqYdMZZ7qq7fkZ3TJdmItNr8=
diff --git a/integration-tests/go.mod b/integration-tests/go.mod
index a943e1c41a9..5926d54a6d4 100644
--- a/integration-tests/go.mod
+++ b/integration-tests/go.mod
@@ -1,6 +1,6 @@
 module github.com/smartcontractkit/chainlink/integration-tests
 
-go 1.21
+go 1.21.3
 
 // Make sure we're working with the latest chainlink libs
 replace github.com/smartcontractkit/chainlink/v2 => ../
@@ -387,7 +387,8 @@ require (
 	github.com/sirupsen/logrus v1.9.3 // indirect
 	github.com/smartcontractkit/caigo v0.0.0-20230621050857-b29a4ca8c704 // indirect
 	github.com/smartcontractkit/chainlink-cosmos v0.4.1-0.20231109141932-cb1ea9020255 // indirect
-	github.com/smartcontractkit/chainlink-relay v0.1.7-0.20231113174149-046d4ddaca1a // indirect
+	github.com/smartcontractkit/chainlink-llo v0.0.0-20231115154526-abefc17cc332 // indirect
+	github.com/smartcontractkit/chainlink-relay v0.1.7-0.20231115153227-c2e71a404d2f // indirect
 	github.com/smartcontractkit/chainlink-solana v1.0.3-0.20231023133638-72f4e799ab05 // indirect
 	github.com/smartcontractkit/chainlink-starknet/relayer v0.0.1-beta-test.0.20231024133459-1ef3a11319eb // indirect
 	github.com/smartcontractkit/tdh2/go/ocr2/decryptionplugin v0.0.0-20230906073235-9e478e5e19f1 // indirect
diff --git a/integration-tests/go.sum b/integration-tests/go.sum
index 5719c36b5a8..7577e71d8ba 100644
--- a/integration-tests/go.sum
+++ b/integration-tests/go.sum
@@ -2369,8 +2369,10 @@ github.com/smartcontractkit/caigo v0.0.0-20230621050857-b29a4ca8c704 h1:T3lFWumv
 github.com/smartcontractkit/caigo v0.0.0-20230621050857-b29a4ca8c704/go.mod h1:2QuJdEouTWjh5BDy5o/vgGXQtR4Gz8yH1IYB5eT7u4M=
 github.com/smartcontractkit/chainlink-cosmos v0.4.1-0.20231109141932-cb1ea9020255 h1:Pt6c7bJU9wIN6PQQnmN8UmYYH6lpfiQ6U/B8yEC2s5s=
 github.com/smartcontractkit/chainlink-cosmos v0.4.1-0.20231109141932-cb1ea9020255/go.mod h1:EHppaccd/LTlTMI2o4dmBHe4BknEgEFFDjDGMNuGb3k=
-github.com/smartcontractkit/chainlink-relay v0.1.7-0.20231113174149-046d4ddaca1a h1:G/pD8uI1PULRJU8Y3eLLzjqQBp9ruG9hj+wWxtyrgTo=
-github.com/smartcontractkit/chainlink-relay v0.1.7-0.20231113174149-046d4ddaca1a/go.mod h1:M9U1JV7IQi8Sfj4JR1qSi1tIh6omgW78W/8SHN/8BUQ=
+github.com/smartcontractkit/chainlink-llo v0.0.0-20231115154526-abefc17cc332 h1:md6WwVyfC5jTR6jXZrs1X0TmxOA8jWTeK+3ZAIw2ch0=
+github.com/smartcontractkit/chainlink-llo v0.0.0-20231115154526-abefc17cc332/go.mod h1:iyWCEOiRl87OCJbAecsVTqE8Qv47aHWLX8KbCKay7XQ=
+github.com/smartcontractkit/chainlink-relay v0.1.7-0.20231115153227-c2e71a404d2f h1:6MsxL2XyzR5BKI8sQv7X2ruNS0l0Jf8OGv7SVSx3WJI=
+github.com/smartcontractkit/chainlink-relay v0.1.7-0.20231115153227-c2e71a404d2f/go.mod h1:rOayi690YxLlkQy959PD8INhOAIAUi9LoN0G+J/CEf4=
 github.com/smartcontractkit/chainlink-solana v1.0.3-0.20231023133638-72f4e799ab05 h1:DaPSVnxe7oz1QJ+AVIhQWs1W3ubQvwvGo9NbHpMs1OQ=
 github.com/smartcontractkit/chainlink-solana v1.0.3-0.20231023133638-72f4e799ab05/go.mod h1:o0Pn1pbaUluboaK6/yhf8xf7TiFCkyFl6WUOdwqamuU=
 github.com/smartcontractkit/chainlink-starknet/relayer v0.0.1-beta-test.0.20231024133459-1ef3a11319eb h1:HiluOfEVGOQTM6BTDImOqYdMZZ7qq7fkZ3TJdmItNr8=