pipeline

Documentation

Index

• func SetDebug(enabled bool)
• func Start(node Upstreamer)
• func Wait(upstream ...Upstreamer) <-chan error
• type Node
  • func (n *Node) AbortChannel() chan struct{}
  • func (n *Node) AbortSending()
  • func (n *Node) AbortWithError(err error) error
  • func (n *Node) Close()
  • func (n *Node) ErrorChannel() chan error
  • func (n *Node) Init(errors chan error, done chan struct{})
  • func (n *Node) SetUpstream(upstream Upstreamer)
  • func (n *Node) String() string
  • func (n *Node) Upstreamer() Upstreamer
• type Upstreamer

Functions

func SetDebug

func SetDebug(enabled bool)

func Start

func Start(node Upstreamer)

func Wait

func Wait(upstream ...Upstreamer) <-chan error

Types

type Node

type Node struct {
	Upstream Upstreamer
	// contains filtered or unexported fields
}

func (*Node) AbortChannel

func (n *Node) AbortChannel() chan struct{}

func (*Node) AbortSending

func (n *Node) AbortSending()

func (*Node) AbortWithError

func (n *Node) AbortWithError(err error) error

func (*Node) Close

func (n *Node) Close()

func (*Node) ErrorChannel

func (n *Node) ErrorChannel() chan error

func (*Node) Init

func (n *Node) Init(errors chan error, done chan struct{})

func (*Node) SetUpstream

func (n *Node) SetUpstream(upstream Upstreamer)

func (*Node) String

func (n *Node) String() string

func (*Node) Upstreamer

func (n *Node) Upstreamer() Upstreamer

type Upstreamer

type Upstreamer interface {
	AbortWithError(error) error
	Close()
	Init(errors chan error, done chan struct{})
	Run() error
	AbortSending()
	ErrorChannel() chan error
	Upstreamer() Upstreamer
	SetUpstream(Upstreamer)
}