istio

type Cache struct {
	Name      string
	Namespace string
}

type Provider struct {
	Ctx        context.Context
	KubeClient kubernetes.Interface
	Client     ezkube.Ensurer

	// pulls the image descriptor so we can get the
	// name of the file created by the cache
	Puller pull.ImagePuller

	// the target workload to deploy the filter
	Workload Workload

	// reference to the wasme cache
	Cache Cache

	// set owner references on created Filters with this parent object
	// if it's nil, they will not have an owner reference set
	ParentObject ezkube.Object

	// Callback to the caller when for when the istio provider
	// updates a workload.
	// err != nil in the case that update failed
	OnWorkload func(workloadMeta metav1.ObjectMeta, err error)

	// namespace of the istio control plane
	// Provider will use this to determine the installed version of istio
	// for abi compatibility
	// defaults to istio-system
	IstioNamespace string

	// if non-zero, wait for cache events to be populated with this timeout before
	// creating istio EnvoyFilters.
	// set to zero to skip the check
	WaitForCacheTimeout time.Duration
}

type VersionInspector interface {
	GetIstioVersion() (string, error)
}

type Workload struct {
	// leave name empty to select ALL workloads in the namespace
	Labels    map[string]string
	Namespace string
	Kind      string
}