NAS gateway: fix notification initialization (#8920)

Co-authored-by: Harshavardhana <harsha@minio.io>
master
poornas 5 years ago committed by GitHub
parent 7ce63b3078
commit 1ea2449269
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
  1. 6
      cmd/gateway-main.go
  2. 2
      cmd/notification.go

@ -243,12 +243,16 @@ func StartGateway(ctx *cli.Context, gw Gateway) {
// sub-systems, make sure that we do not move the above codeblock elsewhere. // sub-systems, make sure that we do not move the above codeblock elsewhere.
if enableConfigOps { if enableConfigOps {
logger.FatalIf(globalConfigSys.Init(newObject), "Unable to initialize config system") logger.FatalIf(globalConfigSys.Init(newObject), "Unable to initialize config system")
buckets, err := newObject.ListBuckets(context.Background())
if err != nil {
logger.Fatal(err, "Unable to list buckets")
}
logger.FatalIf(globalNotificationSys.Init(buckets, newObject), "Unable to initialize notification system")
// Start watching disk for reloading config, this // Start watching disk for reloading config, this
// is only enabled for "NAS" gateway. // is only enabled for "NAS" gateway.
globalConfigSys.WatchConfigNASDisk(newObject) globalConfigSys.WatchConfigNASDisk(newObject)
} }
// This is only to uniquely identify each gateway deployments. // This is only to uniquely identify each gateway deployments.
globalDeploymentID = env.Get("MINIO_GATEWAY_DEPLOYMENT_ID", mustGetUUID()) globalDeploymentID = env.Get("MINIO_GATEWAY_DEPLOYMENT_ID", mustGetUUID())
logger.SetDeploymentID(globalDeploymentID) logger.SetDeploymentID(globalDeploymentID)

@ -704,7 +704,7 @@ func (sys *NotificationSys) Init(buckets []BucketInfo, objAPI ObjectLayer) error
} }
// In gateway mode, notifications are not supported. // In gateway mode, notifications are not supported.
if globalIsGateway { if globalIsGateway && !objAPI.IsNotificationSupported() {
return nil return nil
} }

Loading…
Cancel
Save