|
|
@ -17,9 +17,12 @@ package third
|
|
|
|
import (
|
|
|
|
import (
|
|
|
|
"context"
|
|
|
|
"context"
|
|
|
|
"fmt"
|
|
|
|
"fmt"
|
|
|
|
"github.com/openimsdk/open-im-server/v3/pkg/rpcli"
|
|
|
|
|
|
|
|
"time"
|
|
|
|
"time"
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
"github.com/openimsdk/open-im-server/v3/pkg/rpcli"
|
|
|
|
|
|
|
|
"github.com/openimsdk/tools/s3/aws"
|
|
|
|
|
|
|
|
"github.com/openimsdk/tools/s3/disable"
|
|
|
|
|
|
|
|
|
|
|
|
"github.com/openimsdk/open-im-server/v3/pkg/common/config"
|
|
|
|
"github.com/openimsdk/open-im-server/v3/pkg/common/config"
|
|
|
|
"github.com/openimsdk/open-im-server/v3/pkg/common/storage/cache/redis"
|
|
|
|
"github.com/openimsdk/open-im-server/v3/pkg/common/storage/cache/redis"
|
|
|
|
"github.com/openimsdk/open-im-server/v3/pkg/common/storage/controller"
|
|
|
|
"github.com/openimsdk/open-im-server/v3/pkg/common/storage/controller"
|
|
|
@ -90,6 +93,10 @@ func Start(ctx context.Context, config *Config, client discovery.SvcDiscoveryReg
|
|
|
|
o, err = oss.NewOSS(*config.RpcConfig.Object.Oss.Build())
|
|
|
|
o, err = oss.NewOSS(*config.RpcConfig.Object.Oss.Build())
|
|
|
|
case "kodo":
|
|
|
|
case "kodo":
|
|
|
|
o, err = kodo.NewKodo(*config.RpcConfig.Object.Kodo.Build())
|
|
|
|
o, err = kodo.NewKodo(*config.RpcConfig.Object.Kodo.Build())
|
|
|
|
|
|
|
|
case "aws":
|
|
|
|
|
|
|
|
o, err = aws.NewAws(*config.RpcConfig.Object.Aws.Build())
|
|
|
|
|
|
|
|
case "":
|
|
|
|
|
|
|
|
o = disable.NewDisable()
|
|
|
|
default:
|
|
|
|
default:
|
|
|
|
err = fmt.Errorf("invalid object enable: %s", enable)
|
|
|
|
err = fmt.Errorf("invalid object enable: %s", enable)
|
|
|
|
}
|
|
|
|
}
|
|
|
|