StreamID => type alias

smartcontractkit · Jan 11, 2024 · 6126870 · 6126870
1 parent aa24834
commit 6126870
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 6 deletions.
diff --git a/core/services/streams/delegate.go b/core/services/streams/delegate.go
@@ -48,7 +48,7 @@ func (d *Delegate) ServicesForSpec(jb job.Job) (services []job.ServiceCtx, err e
 		return nil, errors.New("job name is required to be present for stream specs")
 	}
 	id := StreamID(jb.Name.String)
-	lggr := d.lggr.Named(id.String()).With("streamID", id)
+	lggr := d.lggr.Named(id).With("streamID", id)
 
 	rrs := ocrcommon.NewResultRunSaver(d.runner, lggr, d.cfg.MaxSuccessfulRuns(), d.cfg.ResultWriteQueueDepth())
 	services = append(services, rrs, &StreamService{

diff --git a/core/services/streams/stream_registry.go b/core/services/streams/stream_registry.go
@@ -8,11 +8,7 @@ import (
 	"github.com/smartcontractkit/chainlink/v2/core/services/pipeline"
 )
 
-type StreamID string
-
-func (s StreamID) String() string {
-	return string(s)
-}
+type StreamID = string
 
 type Registry interface {
 	Get(streamID StreamID) (strm Stream, exists bool)