pipelines

Feb 7, 2021

Changes in this version

+ type CodeframePipe interface

+ ProcessCodeframeRecords func(in chan *records.CodeframeRecord) chan *records.CodeframeRecord

+ type CodeframePipeline struct

+ func NewCodeframePipeline(pipes ...CodeframePipe) CodeframePipeline

+ func (p *CodeframePipeline) Close()

+ func (p *CodeframePipeline) Dequeue(handler func(*records.CodeframeRecord))

+ func (p *CodeframePipeline) Enqueue(item *records.CodeframeRecord)

+ type EventPipe interface

+ ProcessEventRecords func(in chan *records.EventOrientedRecord) chan *records.EventOrientedRecord

+ type EventPipeline struct

+ func NewEventPipeline(pipes ...EventPipe) EventPipeline

+ func (p *EventPipeline) Close()

+ func (p *EventPipeline) Dequeue(handler func(*records.EventOrientedRecord))

+ func (p *EventPipeline) Enqueue(item *records.EventOrientedRecord)

+ type ObjectPipe interface

+ ProcessObjectRecords func(in chan *records.ObjectRecord) chan *records.ObjectRecord

+ type ObjectPipeline struct

+ func NewObjectPipeline(pipes ...ObjectPipe) ObjectPipeline

+ func (p *ObjectPipeline) Close()

+ func (p *ObjectPipeline) Dequeue(handler func(*records.ObjectRecord))

+ func (p *ObjectPipeline) Enqueue(item *records.ObjectRecord)

+ type StudentPipe interface

+ ProcessStudentRecords func(in chan *records.StudentOrientedRecord) chan *records.StudentOrientedRecord

+ type StudentPipeline struct

+ func NewStudentPipeline(pipes ...StudentPipe) StudentPipeline

+ func (p *StudentPipeline) Close()

+ func (p *StudentPipeline) Dequeue(handler func(*records.StudentOrientedRecord))

+ func (p *StudentPipeline) Enqueue(item *records.StudentOrientedRecord)