diff --git a/backend/src/apiserver/client/minio.go b/backend/src/apiserver/client/minio.go index 800f815be5b..27c08a67901 100644 --- a/backend/src/apiserver/client/minio.go +++ b/backend/src/apiserver/client/minio.go @@ -52,7 +52,7 @@ func CreateMinioClient(minioServiceHost string, minioServicePort string, cred := createCredentialProvidersChain(endpoint, accessKey, secretKey) minioClient, err := minio.NewWithCredentials(endpoint, cred, secure, region) if err != nil { - return nil, errors.Wrapf(err, "Error while creating minio client: %+v", err) + return nil, errors.Wrapf(err, "Error while creating object store client: %+v", err) } return minioClient, nil } @@ -74,7 +74,7 @@ func CreateMinioClientOrFatal(minioServiceHost string, minioServicePort string, b.MaxElapsedTime = initConnectionTimeout err = backoff.Retry(operation, b) if err != nil { - glog.Fatalf("Failed to create Minio client. Error: %v", err) + glog.Fatalf("Failed to create object store client. Error: %v", err) } return minioClient } diff --git a/backend/src/apiserver/client_manager/client_manager.go b/backend/src/apiserver/client_manager/client_manager.go index 261aef5605f..2368666e3ff 100644 --- a/backend/src/apiserver/client_manager/client_manager.go +++ b/backend/src/apiserver/client_manager/client_manager.go @@ -168,9 +168,10 @@ func (c *ClientManager) Authenticators() []auth.Authenticator { func (c *ClientManager) init() { glog.Info("Initializing client manager") + glog.Info("Initializing DB client...") db := InitDBClient(common.GetDurationConfig(initConnectionTimeout)) db.SetConnMaxLifetime(common.GetDurationConfig(dbConMaxLifeTime)) - + glog.Info("DB client initialized successfully") // time c.time = util.NewRealTime() @@ -185,8 +186,9 @@ func (c *ClientManager) init() { c.resourceReferenceStore = storage.NewResourceReferenceStore(db) c.dBStatusStore = storage.NewDBStatusStore(db) c.defaultExperimentStore = storage.NewDefaultExperimentStore(db) + glog.Info("Initializing Object store client...") c.objectStore = initMinioClient(common.GetDurationConfig(initConnectionTimeout)) - + glog.Info("Object store client initialized successfully") // Use default value of client QPS (5) & burst (10) defined in // k8s.io/client-go/rest/config.go#RESTClientFor clientParams := util.ClientParameters{ @@ -494,10 +496,10 @@ func initMinioClient(initConnectionTimeout time.Duration) storage.ObjectStoreInt } func createMinioBucket(minioClient *minio.Client, bucketName, region string) { - // Check to see if we already own this bucket. + // Check to see if it exists, and we have permission to access it. exists, err := minioClient.BucketExists(bucketName) if err != nil { - glog.Fatalf("Failed to check if Minio bucket exists. Error: %v", err) + glog.Fatalf("Failed to check if object store bucket exists. Error: %v", err) } if exists { glog.Infof("We already own %s\n", bucketName) @@ -506,7 +508,7 @@ func createMinioBucket(minioClient *minio.Client, bucketName, region string) { // Create bucket if it does not exist err = minioClient.MakeBucket(bucketName, region) if err != nil { - glog.Fatalf("Failed to create Minio bucket. Error: %v", err) + glog.Fatalf("Failed to create object store bucket. Error: %v", err) } glog.Infof("Successfully created bucket %s\n", bucketName) }