Rename struct DataTransport to DataSource

Author: raynaudoe

connections/data_transport.go connections/data_source.goconnections/data_transport.go renamed to connections/data_source.go

@@ -13,7 +13,7 @@ const (
 	defaultRetryDelay = 30 * time.Second
 )
 
-type DataTransport struct {
+type DataSource struct {
 	// data sources
 	DbConn        *gorm.DB
 	RosettaClient *client.APIClient
@@ -24,10 +24,10 @@ type DataTransport struct {
 	RetryDelay time.Duration
 }
 
-type TransportOption func(*DataTransport)
+type SourceOption func(*DataSource)
 
-func NewDataTransport(opts ...TransportOption) DataTransport {
-	d := DataTransport{
+func NewDataSource(opts ...SourceOption) DataSource {
+	d := DataSource{
 		Ctx:        context.Background(),
 		RetryDelay: defaultRetryDelay,
 	}
@@ -38,38 +38,38 @@ func NewDataTransport(opts ...TransportOption) DataTransport {
 	return d
 }
 
-func WithContext(ctx context.Context) TransportOption {
-	return func(w *DataTransport) {
+func WithContext(ctx context.Context) SourceOption {
+	return func(w *DataSource) {
 		w.Ctx = ctx
 	}
 }
 
-func WithRetryDelay(delay time.Duration) TransportOption {
-	return func(w *DataTransport) {
+func WithRetryDelay(delay time.Duration) SourceOption {
+	return func(w *DataSource) {
 		w.RetryDelay = delay
 	}
 }
 
-func WithDBConnection(dbConn *gorm.DB) TransportOption {
-	return func(w *DataTransport) {
+func WithDBConnection(dbConn *gorm.DB) SourceOption {
+	return func(w *DataSource) {
 		w.DbConn = dbConn
 	}
 }
 
-func WithRosettaClient(client *client.APIClient) TransportOption {
-	return func(w *DataTransport) {
+func WithRosettaClient(client *client.APIClient) SourceOption {
+	return func(w *DataSource) {
 		w.RosettaClient = client
 	}
 }
 
-func WithNodeClient(node interface{}) TransportOption {
-	return func(w *DataTransport) {
+func WithNodeClient(node interface{}) SourceOption {
+	return func(w *DataSource) {
 		w.NodeClient = node
 	}
 }
 
-func WithDataStore(cfg ds.DataStoreConfig) TransportOption {
-	return func(w *DataTransport) {
+func WithDataStore(cfg ds.DataStoreConfig) SourceOption {
+	return func(w *DataSource) {
 		switch cfg.Service {
 		case ds.MinIOStorage:
 			c, _ := ds.NewMinioClient(cfg)

workers/workQueue/dispatcher.go

@@ -34,10 +34,10 @@ func NewJobDispatcher(cfg DispatcherConfig) JobDispatcher {
 	return d
 }
 
-func (j JobDispatcher) BuildWorkers(count int, dataTransport connections.DataTransport, constructor WorkerConstructor) {
+func (j JobDispatcher) BuildWorkers(count int, dataSource connections.DataSource, constructor WorkerConstructor) {
 	for i := 0; i < count; i++ {
 		workerId := fmt.Sprintf("worker.%d", i)
-		worker := constructor(workerId, dataTransport, j.workerChannel)
+		worker := constructor(workerId, dataSource, j.workerChannel)
 		worker.Worker.Start()
 	}
 }

workers/workQueue/worker_queued.go

@@ -11,7 +11,7 @@ type QueuedWorker struct {
 	Worker IQueuedWorker
 }
 
-type WorkerConstructor func(string, cn.DataTransport, chan chan Work) QueuedWorker
+type WorkerConstructor func(string, cn.DataSource, chan chan Work) QueuedWorker
 
 type Work struct {
 	JobId  int64