public class InformerStatefulSets7 {
    public static void main(String[] args)  {
        /**/
        ApiClient apiClient = null;
        try {
            ClassPathResource resource = new ClassPathResource("kubectl.conf");
            InputStream inputStream = resource.getInputStream();
            Reader input = new InputStreamReader(inputStream);

            KubeConfig kubeConfig = KubeConfig.loadKubeConfig(input);
            apiClient = ClientBuilder.kubeconfig(kubeConfig).build();
           apiClient.getHttpClient().newBuilder().pingInterval(100, TimeUnit.MILLISECONDS);
        } catch (Exception e) {
            e.printStackTrace();
        }
        
        SharedInformerFactory factory = new SharedInformerFactory();

        AppsV1Api appsV1Api = new AppsV1Api(apiClient);

        // StatefulSet informer
        SharedIndexInformer<V1StatefulSet> statefulSetInformer =
                factory.sharedIndexInformerFor(
                        (CallGeneratorParams params) -> {
                            try {
                                return appsV1Api.listNamespacedStatefulSetCall(
                                        "default",
                                        null,
                                        null,
                                        null,
                                        null,
                                        null,
                                        null,
                                        params.resourceVersion,
                                        params.timeoutSeconds,
                                        params.watch,
                                        null);
                            } catch (ApiException e) {
                                e.printStackTrace();
                                return null;
                            }

                        },
                        V1StatefulSet.class,
                        V1StatefulSetList.class);

        statefulSetInformer.addEventHandlerWithResyncPeriod(
                new ResourceEventHandler<V1StatefulSet>() {
                    @Override
                    public void onAdd(V1StatefulSet statefulSet) {
                        System.out.printf("%s StatefulSet added!\n", statefulSet.getMetadata().getName());
                    }

                    @Override
                    public void onUpdate(V1StatefulSet oldStatefulSet, V1StatefulSet newStatefulSet) {
                        System.out.printf("%s StatefulSet update!\n", newStatefulSet.getMetadata().getName());
                        System.out.println(newStatefulSet);
                    }

                    @Override
                    public void onDelete(V1StatefulSet statefulSet, boolean deletedFinalStateUnknown) {
                        System.out.printf("%s StatefulSet delete!\n", statefulSet.getMetadata().getName());
                        System.out.println(statefulSet);
                    }
                },1000);

        statefulSetInformer.run();
        
    }
}