pipeline

type AsyncWatcher interface {
	WatchAsync(context.Context, chan<- types.Message) <-chan error
}

type Params struct {
	Logger       log.Logger        // Logger is used for logging errors.
	Watcher      AsyncWatcher      // Watcher is used to start watching.
	NewProcessor processor.Factory // NewProcessor creates a processor for all message.
	BufferSize   int               // BufferSize is the message buffer size. Defaults to 0.
}

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