func()

in tattler.go [198:211]

• 11 lines of code
• 3 McCabe index (conditional complexity)

func (r *Runner) AddProcessor(ctx context.Context, name string, in chan batching.Batches) error {
	r.mu.Lock()
	defer r.mu.Unlock()

	if in == nil {
		return fmt.Errorf("in cannot be nil")
	}

	if r.started {
		return fmt.Errorf("cannot add a processor after Runner has started")
	}

	return r.router.Register(ctx, name, in)
}