source

Documentation

Overview

source package is responsible for holding the logic of the start state of the plumbing system

Index

• Constants
• type Source
  • func NewSource(dsc, file string, pps map[string]*pipe.Pipe) (*Source, error)

Constants

const ColIndex = 0

ColIndex defines the position of the column names in the slice given by the csv package after reading a CSV file

Types

type Source

type Source struct {
	Description string                // Description of the source
	Pipes       map[string]*pipe.Pipe // mapping of CSV column titles to the Pipes that will operate on the columns
	// contains filtered or unexported fields
}

Source represents the beginning state of a pipeline

func NewSource

func NewSource(dsc, file string, pps map[string]*pipe.Pipe) (*Source, error)

New returns a new instance of a Source