I was able to create a watcher for resources created by

operator (statefulset)

and when

service

resource has been created, I am trying to get it using something like this:

const kc = new k8sClient.KubeConfig();
const watcher = config.servicesK8s.cluster.kubeconfig
  .apply(kubeConfig => kc.loadFromString(kubeConfig))
  .apply(() => new k8sClient.Watch(kc));

export let serviceName = watcher.apply(w => waitFor(w, 'elastic-es-http'));

export const service = pulumi
  .all([namespace.metadata.name, serviceName])
  .apply(([ns, name]) =>
    k8s.core.v1.Service.get('elastic-svc', `${ns}/${name}`, {
      parent: namespace,
      dependsOn: [elasticsearch]
    })
  );