Skip to content

Commit

Permalink
Fix initKube: broadcast KubeReady event
Browse files Browse the repository at this point in the history
  • Loading branch information
smallinsky committed Dec 15, 2021
1 parent 1e09b82 commit 1eac241
Showing 1 changed file with 4 additions and 2 deletions.
6 changes: 4 additions & 2 deletions lib/service/kubernetes.go
Original file line number Diff line number Diff line change
Expand Up @@ -20,6 +20,9 @@ import (
"net"
"net/http"

"github.com/gravitational/trace"
"github.com/sirupsen/logrus"

"github.com/gravitational/teleport"
apidefaults "github.com/gravitational/teleport/api/defaults"
"github.com/gravitational/teleport/api/types"
Expand All @@ -30,8 +33,6 @@ import (
"github.com/gravitational/teleport/lib/reversetunnel"
"github.com/gravitational/teleport/lib/services"
"github.com/gravitational/teleport/lib/utils"
"github.com/gravitational/trace"
"github.com/sirupsen/logrus"
)

func (process *TeleportProcess) initKubernetes() {
Expand Down Expand Up @@ -270,6 +271,7 @@ func (process *TeleportProcess) initKubernetesService(log *logrus.Entry, conn *C
"Kubernetes service %s:%s is starting on %v.",
teleport.Version, teleport.Gitref, listener.Addr())
}
process.BroadcastEvent(Event{Name: KubernetesReady, Payload: nil})
err := kubeServer.Serve(listener)
if err != nil {
if err == http.ErrServerClosed {
Expand Down

0 comments on commit 1eac241

Please sign in to comment.