From b86a1cb94eaa9af356041c814a63e4503f10d52f Mon Sep 17 00:00:00 2001 From: Matt Butcher Date: Tue, 12 Apr 2016 12:23:44 -0600 Subject: [PATCH] ifeat(tiller): add environment to server struct --- cmd/tiller/server.go | 20 ++++++++++++++++++-- 1 file changed, 18 insertions(+), 2 deletions(-) diff --git a/cmd/tiller/server.go b/cmd/tiller/server.go index 1ccb3abfc..5a98244db 100644 --- a/cmd/tiller/server.go +++ b/cmd/tiller/server.go @@ -3,24 +3,40 @@ package main import ( "net" + "github.com/deis/tiller/cmd/tiller/environment" "github.com/deis/tiller/pkg/hapi" ctx "golang.org/x/net/context" "google.golang.org/grpc" ) -type server struct{} +type server struct { + Environment *environment.Environment +} + +// newServer creates a new server with the default environment. +// +// TODO: This can take a configuration object of some sort so that we can +// initialize the environment with the correct stuff. +func newServer() *server { + return &server{ + Environment: environment.New(), + } +} func (s *server) Ready(c ctx.Context, req *hapi.PingRequest) (*hapi.PingResponse, error) { return &hapi.PingResponse{Status: "OK"}, nil } +// startServer starts a new gRPC server listening on the given address. +// +// addr must conform to the requirements of "net.Listen". func startServer(addr string) error { lstn, err := net.Listen("tcp", addr) if err != nil { return nil } - hserver := &server{} + hserver := newServer() srv := grpc.NewServer() hapi.RegisterProbeServer(srv, hserver)