Merge branch 'main' into compilation_directive

cmd/layotto_multiple_api/helloworld/component/helloworld.go

@@ -1,4 +1,3 @@
-//
 // 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.

cmd/layotto_multiple_api/helloworld/component/in_memory.go

@@ -1,4 +1,3 @@
-//
 // 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.

cmd/layotto_multiple_api/helloworld/component/say_goodbye.go

@@ -1,4 +1,3 @@
-//
 // 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.

components/configstores/apollo/change_listener_test.go

@@ -61,7 +61,7 @@ func setupChangeListener() *changeListener {
 	return newChangeListener(mockRepo)
 }
 
-//Test modified
+// Test modified
 func Test_changeListener_OnChange(t *testing.T) {
 	lis := setupChangeListener()
 	ch := make(chan *configstores.SubscribeResp)

components/configstores/apollo/configstore.go

@@ -110,7 +110,7 @@ func newHttpClient() httpClient {
 	}
 }
 
-//Init SetConfig the configuration store.
+// Init SetConfig the configuration store.
 func (c *ConfigStore) Init(config *configstores.StoreConfig) error {
 	err := c.doInit(config)
 	if err != nil {
@@ -602,7 +602,7 @@ func (c *ConfigStore) initTagsClient(tagCfg *repoConfig) error {
 	return c.tagsRepo.Connect()
 }
 
-//refer to https://www.apolloconfig.com/#/zh/usage/apollo-open-api-platform?id=_327-%e5%88%9b%e5%bb%banamespace
+// refer to https://www.apolloconfig.com/#/zh/usage/apollo-open-api-platform?id=_327-%e5%88%9b%e5%bb%banamespace
 func (c *ConfigStore) createNamespace(env string, appId string, cluster string, namespace string) error {
 	// 1. request
 	url := fmt.Sprintf(createNamespaceUrlTpl, c.openAPIAddress, appId)

components/configstores/apollo/repository.go

@@ -52,7 +52,7 @@ func init() {
 	agollo.SetLogger(NewDefaultLogger(log.DefaultLogger))
 }
 
-//Implement Repository interface
+// Implement Repository interface
 type AgolloRepository struct {
 	client agollo.Client
 	cfg    *repoConfig

components/configstores/etcdv3/etcdv3.go

@@ -1,4 +1,3 @@
-//
 // 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.
@@ -60,7 +59,7 @@ func NewStore() configstores.Store {
 	return &EtcdV3ConfigStore{subscribeKey: make(map[string]string), watchRespCh: make(chan *configstores.SubscribeResp)}
 }
 
-//Init init the configuration store.
+// Init init the configuration store.
 func (c *EtcdV3ConfigStore) Init(config *configstores.StoreConfig) error {
 	t, err := strconv.Atoi(config.TimeOut)
 	if err != nil {

components/configstores/etcdv3/etcdv3_test.go

@@ -1,4 +1,3 @@
-//
 // 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.

components/custom/component.go

@@ -1,4 +1,3 @@
-//
 // 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.

components/custom/config.go

@@ -1,4 +1,3 @@
-//
 // 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.

components/custom/registry.go

@@ -1,4 +1,3 @@
-//
 // 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.

components/lock/consul/consul_lock.go

@@ -1,4 +1,3 @@
-//
 // 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.

components/lock/consul/consul_lock_test.go

@@ -1,4 +1,3 @@
-//
 // 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.
@@ -49,7 +48,7 @@ func TestConsulLock_Features(t *testing.T) {
 	assert.True(t, len(comp.Features()) == 0)
 }
 
-//A lock A unlock
+// A lock A unlock
 func TestConsulLock_TryLock(t *testing.T) {
 	//mock
 	ctrl := gomock.NewController(t)
@@ -94,7 +93,7 @@ func TestConsulLock_TryLock(t *testing.T) {
 
 }
 
-//A lock B lock
+// A lock B lock
 func TestConsulLock_ALock_BLock(t *testing.T) {
 
 	//mock

components/lock/etcd/etcd_lock.go

@@ -1,4 +1,3 @@
-//
 // 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.

components/lock/etcd/etcd_lock_test.go

@@ -1,4 +1,3 @@
-//
 // 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.

components/lock/lock_store.go

@@ -1,4 +1,3 @@
-//
 // 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.

components/lock/mongo/mongo_lock.go

@@ -1,4 +1,3 @@
-//
 // 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.

components/lock/mongo/mongo_lock_test.go

@@ -1,4 +1,3 @@
-//
 // 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.

components/lock/redis/cluster_redis_lock.go

@@ -1,4 +1,3 @@
-//
 // 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.
@@ -28,8 +27,8 @@ import (
 	"mosn.io/layotto/components/pkg/utils"
 )
 
-//RedLock
-//it will be best to use at least 5 hosts
+// RedLock
+// it will be best to use at least 5 hosts
 type ClusterRedisLock struct {
 	clients  []*redis.Client
 	metadata utils.RedisClusterMetadata

components/lock/redis/cluster_redis_lock_test.go

@@ -1,4 +1,3 @@
-//
 // 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.

components/lock/redis/standalone_redis_lock.go

@@ -1,4 +1,3 @@
-//
 // 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.

components/lock/redis/standalone_redis_lock_test.go

@@ -1,4 +1,3 @@
-//
 // 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.

components/lock/types.go

@@ -1,4 +1,3 @@
-//
 // 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.

components/lock/zookeeper/zookeeper_lock.go

@@ -43,7 +43,7 @@ type ZookeeperLock struct {
 	logger     log.ErrorLogger
 }
 
-//NewZookeeperLock Create ZookeeperLock
+// NewZookeeperLock Create ZookeeperLock
 func NewZookeeperLock(logger log.ErrorLogger) *ZookeeperLock {
 	lock := &ZookeeperLock{
 		logger: logger,
@@ -76,7 +76,7 @@ func (p *ZookeeperLock) Features() []lock.Feature {
 	return nil
 }
 
-//TryLock Node tries to acquire a zookeeper lock
+// TryLock Node tries to acquire a zookeeper lock
 func (p *ZookeeperLock) TryLock(req *lock.TryLockRequest) (*lock.TryLockResponse, error) {
 
 	conn, err := p.factory.NewConnection(time.Duration(req.Expire)*time.Second, p.metadata)
@@ -110,7 +110,7 @@ func (p *ZookeeperLock) TryLock(req *lock.TryLockRequest) (*lock.TryLockResponse
 
 }
 
-//Unlock Node tries to release a zookeeper lock
+// Unlock Node tries to release a zookeeper lock
 func (p *ZookeeperLock) Unlock(req *lock.UnlockRequest) (*lock.UnlockResponse, error) {
 
 	conn := p.unlockConn

components/oss/aliyun/oss.go

@@ -560,7 +560,7 @@ func (a *AliyunOSS) SignURL(ctx context.Context, req *l8oss.SignURLInput) (*l8os
 	return &l8oss.SignURLOutput{SignedUrl: resp}, err
 }
 
-//UpdateDownloadBandwidthRateLimit update all client rate
+// UpdateDownloadBandwidthRateLimit update all client rate
 func (a *AliyunOSS) UpdateDownloadBandwidthRateLimit(ctx context.Context, req *l8oss.UpdateBandwidthRateLimitInput) error {
 	cli, err := a.getClient()
 	if err != nil {
@@ -570,7 +570,7 @@ func (a *AliyunOSS) UpdateDownloadBandwidthRateLimit(ctx context.Context, req *l
 	return err
 }
 
-//UpdateUploadBandwidthRateLimit update all client rate
+// UpdateUploadBandwidthRateLimit update all client rate
 func (a *AliyunOSS) UpdateUploadBandwidthRateLimit(ctx context.Context, req *l8oss.UpdateBandwidthRateLimitInput) error {
 	cli, err := a.getClient()
 	if err != nil {

components/pkg/actuators/actutors_test.go

@@ -1,4 +1,3 @@
-//
 // 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.

components/pkg/common/error.go

@@ -1,4 +1,3 @@
-//
 // 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.

components/pkg/mock/custom_component_mock.go

@@ -1,4 +1,3 @@
-//
 // 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.

components/pkg/mock/mongo_lock_mock.go

@@ -1,4 +1,3 @@
-//
 // 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.

components/pkg/mock/mongo_sequencer_mock.go

@@ -1,4 +1,3 @@
-//
 // 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.

components/pkg/utils/consul.go

@@ -1,4 +1,3 @@
-//
 // 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.

components/pkg/utils/etcd.go

@@ -1,4 +1,3 @@
-//
 // 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.

components/pkg/utils/mongo.go

@@ -1,4 +1,3 @@
-//
 // 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.

components/pkg/utils/mysql.go

@@ -1,4 +1,3 @@
-//
 // 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.

components/pkg/utils/oss.go

@@ -1,4 +1,3 @@
-//
 // 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.

components/pkg/utils/redis.go

@@ -1,4 +1,3 @@
-//
 // 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.

components/pkg/utils/zookeeper.go

@@ -1,4 +1,3 @@
-//
 // 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.

components/pubsub/types.go

@@ -10,7 +10,6 @@
 // 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 pubsub
 
 const (

components/ref/config.go

@@ -16,7 +16,7 @@
 
 package ref
 
-//Config is ref json config
+// Config is ref json config
 type Config struct {
 	SecretRef []*Item `json:"secret_ref"`
 }

components/rpc/invoker/mosn/transport_protocol/bolt_test.go

@@ -1,4 +1,3 @@
-//
 // 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.

components/sequencer/etcd/store.go

@@ -1,4 +1,3 @@
-//
 // 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.

components/sequencer/etcd/store_test.go

@@ -1,4 +1,3 @@
-//
 // 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.

components/sequencer/mongo/mongo_sequencer.go

@@ -1,4 +1,3 @@
-//
 // 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.

components/sequencer/mongo/mongo_sequencer_test.go

@@ -1,4 +1,3 @@
-//
 // 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.

components/sequencer/mysql/mysql.go

@@ -1,4 +1,3 @@
-//
 // 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.

components/sequencer/mysql/mysql_test.go

@@ -1,4 +1,3 @@
-//
 // 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.

components/sequencer/redis/standalone_redis_sequencer.go

@@ -1,4 +1,3 @@
-//
 // 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.
@@ -43,9 +42,9 @@ func NewStandaloneRedisSequencer(logger log.ErrorLogger) *StandaloneRedisSequenc
 }
 
 /*
-   1. exists and >= biggerThan, no operation required, return 0
-   2. not exists or < biggthan, reset val, return 1
-   3. lua script occur error, such as tonumer(string), return error
+1. exists and >= biggerThan, no operation required, return 0
+2. not exists or < biggthan, reset val, return 1
+3. lua script occur error, such as tonumer(string), return error
 */
 const initScript = `
 if  redis.call('exists', KEYS[1])==1 and tonumber(redis.call('get', KEYS[1])) >= tonumber(ARGV[1]) then

components/sequencer/redis/standalone_redis_sequencer_test.go

@@ -1,4 +1,3 @@
-//
 // 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.

components/sequencer/store.go

@@ -1,4 +1,3 @@
-//
 // 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.

components/sequencer/zookeeper/zookeeper_sequencer.go

@@ -1,4 +1,3 @@
-//
 // 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.

components/sequencer/zookeeper/zookeeper_sequencer_test.go

@@ -1,4 +1,3 @@
-//
 // 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.

components/trace/export.go

@@ -1,4 +1,3 @@
-//
 // 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.
@@ -17,7 +16,7 @@ import (
 	"sync"
 )
 
-//Exporter  is used to export Span
+// Exporter  is used to export Span
 type Exporter interface {
 	ExportSpan(s *Span)
 }

components/trace/export_test.go

@@ -1,4 +1,3 @@
-//
 // 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.

components/trace/generator.go

@@ -27,7 +27,7 @@ var (
 	generators sync.Map
 )
 
-//Generator  is used to get or generate traceId/spanId/context
+// Generator  is used to get or generate traceId/spanId/context
 type Generator interface {
 	GetTraceId(ctx context.Context) string
 	GetSpanId(ctx context.Context) string