src/server/pps/server/server.go
func NewAPIServer(
	env *serviceenv.ServiceEnv,
	etcdPrefix string,
	namespace string,
	workerImage string,
	workerSidecarImage string,
	workerImagePullPolicy string,
	storageRoot string,
	storageBackend string,
	storageHostPath string,
	iamRole string,
	imagePullSecret string,
	noExposeDockerSocket bool,
	reporter *metrics.Reporter,
	workerUsesRoot bool,
	workerGrpcPort uint16,
	port uint16,
	pprofPort uint16,
	httpPort uint16,
	peerPort uint16,
) (ppsclient.APIServer, error) {
	apiServer := &apiServer{
		Logger:                log.NewLogger("pps.API"),
		env:                   env,
		etcdPrefix:            etcdPrefix,
		namespace:             namespace,
		workerImage:           workerImage,
		workerSidecarImage:    workerSidecarImage,
		workerImagePullPolicy: workerImagePullPolicy,
		storageRoot:           storageRoot,
		storageBackend:        storageBackend,
		storageHostPath:       storageHostPath,
		iamRole:               iamRole,
		imagePullSecret:       imagePullSecret,
		noExposeDockerSocket:  noExposeDockerSocket,
		reporter:              reporter,
		workerUsesRoot:        workerUsesRoot,
		pipelines:             ppsdb.Pipelines(env.GetEtcdClient(), etcdPrefix),
		jobs:                  ppsdb.Jobs(env.GetEtcdClient(), etcdPrefix),
		monitorCancels:        make(map[string]func()),
		workerGrpcPort:        workerGrpcPort,
		port:                  port,
		pprofPort:             pprofPort,
		httpPort:              httpPort,
		peerPort:              peerPort,
	}
	apiServer.validateKube()
	go apiServer.master()
	return apiServer, nil
}
func NewAPIServer(
	env *serviceenv.ServiceEnv,
	etcdPrefix string,
	namespace string,
	workerImage string,
	workerSidecarImage string,
	workerImagePullPolicy string,
	storageRoot string,
	storageBackend string,
	storageHostPath string,
	iamRole string,
	imagePullSecret string,
	noExposeDockerSocket bool,
	reporter *metrics.Reporter,
	workerUsesRoot bool,
	workerGrpcPort uint16,
	port uint16,
	pprofPort uint16,
	httpPort uint16,
	peerPort uint16,
) (ppsclient.APIServer, error) {
	apiServer := &apiServer{
		Logger:                log.NewLogger("pps.API"),
		env:                   env,
		etcdPrefix:            etcdPrefix,
		namespace:             namespace,
		workerImage:           workerImage,
		workerSidecarImage:    workerSidecarImage,
		workerImagePullPolicy: workerImagePullPolicy,
		storageRoot:           storageRoot,
		storageBackend:        storageBackend,
		storageHostPath:       storageHostPath,
		iamRole:               iamRole,
		imagePullSecret:       imagePullSecret,
		noExposeDockerSocket:  noExposeDockerSocket,
		reporter:              reporter,
		workerUsesRoot:        workerUsesRoot,
		pipelines:             ppsdb.Pipelines(env.GetEtcdClient(), etcdPrefix),
		jobs:                  ppsdb.Jobs(env.GetEtcdClient(), etcdPrefix),
		monitorCancels:        make(map[string]func()),
		workerGrpcPort:        workerGrpcPort,
		port:                  port,
		pprofPort:             pprofPort,
		httpPort:              httpPort,
		peerPort:              peerPort,
	}
	apiServer.validateKube()
	go apiServer.master()
	return apiServer, nil
}
func NewAPIServer ( env * serviceenv . ServiceEnv , etcdPrefix string , namespace string , workerImage string , workerSidecarImage string , workerImagePullPolicy string , storageRoot string , storageBackend string , storageHostPath string , iamRole string , imagePullSecret string , noExposeDockerSocket bool , reporter * metrics . Reporter , workerUsesRoot bool , workerGrpcPort uint16 , port uint16 , pprofPort uint16 , httpPort uint16 , peerPort uint16 , ) ( ppsclient . APIServer , error ) { apiServer := & apiServer { Logger : log . NewLogger ( " " ) , env : env , etcdPrefix : etcdPrefix , namespace : namespace , workerImage : workerImage , workerSidecarImage : workerSidecarImage , workerImagePullPolicy : workerImagePullPolicy , storageRoot : storageRoot , storageBackend : storageBackend , storageHostPath : storageHostPath , iamRole : iamRole , imagePullSecret : imagePullSecret , noExposeDockerSocket : noExposeDockerSocket , reporter : reporter , workerUsesRoot : workerUsesRoot , pipelines : ppsdb . Pipelines ( env . GetEtcdClient ( ) , etcdPrefix ) , jobs : ppsdb . Jobs ( env . GetEtcdClient ( ) , etcdPrefix ) , monitorCancels : make ( map [ string ] func ( ) ) , workerGrpcPort : workerGrpcPort , port : port , pprofPort : pprofPort , httpPort : httpPort , peerPort : peerPort , } apiServer . validateKube ( ) go apiServer . master ( ) return apiServer , nil }
// NewAPIServer creates an APIServer.
NewAPIServer creates an APIServer .