class KubeClusterMembershipConnector implements ClusterMembershipConnector {

    @Override
    public Mono<ClusterMembershipRevision<ClusterMember>> unregister(Function<ClusterMember, ClusterMembershipRevision<ClusterMember>> selfUpdate) {
        return reconciler.apply(current ->
                KubeRegistrationActions.unregisterLocal(context, current, selfUpdate).map(f -> f.apply(current))
        ).map(KubeClusterState::getLocalMemberRevision);
    }

    public  KubeClusterMembershipConnector(ClusterMember initial,
                                          KubeMembershipExecutor kubeMembershipExecutor,
                                          KubeLeaderElectionExecutor kubeLeaderElectionExecutor,
                                          KubeClusterMembershipConfiguration configuration,
                                          TitusRuntime titusRuntime);

}