diff --git a/api/clients/accountant.go b/api/clients/v2/accountant.go
similarity index 99%
rename from api/clients/accountant.go
rename to api/clients/v2/accountant.go
index 045877bd7e..65b981004c 100644
--- a/api/clients/accountant.go
+++ b/api/clients/v2/accountant.go
@@ -1,4 +1,4 @@
-package clients
+package v2
 
 import (
 	"context"
diff --git a/api/clients/accountant_test.go b/api/clients/v2/accountant_test.go
similarity index 99%
rename from api/clients/accountant_test.go
rename to api/clients/v2/accountant_test.go
index c6dc3fa692..41a388e572 100644
--- a/api/clients/accountant_test.go
+++ b/api/clients/v2/accountant_test.go
@@ -1,4 +1,4 @@
-package clients
+package v2
 
 import (
 	"context"
diff --git a/api/clients/disperser_client_v2.go b/api/clients/v2/disperser_client.go
similarity index 87%
rename from api/clients/disperser_client_v2.go
rename to api/clients/v2/disperser_client.go
index 5deaecf86a..5380820e7c 100644
--- a/api/clients/disperser_client_v2.go
+++ b/api/clients/v2/disperser_client.go
@@ -1,4 +1,4 @@
-package clients
+package v2
 
 import (
 	"context"
@@ -16,21 +16,21 @@ import (
 	"google.golang.org/grpc"
 )
 
-type DisperserClientV2Config struct {
+type DisperserClientConfig struct {
 	Hostname          string
 	Port              string
 	UseSecureGrpcFlag bool
 }
 
-type DisperserClientV2 interface {
+type DisperserClient interface {
 	Close() error
 	DisperseBlob(ctx context.Context, data []byte, blobVersion corev2.BlobVersion, quorums []core.QuorumID, salt uint32) (*dispv2.BlobStatus, corev2.BlobKey, error)
 	GetBlobStatus(ctx context.Context, blobKey corev2.BlobKey) (*disperser_rpc.BlobStatusReply, error)
 	GetBlobCommitment(ctx context.Context, data []byte) (*disperser_rpc.BlobCommitmentReply, error)
 }
 
-type disperserClientV2 struct {
-	config     *DisperserClientV2Config
+type disperserClient struct {
+	config     *DisperserClientConfig
 	signer     corev2.BlobRequestSigner
 	initOnce   sync.Once
 	conn       *grpc.ClientConn
@@ -39,18 +39,18 @@ type disperserClientV2 struct {
 	accountant *Accountant
 }
 
-var _ DisperserClientV2 = &disperserClientV2{}
+var _ DisperserClient = &disperserClient{}
 
-// DisperserClientV2 maintains a single underlying grpc connection to the disperser server,
+// DisperserClient maintains a single underlying grpc connection to the disperser server,
 // through which it sends requests to disperse blobs and get blob status.
 // The connection is established lazily on the first method call. Don't forget to call Close(),
 // which is safe to call even if the connection was never established.
 //
-// DisperserClientV2 is safe to be used concurrently by multiple goroutines.
+// DisperserClient is safe to be used concurrently by multiple goroutines.
 //
 // Example usage:
 //
-//	client := NewDisperserClientV2(config, signer)
+//	client := NewDisperserClient(config, signer)
 //	defer client.Close()
 //
 //	// The connection will be established on the first call
@@ -61,7 +61,7 @@ var _ DisperserClientV2 = &disperserClientV2{}
 //
 //	// Subsequent calls will use the existing connection
 //	status2, blobKey2, err := client.DisperseBlob(ctx, data, blobHeader)
-func NewDisperserClientV2(config *DisperserClientV2Config, signer corev2.BlobRequestSigner, prover encoding.Prover, accountant *Accountant) (*disperserClientV2, error) {
+func NewDisperserClient(config *DisperserClientConfig, signer corev2.BlobRequestSigner, prover encoding.Prover, accountant *Accountant) (*disperserClient, error) {
 	if config == nil {
 		return nil, api.NewErrorInvalidArg("config must be provided")
 	}
@@ -75,7 +75,7 @@ func NewDisperserClientV2(config *DisperserClientV2Config, signer corev2.BlobReq
 		return nil, api.NewErrorInvalidArg("signer must be provided")
 	}
 
-	return &disperserClientV2{
+	return &disperserClient{
 		config:     config,
 		signer:     signer,
 		prover:     prover,
@@ -85,7 +85,7 @@ func NewDisperserClientV2(config *DisperserClientV2Config, signer corev2.BlobReq
 }
 
 // PopulateAccountant populates the accountant with the payment state from the disperser.
-func (c *disperserClientV2) PopulateAccountant(ctx context.Context) error {
+func (c *disperserClient) PopulateAccountant(ctx context.Context) error {
 	paymentState, err := c.GetPaymentState(ctx)
 	if err != nil {
 		return fmt.Errorf("error getting payment state for initializing accountant: %w", err)
@@ -100,7 +100,7 @@ func (c *disperserClientV2) PopulateAccountant(ctx context.Context) error {
 
 // Close closes the grpc connection to the disperser server.
 // It is thread safe and can be called multiple times.
-func (c *disperserClientV2) Close() error {
+func (c *disperserClient) Close() error {
 	if c.conn != nil {
 		err := c.conn.Close()
 		c.conn = nil
@@ -110,7 +110,7 @@ func (c *disperserClientV2) Close() error {
 	return nil
 }
 
-func (c *disperserClientV2) DisperseBlob(
+func (c *disperserClient) DisperseBlob(
 	ctx context.Context,
 	data []byte,
 	blobVersion corev2.BlobVersion,
@@ -217,7 +217,7 @@ func (c *disperserClientV2) DisperseBlob(
 }
 
 // GetBlobStatus returns the status of a blob with the given blob key.
-func (c *disperserClientV2) GetBlobStatus(ctx context.Context, blobKey corev2.BlobKey) (*disperser_rpc.BlobStatusReply, error) {
+func (c *disperserClient) GetBlobStatus(ctx context.Context, blobKey corev2.BlobKey) (*disperser_rpc.BlobStatusReply, error) {
 	err := c.initOnceGrpcConnection()
 	if err != nil {
 		return nil, api.NewErrorInternal(err.Error())
@@ -230,7 +230,7 @@ func (c *disperserClientV2) GetBlobStatus(ctx context.Context, blobKey corev2.Bl
 }
 
 // GetPaymentState returns the payment state of the disperser client
-func (c *disperserClientV2) GetPaymentState(ctx context.Context) (*disperser_rpc.GetPaymentStateReply, error) {
+func (c *disperserClient) GetPaymentState(ctx context.Context) (*disperser_rpc.GetPaymentStateReply, error) {
 	err := c.initOnceGrpcConnection()
 	if err != nil {
 		return nil, api.NewErrorInternal(err.Error())
@@ -257,7 +257,7 @@ func (c *disperserClientV2) GetPaymentState(ctx context.Context) (*disperser_rpc
 // While the blob commitment can be calculated by anyone, it requires SRS points to
 // be loaded. For service that does not have access to SRS points, this method can be
 // used to calculate the blob commitment in blob header, which is required for dispersal.
-func (c *disperserClientV2) GetBlobCommitment(ctx context.Context, data []byte) (*disperser_rpc.BlobCommitmentReply, error) {
+func (c *disperserClient) GetBlobCommitment(ctx context.Context, data []byte) (*disperser_rpc.BlobCommitmentReply, error) {
 	err := c.initOnceGrpcConnection()
 	if err != nil {
 		return nil, api.NewErrorInternal(err.Error())
@@ -271,7 +271,7 @@ func (c *disperserClientV2) GetBlobCommitment(ctx context.Context, data []byte)
 
 // initOnceGrpcConnection initializes the grpc connection and client if they are not already initialized.
 // If initialization fails, it caches the error and will return it on every subsequent call.
-func (c *disperserClientV2) initOnceGrpcConnection() error {
+func (c *disperserClient) initOnceGrpcConnection() error {
 	var initErr error
 	c.initOnce.Do(func() {
 		addr := fmt.Sprintf("%v:%v", c.config.Hostname, c.config.Port)
diff --git a/api/clients/mock/node_client_v2.go b/api/clients/v2/mock/node_client.go
similarity index 85%
rename from api/clients/mock/node_client_v2.go
rename to api/clients/v2/mock/node_client.go
index adc03053dc..f89ab8335c 100644
--- a/api/clients/mock/node_client_v2.go
+++ b/api/clients/v2/mock/node_client.go
@@ -3,7 +3,7 @@ package mock
 import (
 	"context"
 
-	"github.com/Layr-Labs/eigenda/api/clients"
+	clients "github.com/Layr-Labs/eigenda/api/clients/v2"
 	"github.com/Layr-Labs/eigenda/core"
 	corev2 "github.com/Layr-Labs/eigenda/core/v2"
 	"github.com/stretchr/testify/mock"
@@ -13,7 +13,7 @@ type MockNodeClientV2 struct {
 	mock.Mock
 }
 
-var _ clients.NodeClientV2 = (*MockNodeClientV2)(nil)
+var _ clients.NodeClient = (*MockNodeClientV2)(nil)
 
 func NewNodeClientV2() *MockNodeClientV2 {
 	return &MockNodeClientV2{}
diff --git a/api/clients/mock/relay_client.go b/api/clients/v2/mock/relay_client.go
similarity index 96%
rename from api/clients/mock/relay_client.go
rename to api/clients/v2/mock/relay_client.go
index e97e1e5406..fb79ef912f 100644
--- a/api/clients/mock/relay_client.go
+++ b/api/clients/v2/mock/relay_client.go
@@ -3,7 +3,7 @@ package mock
 import (
 	"context"
 
-	"github.com/Layr-Labs/eigenda/api/clients"
+	clients "github.com/Layr-Labs/eigenda/api/clients/v2"
 	corev2 "github.com/Layr-Labs/eigenda/core/v2"
 	"github.com/stretchr/testify/mock"
 )
diff --git a/api/clients/node_client_v2.go b/api/clients/v2/node_client.go
similarity index 84%
rename from api/clients/node_client_v2.go
rename to api/clients/v2/node_client.go
index 58452aa94a..ecfee6d5e2 100644
--- a/api/clients/node_client_v2.go
+++ b/api/clients/v2/node_client.go
@@ -1,4 +1,4 @@
-package clients
+package v2
 
 import (
 	"context"
@@ -12,37 +12,37 @@ import (
 	"google.golang.org/grpc"
 )
 
-type NodeClientV2Config struct {
+type NodeClientConfig struct {
 	Hostname          string
 	Port              string
 	UseSecureGrpcFlag bool
 }
 
-type NodeClientV2 interface {
+type NodeClient interface {
 	StoreChunks(ctx context.Context, certs *corev2.Batch) (*core.Signature, error)
 	Close() error
 }
 
-type nodeClientV2 struct {
-	config   *NodeClientV2Config
+type nodeClient struct {
+	config   *NodeClientConfig
 	initOnce sync.Once
 	conn     *grpc.ClientConn
 
 	dispersalClient nodegrpc.DispersalClient
 }
 
-var _ NodeClientV2 = (*nodeClientV2)(nil)
+var _ NodeClient = (*nodeClient)(nil)
 
-func NewNodeClientV2(config *NodeClientV2Config) (*nodeClientV2, error) {
+func NewNodeClient(config *NodeClientConfig) (*nodeClient, error) {
 	if config == nil || config.Hostname == "" || config.Port == "" {
 		return nil, fmt.Errorf("invalid config: %v", config)
 	}
-	return &nodeClientV2{
+	return &nodeClient{
 		config: config,
 	}, nil
 }
 
-func (c *nodeClientV2) StoreChunks(ctx context.Context, batch *corev2.Batch) (*core.Signature, error) {
+func (c *nodeClient) StoreChunks(ctx context.Context, batch *corev2.Batch) (*core.Signature, error) {
 	if len(batch.BlobCertificates) == 0 {
 		return nil, fmt.Errorf("no blob certificates in the batch")
 	}
@@ -89,7 +89,7 @@ func (c *nodeClientV2) StoreChunks(ctx context.Context, batch *corev2.Batch) (*c
 
 // Close closes the grpc connection to the disperser server.
 // It is thread safe and can be called multiple times.
-func (c *nodeClientV2) Close() error {
+func (c *nodeClient) Close() error {
 	if c.conn != nil {
 		err := c.conn.Close()
 		c.conn = nil
@@ -99,7 +99,7 @@ func (c *nodeClientV2) Close() error {
 	return nil
 }
 
-func (c *nodeClientV2) initOnceGrpcConnection() error {
+func (c *nodeClient) initOnceGrpcConnection() error {
 	var initErr error
 	c.initOnce.Do(func() {
 		addr := fmt.Sprintf("%v:%v", c.config.Hostname, c.config.Port)
diff --git a/api/clients/relay_client.go b/api/clients/v2/relay_client.go
similarity index 99%
rename from api/clients/relay_client.go
rename to api/clients/v2/relay_client.go
index f43d747ab8..52ae32ee80 100644
--- a/api/clients/relay_client.go
+++ b/api/clients/v2/relay_client.go
@@ -1,4 +1,4 @@
-package clients
+package v2
 
 import (
 	"context"
diff --git a/api/clients/retrieval_client_v2.go b/api/clients/v2/retrieval_client.go
similarity index 86%
rename from api/clients/retrieval_client_v2.go
rename to api/clients/v2/retrieval_client.go
index e6edd5118b..bd095db6f4 100644
--- a/api/clients/retrieval_client_v2.go
+++ b/api/clients/v2/retrieval_client.go
@@ -1,10 +1,11 @@
-package clients
+package v2
 
 import (
 	"context"
 	"errors"
 	"fmt"
 
+	"github.com/Layr-Labs/eigenda/api/clients"
 	grpcnode "github.com/Layr-Labs/eigenda/api/grpc/node/v2"
 	"github.com/Layr-Labs/eigenda/core"
 	corev2 "github.com/Layr-Labs/eigenda/core/v2"
@@ -16,14 +17,14 @@ import (
 	"github.com/gammazero/workerpool"
 )
 
-// RetrievalClientV2 is an object that can retrieve blobs from the DA nodes.
+// RetrievalClient is an object that can retrieve blobs from the DA nodes.
 // To retrieve a blob from the relay, use RelayClient instead.
-type RetrievalClientV2 interface {
+type RetrievalClient interface {
 	// GetBlob downloads chunks of a blob from operator network and reconstructs the blob.
 	GetBlob(ctx context.Context, blobHeader corev2.BlobHeader, referenceBlockNumber uint64, quorumID core.QuorumID) ([]byte, error)
 }
 
-type retrievalClientV2 struct {
+type retrievalClient struct {
 	logger            logging.Logger
 	ethClient         core.Reader
 	indexedChainState core.IndexedChainState
@@ -31,15 +32,15 @@ type retrievalClientV2 struct {
 	numConnections    int
 }
 
-// NewRetrievalClientV2 creates a new retrieval client.
-func NewRetrievalClientV2(
+// NewRetrievalClient creates a new retrieval client.
+func NewRetrievalClient(
 	logger logging.Logger,
 	ethClient core.Reader,
 	chainState core.IndexedChainState,
 	verifier encoding.Verifier,
 	numConnections int,
-) RetrievalClientV2 {
-	return &retrievalClientV2{
+) RetrievalClient {
+	return &retrievalClient{
 		logger:            logger.With("component", "RetrievalClient"),
 		ethClient:         ethClient,
 		indexedChainState: chainState,
@@ -48,7 +49,7 @@ func NewRetrievalClientV2(
 	}
 }
 
-func (r *retrievalClientV2) GetBlob(ctx context.Context, blobHeader corev2.BlobHeader, referenceBlockNumber uint64, quorumID core.QuorumID) ([]byte, error) {
+func (r *retrievalClient) GetBlob(ctx context.Context, blobHeader corev2.BlobHeader, referenceBlockNumber uint64, quorumID core.QuorumID) ([]byte, error) {
 	blobKey, err := blobHeader.BlobKey()
 	if err != nil {
 		return nil, err
@@ -90,7 +91,7 @@ func (r *retrievalClientV2) GetBlob(ctx context.Context, blobHeader corev2.BlobH
 	}
 
 	// Fetch chunks from all operators
-	chunksChan := make(chan RetrievedChunks, len(operators))
+	chunksChan := make(chan clients.RetrievedChunks, len(operators))
 	pool := workerpool.New(r.numConnections)
 	for opID := range operators {
 		opID := opID
@@ -139,13 +140,13 @@ func (r *retrievalClientV2) GetBlob(ctx context.Context, blobHeader corev2.BlobH
 	)
 }
 
-func (r *retrievalClientV2) getChunksFromOperator(
+func (r *retrievalClient) getChunksFromOperator(
 	ctx context.Context,
 	opID core.OperatorID,
 	opInfo *core.IndexedOperatorInfo,
 	blobKey corev2.BlobKey,
 	quorumID core.QuorumID,
-	chunksChan chan RetrievedChunks,
+	chunksChan chan clients.RetrievedChunks,
 ) {
 	conn, err := grpc.NewClient(
 		core.OperatorSocket(opInfo.Socket).GetRetrievalSocket(),
@@ -158,7 +159,7 @@ func (r *retrievalClientV2) getChunksFromOperator(
 		}
 	}()
 	if err != nil {
-		chunksChan <- RetrievedChunks{
+		chunksChan <- clients.RetrievedChunks{
 			OperatorID: opID,
 			Err:        err,
 			Chunks:     nil,
@@ -174,7 +175,7 @@ func (r *retrievalClientV2) getChunksFromOperator(
 
 	reply, err := n.GetChunks(ctx, request)
 	if err != nil {
-		chunksChan <- RetrievedChunks{
+		chunksChan <- clients.RetrievedChunks{
 			OperatorID: opID,
 			Err:        err,
 			Chunks:     nil,
@@ -187,7 +188,7 @@ func (r *retrievalClientV2) getChunksFromOperator(
 		var chunk *encoding.Frame
 		chunk, err = new(encoding.Frame).DeserializeGnark(data)
 		if err != nil {
-			chunksChan <- RetrievedChunks{
+			chunksChan <- clients.RetrievedChunks{
 				OperatorID: opID,
 				Err:        err,
 				Chunks:     nil,
@@ -197,7 +198,7 @@ func (r *retrievalClientV2) getChunksFromOperator(
 
 		chunks[i] = chunk
 	}
-	chunksChan <- RetrievedChunks{
+	chunksChan <- clients.RetrievedChunks{
 		OperatorID: opID,
 		Err:        nil,
 		Chunks:     chunks,
diff --git a/api/clients/v2/utils.go b/api/clients/v2/utils.go
new file mode 100644
index 0000000000..a6c34caf00
--- /dev/null
+++ b/api/clients/v2/utils.go
@@ -0,0 +1,19 @@
+package v2
+
+import (
+	"crypto/tls"
+
+	"google.golang.org/grpc"
+	"google.golang.org/grpc/credentials"
+	"google.golang.org/grpc/credentials/insecure"
+)
+
+func getGrpcDialOptions(useSecureGrpcFlag bool) []grpc.DialOption {
+	options := []grpc.DialOption{}
+	if useSecureGrpcFlag {
+		options = append(options, grpc.WithTransportCredentials(credentials.NewTLS(&tls.Config{})))
+	} else {
+		options = append(options, grpc.WithTransportCredentials(insecure.NewCredentials()))
+	}
+	return options
+}
diff --git a/disperser/controller/dispatcher.go b/disperser/controller/dispatcher.go
index 1a4e299199..c592941c4e 100644
--- a/disperser/controller/dispatcher.go
+++ b/disperser/controller/dispatcher.go
@@ -4,11 +4,12 @@ import (
 	"context"
 	"errors"
 	"fmt"
-	"github.com/prometheus/client_golang/prometheus"
 	"math"
 	"time"
 
-	"github.com/Layr-Labs/eigenda/api/clients"
+	"github.com/prometheus/client_golang/prometheus"
+
+	clients "github.com/Layr-Labs/eigenda/api/clients/v2"
 	"github.com/Layr-Labs/eigenda/common"
 	"github.com/Layr-Labs/eigenda/core"
 	corev2 "github.com/Layr-Labs/eigenda/core/v2"
@@ -443,7 +444,7 @@ func (d *Dispatcher) GetOperatorState(ctx context.Context, metadatas []*v2.BlobM
 	return d.chainState.GetIndexedOperatorState(ctx, uint(blockNumber), quorumIds)
 }
 
-func (d *Dispatcher) sendChunks(ctx context.Context, client clients.NodeClientV2, batch *corev2.Batch) (*core.Signature, error) {
+func (d *Dispatcher) sendChunks(ctx context.Context, client clients.NodeClient, batch *corev2.Batch) (*core.Signature, error) {
 	ctxWithTimeout, cancel := context.WithTimeout(ctx, d.NodeRequestTimeout)
 	defer cancel()
 
diff --git a/disperser/controller/dispatcher_test.go b/disperser/controller/dispatcher_test.go
index cdc507cfd0..ec1f62a6bb 100644
--- a/disperser/controller/dispatcher_test.go
+++ b/disperser/controller/dispatcher_test.go
@@ -2,12 +2,13 @@ package controller_test
 
 import (
 	"context"
-	"github.com/prometheus/client_golang/prometheus"
 	"math/big"
 	"testing"
 	"time"
 
-	clientsmock "github.com/Layr-Labs/eigenda/api/clients/mock"
+	"github.com/prometheus/client_golang/prometheus"
+
+	clientsmock "github.com/Layr-Labs/eigenda/api/clients/v2/mock"
 	"github.com/Layr-Labs/eigenda/common"
 	"github.com/Layr-Labs/eigenda/core"
 	coremock "github.com/Layr-Labs/eigenda/core/mock"
diff --git a/disperser/controller/mock_node_client_manager.go b/disperser/controller/mock_node_client_manager.go
index d9e54f9cc3..9491fd3c50 100644
--- a/disperser/controller/mock_node_client_manager.go
+++ b/disperser/controller/mock_node_client_manager.go
@@ -1,7 +1,7 @@
 package controller
 
 import (
-	"github.com/Layr-Labs/eigenda/api/clients"
+	clients "github.com/Layr-Labs/eigenda/api/clients/v2"
 	"github.com/stretchr/testify/mock"
 )
 
@@ -11,8 +11,8 @@ type MockClientManager struct {
 
 var _ NodeClientManager = (*MockClientManager)(nil)
 
-func (m *MockClientManager) GetClient(host, port string) (clients.NodeClientV2, error) {
+func (m *MockClientManager) GetClient(host, port string) (clients.NodeClient, error) {
 	args := m.Called(host, port)
-	client, _ := args.Get(0).(clients.NodeClientV2)
+	client, _ := args.Get(0).(clients.NodeClient)
 	return client, args.Error(1)
 }
diff --git a/disperser/controller/node_client_manager.go b/disperser/controller/node_client_manager.go
index 0957428c68..45c8309cf8 100644
--- a/disperser/controller/node_client_manager.go
+++ b/disperser/controller/node_client_manager.go
@@ -3,25 +3,25 @@ package controller
 import (
 	"fmt"
 
-	"github.com/Layr-Labs/eigenda/api/clients"
+	clients "github.com/Layr-Labs/eigenda/api/clients/v2"
 	"github.com/Layr-Labs/eigensdk-go/logging"
 	lru "github.com/hashicorp/golang-lru/v2"
 )
 
 type NodeClientManager interface {
-	GetClient(host, port string) (clients.NodeClientV2, error)
+	GetClient(host, port string) (clients.NodeClient, error)
 }
 
 type nodeClientManager struct {
 	// nodeClients is a cache of node clients keyed by socket address
-	nodeClients *lru.Cache[string, clients.NodeClientV2]
+	nodeClients *lru.Cache[string, clients.NodeClient]
 	logger      logging.Logger
 }
 
 var _ NodeClientManager = (*nodeClientManager)(nil)
 
 func NewNodeClientManager(cacheSize int, logger logging.Logger) (*nodeClientManager, error) {
-	closeClient := func(socket string, value clients.NodeClientV2) {
+	closeClient := func(socket string, value clients.NodeClient) {
 		if err := value.Close(); err != nil {
 			logger.Error("failed to close node client", "err", err)
 		}
@@ -37,12 +37,12 @@ func NewNodeClientManager(cacheSize int, logger logging.Logger) (*nodeClientMana
 	}, nil
 }
 
-func (m *nodeClientManager) GetClient(host, port string) (clients.NodeClientV2, error) {
+func (m *nodeClientManager) GetClient(host, port string) (clients.NodeClient, error) {
 	socket := fmt.Sprintf("%s:%s", host, port)
 	client, ok := m.nodeClients.Get(socket)
 	if !ok {
 		var err error
-		client, err = clients.NewNodeClientV2(&clients.NodeClientV2Config{
+		client, err = clients.NewNodeClient(&clients.NodeClientConfig{
 			Hostname: host,
 			Port:     port,
 		})
diff --git a/inabox/tests/integration_v2_test.go b/inabox/tests/integration_v2_test.go
index 3a9f19b6b6..2d8598b9d4 100644
--- a/inabox/tests/integration_v2_test.go
+++ b/inabox/tests/integration_v2_test.go
@@ -5,7 +5,7 @@ import (
 	"crypto/rand"
 	"time"
 
-	"github.com/Layr-Labs/eigenda/api/clients"
+	clients "github.com/Layr-Labs/eigenda/api/clients/v2"
 	disperserpb "github.com/Layr-Labs/eigenda/api/grpc/disperser/v2"
 	"github.com/Layr-Labs/eigenda/core"
 	auth "github.com/Layr-Labs/eigenda/core/auth/v2"
@@ -26,7 +26,7 @@ var _ = Describe("Inabox v2 Integration", func() {
 		privateKeyHex := "0x0123456789abcdef0123456789abcdef0123456789abcdef0123456789abcded"
 		signer := auth.NewLocalBlobRequestSigner(privateKeyHex)
 
-		disp, err := clients.NewDisperserClientV2(&clients.DisperserClientV2Config{
+		disp, err := clients.NewDisperserClient(&clients.DisperserClientConfig{
 			Hostname: "localhost",
 			Port:     "32005",
 		}, signer, nil, nil)
diff --git a/node/grpc/server_v2_test.go b/node/grpc/server_v2_test.go
index 11ef1fce3e..901c2ad0dd 100644
--- a/node/grpc/server_v2_test.go
+++ b/node/grpc/server_v2_test.go
@@ -7,8 +7,8 @@ import (
 	"sync/atomic"
 	"testing"
 
-	"github.com/Layr-Labs/eigenda/api/clients"
-	clientsmock "github.com/Layr-Labs/eigenda/api/clients/mock"
+	clients "github.com/Layr-Labs/eigenda/api/clients/v2"
+	clientsmock "github.com/Layr-Labs/eigenda/api/clients/v2/mock"
 	pbcommon "github.com/Layr-Labs/eigenda/api/grpc/common/v2"
 	pbv2 "github.com/Layr-Labs/eigenda/api/grpc/node/v2"
 	"github.com/Layr-Labs/eigenda/common"
diff --git a/node/node.go b/node/node.go
index d8422c8aef..4533c8765c 100644
--- a/node/node.go
+++ b/node/node.go
@@ -32,7 +32,7 @@ import (
 	"google.golang.org/grpc/credentials"
 	"google.golang.org/grpc/credentials/insecure"
 
-	"github.com/Layr-Labs/eigenda/api/clients"
+	clients "github.com/Layr-Labs/eigenda/api/clients/v2"
 	"github.com/Layr-Labs/eigenda/api/grpc/node"
 	"github.com/Layr-Labs/eigenda/common/geth"
 	"github.com/Layr-Labs/eigenda/core"
diff --git a/node/node_test.go b/node/node_test.go
index 8000b2e2d4..906183c812 100644
--- a/node/node_test.go
+++ b/node/node_test.go
@@ -8,7 +8,7 @@ import (
 	"testing"
 	"time"
 
-	clientsmock "github.com/Layr-Labs/eigenda/api/clients/mock"
+	clientsmock "github.com/Layr-Labs/eigenda/api/clients/v2/mock"
 	"github.com/Layr-Labs/eigenda/common"
 	"github.com/Layr-Labs/eigenda/common/geth"
 	"github.com/Layr-Labs/eigenda/core"
diff --git a/node/node_v2.go b/node/node_v2.go
index a2572bd4b7..6acf2e3374 100644
--- a/node/node_v2.go
+++ b/node/node_v2.go
@@ -8,7 +8,7 @@ import (
 	"fmt"
 	"math/rand"
 
-	"github.com/Layr-Labs/eigenda/api/clients"
+	clients "github.com/Layr-Labs/eigenda/api/clients/v2"
 	"github.com/Layr-Labs/eigenda/core"
 	corev2 "github.com/Layr-Labs/eigenda/core/v2"
 	"github.com/gammazero/workerpool"
diff --git a/node/node_v2_test.go b/node/node_v2_test.go
index 14e1b0259b..cdde979683 100644
--- a/node/node_v2_test.go
+++ b/node/node_v2_test.go
@@ -6,7 +6,7 @@ import (
 	"testing"
 	"time"
 
-	"github.com/Layr-Labs/eigenda/api/clients"
+	clients "github.com/Layr-Labs/eigenda/api/clients/v2"
 	"github.com/Layr-Labs/eigenda/core"
 	v2 "github.com/Layr-Labs/eigenda/core/v2"
 	"github.com/Layr-Labs/eigenda/encoding"