ctbManager, _ := NewInformerManager(ctbInformer, 256, 5*time.Minute)

	informerFactory.Start(ctx.Done())
	if !cache.WaitForCacheSync(ctx.Done(), ctbInformer.Informer().HasSynced) {
		t.Fatalf("Timed out waiting for informer to sync")
	}

	gotBundle, err := ctbManager.GetTrustAnchorsByName("ctb1", false)
	if err != nil {
		t.Fatalf("Error while calling GetTrustAnchorsByName: %v", err)
	}

 * limitations under the License.
 */

package org.gradle.tooling.events.task;

import org.gradle.tooling.events.FinishEvent;

/**
 * An event that informs about a task having finished its execution. You can query the result of the task using {@link #getResult()}.
 *
 * @since 2.5
 */
public interface TaskFinishEvent extends TaskProgressEvent, FinishEvent {

    /**

		stop := make(chan struct{})
		defer close(stop)
		informerFactory.Start(stop)
		informer := informerFactory.Apps().V1().ControllerRevisions()
		informerFactory.WaitForCacheSync(stop)
		for i := range test.revisions {
			informer.Informer().GetIndexer().Add(test.revisions[i])
		}

		history := NewHistory(client, informer.Lister())
		revisions, err := history.ListControllerRevisions(test.parent, test.selector)
		if err != nil {

}

// NewPVAssumeCache creates a PV assume cache.
func NewPVAssumeCache(logger klog.Logger, informer assumecache.Informer) *PVAssumeCache {
	logger = klog.LoggerWithName(logger, "PV Cache")
	return &PVAssumeCache{
		AssumeCache: assumecache.NewAssumeCache(logger, informer, "v1.PersistentVolume", "storageclass", pvStorageClassIndexFunc),
		logger:      logger,
	}
}

			if handlerRegistration, err = informerFactory.Storage().V1().CSINodes().Informer().AddEventHandler(
				buildEvtResHandler(at, framework.CSINode, "CSINode"),
			); err != nil {
				return err
			}
			handlers = append(handlers, handlerRegistration)
		case framework.CSIDriver:
			if handlerRegistration, err = informerFactory.Storage().V1().CSIDrivers().Informer().AddEventHandler(
				buildEvtResHandler(at, framework.CSIDriver, "CSIDriver"),

 * See the License for the specific language governing permissions and
 * limitations under the License.
 */
package org.gradle.tooling.events;

/**
 * An event that informs about an interim results of the operation.
 *
 * @since 3.5
 */
public interface StatusEvent extends ProgressEvent {
    /**
     * The amount of work already performed by the build operation.
     *

 * limitations under the License.
 */

package org.gradle.tooling.events.task;

import org.gradle.tooling.events.StartEvent;

/**
 * An event that informs about a task having started its execution.
 *
 * @since 2.5
 */
public interface TaskStartEvent extends TaskProgressEvent, StartEvent {

 * limitations under the License.
 */

package org.gradle.tooling.events.configuration;

import org.gradle.tooling.events.FinishEvent;

/**
 * An event that informs about a project configuration operation having finished its execution.
 *
 * @since 5.1
 */
public interface ProjectConfigurationFinishEvent extends ProjectConfigurationProgressEvent, FinishEvent {
    @Override

 * limitations under the License.
 */

package org.gradle.tooling.events.transform;

import org.gradle.tooling.events.FinishEvent;

/**
 * An event that informs about a transform operation having finished its execution.
 *
 * @since 5.1
 */
public interface TransformFinishEvent extends TransformProgressEvent, FinishEvent {
    @Override
    TransformOperationResult getResult();

 * limitations under the License.
 */

package org.gradle.tooling.events.work;

import org.gradle.tooling.events.StartEvent;

/**
 * An event that informs about a work item having started its execution.
 *
 * @since 5.1
 */
public interface WorkItemStartEvent extends WorkItemProgressEvent, StartEvent {