feat(oss api): support ceph oss

.gitignore

@@ -54,6 +54,7 @@ cmd/layotto_multiple_api/nohup.out
 default.etcd/
 demo/configuration/common/client
 demo/file/client
+demo/oss/client
 demo/flowcontrol/client
 demo/lock/redis/client
 demo/pubsub/redis/client/publisher

cmd/layotto/main.go

@@ -30,6 +30,8 @@ import (
 
 	aliyun_oss "mosn.io/layotto/components/oss/aliyun"
 
+	ceph_oss "mosn.io/layotto/components/oss/ceph"
+
 	"mosn.io/mosn/pkg/istio"
 
 	aliyun_file "mosn.io/layotto/components/file/aliyun"
@@ -290,6 +292,7 @@ func NewRuntimeGrpcServer(data json.RawMessage, opts ...grpc.ServerOption) (mgrp
 		runtime.WithOssFactory(
 			oss.NewFactory("aws.oss", aws_oss.NewAwsOss),
 			oss.NewFactory("aliyun.oss", aliyun_oss.NewAliyunOss),
+			oss.NewFactory("ceph.oss", ceph_oss.NewCephOss),
 		),
 		// PubSub
 		runtime.WithPubSubFactory(

cmd/layotto_multiple_api/main.go

@@ -30,6 +30,8 @@ import (
 
 	aliyun_oss "mosn.io/layotto/components/oss/aliyun"
 
+	ceph_oss "mosn.io/layotto/components/oss/ceph"
+
 	aliyun_file "mosn.io/layotto/components/file/aliyun"
 	"mosn.io/layotto/components/file/local"
 
@@ -304,6 +306,7 @@ func NewRuntimeGrpcServer(data json.RawMessage, opts ...grpc.ServerOption) (mgrp
 		runtime.WithOssFactory(
 			oss.NewFactory("aws.oss", aws_oss.NewAwsOss),
 			oss.NewFactory("aliyun.oss", aliyun_oss.NewAliyunOss),
+			oss.NewFactory("ceph.oss", ceph_oss.NewCephOss),
 		),
 
 		// PubSub

cmd/layotto_without_xds/main.go

@@ -31,6 +31,8 @@ import (
 
 	aliyun_oss "mosn.io/layotto/components/oss/aliyun"
 
+	ceph_oss "mosn.io/layotto/components/oss/ceph"
+
 	"mosn.io/layotto/components/file/aliyun"
 	aws_file "mosn.io/layotto/components/file/aws"
 	"mosn.io/layotto/components/file/minio"
@@ -408,6 +410,7 @@ func NewRuntimeGrpcServer(data json.RawMessage, opts ...grpc.ServerOption) (mgrp
 		runtime.WithOssFactory(
 			oss.NewFactory("aws.oss", aws_oss.NewAwsOss),
 			oss.NewFactory("aliyun.oss", aliyun_oss.NewAliyunOss),
+			oss.NewFactory("ceph.oss", ceph_oss.NewCephOss),
 		),
 
 		// Sequencer

components/oss/ceph/option.go

@@ -0,0 +1,43 @@
+/*
+* Copyright 2021 Layotto Authors
+*
+* Licensed under the Apache License, Version 2.0 (the "License");
+* you may not use this file except in compliance with the License.
+* You may obtain a copy of the License at
+*
+*     http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+ */
+
+package ceph
+
+import (
+	"time"
+
+	"github.com/jinzhu/copier"
+)
+
+var (
+	int642time = copier.TypeConverter{
+		SrcType: int64(0),
+		DstType: &time.Time{},
+		Fn: func(src interface{}) (interface{}, error) {
+			s, _ := src.(int64)
+			t := time.Unix(s, 0)
+			return &t, nil
+		},
+	}
+	time2int64 = copier.TypeConverter{
+		SrcType: &time.Time{},
+		DstType: int64(0),
+		Fn: func(src interface{}) (interface{}, error) {
+			s, _ := src.(*time.Time)
+			return s.Unix(), nil
+		},
+	}
+)

components/oss/ceph/option_test.go

@@ -0,0 +1,52 @@
+/*
+* Copyright 2021 Layotto Authors
+*
+* Licensed under the Apache License, Version 2.0 (the "License");
+* you may not use this file except in compliance with the License.
+* You may obtain a copy of the License at
+*
+*     http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+ */
+
+package ceph
+
+import (
+	"testing"
+	"time"
+
+	"github.com/stretchr/testify/assert"
+
+	"github.com/jinzhu/copier"
+)
+
+func TestCopierOption(t *testing.T) {
+	type ValueWithInt64 struct {
+		TestString      string
+		TestInt64toTime int64
+	}
+
+	type ValueWithTimer struct {
+		TestString      *string
+		TestInt64toTime *time.Time
+	}
+	timer := time.Now().Unix()
+	srcValue := &ValueWithInt64{TestInt64toTime: timer}
+	destValue := &ValueWithTimer{}
+	err := copier.CopyWithOption(destValue, srcValue, copier.Option{IgnoreEmpty: true, DeepCopy: true, Converters: []copier.TypeConverter{int642time}})
+	assert.Nil(t, err)
+	assert.Nil(t, destValue.TestString)
+	assert.Equal(t, timer, destValue.TestInt64toTime.Unix())
+
+	ti := time.Now()
+	src := &ValueWithTimer{TestInt64toTime: &ti}
+	dst := &ValueWithInt64{}
+	err = copier.CopyWithOption(dst, src, copier.Option{IgnoreEmpty: true, DeepCopy: true, Converters: []copier.TypeConverter{time2int64}})
+	assert.Nil(t, err)
+	assert.Equal(t, ti.Unix(), dst.TestInt64toTime)
+}