WIP

smartcontractkit · Oct 16, 2023 · 2bfe646 · 2bfe646
1 parent 66bf221
commit 2bfe646
Show file tree

Hide file tree

Showing 24 changed files with 412 additions and 400 deletions.
diff --git a/pkg/loop/grpc_plugin_service_test.go b/pkg/loop/grpc_plugin_service_test.go
diff --git a/pkg/loop/internal/median.go b/pkg/loop/internal/median.go
@@ -179,7 +179,7 @@ type medianProviderClient struct {
 func (m *medianProviderClient) ClientConn() grpc.ClientConnInterface { return m.cc }
 
 func newMedianProviderClient(b *brokerExt, cc grpc.ClientConnInterface) *medianProviderClient {
-	m := &medianProviderClient{pluginProviderClient: newPluginProviderClient(b, cc)}
+	m := &medianProviderClient{pluginProviderClient: newPluginProviderClient(b.withName("MedianProviderClient"), cc)}
 	m.reportCodec = &reportCodecClient{b, pb.NewReportCodecClient(m.cc)}
 	m.medianContract = &medianContractClient{pb.NewMedianContractClient(m.cc)}
 	m.onchainConfigCodec = &onchainConfigCodecClient{b, pb.NewOnchainConfigCodecClient(m.cc)}

diff --git a/pkg/loop/internal/pb/plugin_service.pb.go b/pkg/loop/internal/pb/plugin_service.pb.go
diff --git a/pkg/loop/internal/pb/plugin_service.proto b/pkg/loop/internal/pb/plugin_service.proto
@@ -5,7 +5,7 @@ option go_package = "github.com/smartcontractkit/chainlink-relay/pkg/loop/intern
 package loop;
 
 service PluginService {
-  rpc NewPluginServiceFactory (NewPluginServiceFactoryRequest) returns (NewPluginServiceFactoryReply) {}
+  rpc NewReportingPluginFactory (NewReportingPluginFactoryRequest) returns (NewReportingPluginFactoryReply) {}
 }
 
 message PluginServiceConfig {
@@ -15,14 +15,14 @@ message PluginServiceConfig {
   bytes pluginConfig = 4;
 }
 
-// NewPluginServiceFactoryRequest has arguments for [github.com/smartcontractkit/chainlink-relay/pkg/loop.PluginService.NewPluginServiceFactory].
-message NewPluginServiceFactoryRequest {
+// NewReportingPluginFactoryRequest has arguments for [github.com/smartcontractkit/chainlink-relay/pkg/loop.PluginService.NewReportingPluginFactory].
+message NewReportingPluginFactoryRequest {
   uint32 providerID = 1;
   uint32 errorLogID = 2;
   PluginServiceConfig pluginServiceConfig = 3;
 }
 
-// NewPluginServiceFactoryReply has return arguments for [github.com/smartcontractkit/chainlink-relay/pkg/loop.PluginService.NewPluginServiceFactory].
-message NewPluginServiceFactoryReply {
+// NewReportingPlufinFactoryReply has return arguments for [github.com/smartcontractkit/chainlink-relay/pkg/loop.PluginService.NewReportingPluginFactory].
+message NewReportingPluginFactoryReply {
   uint32 reportingPluginFactoryID = 1;
 }