aboutsummaryrefslogtreecommitdiff
path: root/weed/s3api/s3api_server.go
diff options
context:
space:
mode:
authorLHHDZ <changlin.shi@ly.com>2022-09-29 03:45:18 +0800
committerGitHub <noreply@github.com>2022-09-28 12:45:18 -0700
commitaacdcc4cad3d3aea58144640545a630c8b62d11a (patch)
treec2c0aad79a61308b119be7cda9ebd8cdfe4ab285 /weed/s3api/s3api_server.go
parent301b678147c4cca7a3a7b70273ddf389cfcd133a (diff)
downloadseaweedfs-aacdcc4cad3d3aea58144640545a630c8b62d11a.tar.xz
seaweedfs-aacdcc4cad3d3aea58144640545a630c8b62d11a.zip
s3: add account (#3753)
associate `Account` and `Identity` by accountId
Diffstat (limited to 'weed/s3api/s3api_server.go')
-rw-r--r--weed/s3api/s3api_server.go2
1 files changed, 2 insertions, 0 deletions
diff --git a/weed/s3api/s3api_server.go b/weed/s3api/s3api_server.go
index 76163d724..7ed5d4e87 100644
--- a/weed/s3api/s3api_server.go
+++ b/weed/s3api/s3api_server.go
@@ -40,6 +40,7 @@ type S3ApiServer struct {
randomClientId int32
filerGuard *security.Guard
client *http.Client
+ accountManager *AccountManager
}
func NewS3ApiServer(router *mux.Router, option *S3ApiServerOption) (s3ApiServer *S3ApiServer, err error) {
@@ -59,6 +60,7 @@ func NewS3ApiServer(router *mux.Router, option *S3ApiServerOption) (s3ApiServer
filerGuard: security.NewGuard([]string{}, signingKey, expiresAfterSec, readSigningKey, readExpiresAfterSec),
cb: NewCircuitBreaker(option),
}
+ s3ApiServer.accountManager = NewAccountManager(s3ApiServer)
if option.LocalFilerSocket == "" {
s3ApiServer.client = &http.Client{Transport: &http.Transport{
MaxIdleConns: 1024,