lineage

Documentation

Index

• type Tracker
  • func NewTracker(processName, managerURL, pipelineHash string, ...) Tracker
  • func (tracker *Tracker) Start(wg *sync.WaitGroup)
  • func (tracker *Tracker) StartBlocking()

Types

type Tracker

type Tracker struct {
	TransformationName string
	ToLineate          <-chan transmit.Serializable // desc.RemoteFragmentDesc
	// contains filtered or unexported fields
}

Tracker is a structure responsible for tracking lineage information and submitting it to a central gathering point

func NewTracker

func NewTracker(processName, managerURL, pipelineHash string, toLineate chan transmit.Serializable) Tracker

NewTracker instantiates a new Tracker

func (*Tracker) Start

func (tracker *Tracker) Start(wg *sync.WaitGroup)

Start asychronously calls StartBlocking via Goroutine

func (*Tracker) StartBlocking

func (tracker *Tracker) StartBlocking()

StartBlocking starts the main loop of the Tracker