pipeline

Documentation

Index

• Constants
• type Data
  • func NewData(value interface{}, status PipelineStatus) *Data
• type OnComplete
• type OnData
• type OnError
• type Pipeline
  • func FromChannel(in chan interface{}) *Pipeline
  • func FromProducer(producer Producer) *Pipeline
  • func Just(values ...interface{}) *Pipeline
  • func (p *Pipeline) Block() ([]interface{}, error)
  • func (p *Pipeline) Close()
  • func (p *Pipeline) Pipe(stage Stage) *Pipeline
  • func (p *Pipeline) Subscribe(onData OnData, onError OnError, onComplete OnComplete)
• type PipelineStatus
• type Producer
• type Stage

Constants

const (
	Processing = iota
	PipelineError
	Completed
)

Types

type Data

type Data struct {
	Value  interface{}
	Status PipelineStatus
}

func NewData

func NewData(value interface{}, status PipelineStatus) *Data

type OnComplete

type OnComplete = func()

type OnData

type OnData = func(value interface{})

type OnError

type OnError = func(err error)

type Pipeline

type Pipeline struct {
	// contains filtered or unexported fields
}

func FromChannel

func FromChannel(in chan interface{}) *Pipeline

func FromProducer

func FromProducer(producer Producer) *Pipeline

func Just

func Just(values ...interface{}) *Pipeline

func (*Pipeline) Block

func (p *Pipeline) Block() ([]interface{}, error)

func (*Pipeline) Close

func (p *Pipeline) Close()

func (*Pipeline) Pipe

func (p *Pipeline) Pipe(stage Stage) *Pipeline

func (*Pipeline) Subscribe

func (p *Pipeline) Subscribe(onData OnData, onError OnError, onComplete OnComplete)

type PipelineStatus

type PipelineStatus = uint8

type Producer

type Producer = func(chan *Data)

type Stage

type Stage = func(value interface{}) (interface{}, error)