func New()

in readers/apiserver/watchlist/watchlist.go [104:120]

• 15 lines of code
• 2 McCabe index (conditional complexity)

func New(ctx context.Context, clientset *kubernetes.Clientset, retrieveTypes RetrieveType, opts ...Option) (*Reader, error) {
	r, err := reader.New(ctx, clientset, retrieveTypes, opts...)
	if err != nil {
		return nil, err
	}

	newReader := func() (watchReader, error) {
		return reader.New(ctx, clientset, retrieveTypes, opts...)
	}

	return &Reader{
		r:         r,
		closeCh:   make(chan struct{}),
		newReader: newReader,
		logger:    r.Logger(),
	}, nil
}