diff options
| author | LHHDZ <changlin.shi@ly.com> | 2022-09-30 03:29:01 +0800 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2022-09-29 12:29:01 -0700 |
| commit | 3de1e1978091e9675c9d54655dcde0c7dea9d222 (patch) | |
| tree | 86d5b68876c9e964e9ff3ae6b05cef66aa62abf5 /weed/s3api/s3api_server.go | |
| parent | 5e9039d728221b69dc30010e73c3a0a4e7c7e7e8 (diff) | |
| download | seaweedfs-3de1e1978091e9675c9d54655dcde0c7dea9d222.tar.xz seaweedfs-3de1e1978091e9675c9d54655dcde0c7dea9d222.zip | |
s3: sync bucket info from filer (#3759)
Diffstat (limited to 'weed/s3api/s3api_server.go')
| -rw-r--r-- | weed/s3api/s3api_server.go | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/weed/s3api/s3api_server.go b/weed/s3api/s3api_server.go index 7ed5d4e87..e94611d6a 100644 --- a/weed/s3api/s3api_server.go +++ b/weed/s3api/s3api_server.go @@ -41,6 +41,7 @@ type S3ApiServer struct { filerGuard *security.Guard client *http.Client accountManager *AccountManager + bucketRegistry *BucketRegistry } func NewS3ApiServer(router *mux.Router, option *S3ApiServerOption) (s3ApiServer *S3ApiServer, err error) { @@ -61,6 +62,7 @@ func NewS3ApiServer(router *mux.Router, option *S3ApiServerOption) (s3ApiServer cb: NewCircuitBreaker(option), } s3ApiServer.accountManager = NewAccountManager(s3ApiServer) + s3ApiServer.bucketRegistry = NewBucketRegistry(s3ApiServer) if option.LocalFilerSocket == "" { s3ApiServer.client = &http.Client{Transport: &http.Transport{ MaxIdleConns: 1024, @@ -78,7 +80,7 @@ func NewS3ApiServer(router *mux.Router, option *S3ApiServerOption) (s3ApiServer s3ApiServer.registerRouter(router) - go s3ApiServer.subscribeMetaEvents("s3", filer.DirectoryEtcRoot, time.Now().UnixNano()) + go s3ApiServer.subscribeMetaEvents("s3", time.Now().UnixNano(), filer.DirectoryEtcRoot, []string{option.BucketsPath}) return s3ApiServer, nil } |