Skip to content

Commit

Permalink
fix: fix linter errors.
Browse files Browse the repository at this point in the history
Signed-off-by: Andrew Neudegg <andrew.neudegg@finbourne.com>
  • Loading branch information
AndrewNeudegg committed Dec 30, 2020
1 parent c8dae81 commit f721466
Showing 1 changed file with 2 additions and 0 deletions.
2 changes: 2 additions & 0 deletions pkg/pipeline/pipeline.go
Expand Up @@ -11,6 +11,7 @@ import (
sourceb "github.com/andrewneudegg/delta/pkg/source/builder"
)

// Pipeline is the representation of data flow through this application.
type Pipeline struct {
inCh chan events.Event // inCh merges all input channels into a singular channel.
outCh chan events.Event // outCh replicates events to all output channels.
Expand All @@ -20,6 +21,7 @@ type Pipeline struct {
distributors []distributor.D
}

// BuildPipeline will construct the pipeline at the core of delta.
func BuildPipeline(c configuration.Container) (Pipeline, error) {
p := Pipeline{
inCh: make(chan events.Event),
Expand Down

0 comments on commit f721466

Please sign in to comment.