fullstatepipe

Documentation

Index

• Constants
• type Pipe
  • func New(strategy Strategy, stages ...fullstate.Callback) *Pipe
  • func (pipe *Pipe) Callback(ch <-chan *client.ServiceEndpoints)
• type Strategy

Constants

const (
	// Sequence calls to each pipe stage in sequence. Implies storing the state in a buffer.
	Sequence = iota
	// Parallel calls each pipe stage in parallel. No buffering required, but
	// the stages are not really stages anymore.
	Parallel
	// ParallelSendSequenceClose calls each pipe entry in parallel but closes
	// the channel of a stage only after the previous has finished. No
	// buffering required but still a meaningful sequencing, especially when
	// using the diffstore.
	ParallelSendSequenceClose
)

Types

type Pipe

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

func New

func New(strategy Strategy, stages ...fullstate.Callback) *Pipe

func (*Pipe) Callback

func (pipe *Pipe) Callback(ch <-chan *client.ServiceEndpoints)

type Strategy

type Strategy int