view release on metacpan or  search on metacpan

xbin/dbio-pg-k8s  view on Meta::CPAN

}

sub _wait_for_ready {
  my ($k8s, $ns, $name) = @_;
  print STDERR "Waiting for pod $name to be ready";
  my $deadline = time + 120;
  while (time < $deadline) {
    my $pod = eval { $k8s->get('Pod', name => $name, namespace => $ns) };
    if ($pod && _pod_ready($pod)) {
      print STDERR " ready\n";
      return _get_service_endpoint($k8s, $ns, $name);
    }
    print STDERR '.';
    Time::HiRes::sleep(3);
  }
  die "\nTimed out waiting for pod $name\n";
}

sub _pod_ready {
  my ($pod) = @_;
  my $conditions = $pod->status->conditions // [];
  return grep { $_->type eq 'Ready' && $_->status eq 'True' } @$conditions;
}

sub _get_service_endpoint {
  my ($k8s, $ns, $name) = @_;
  my $svc       = $k8s->get('Service', name => $name, namespace => $ns);
  my $node_port = $svc->spec->ports->[0]->nodePort
    or die "No nodePort assigned to service $name\n";

  my $nodes  = $k8s->list('Node');
  my ($node) = grep { _node_ready($_) } @{ $nodes->items };
  die "No ready nodes found\n" unless $node;

  my ($addr) = grep { $_->type eq 'InternalIP' } @{ $node->status->addresses };