aboutsummaryrefslogtreecommitdiff
path: root/weed/replication
diff options
context:
space:
mode:
authorj.laycock <joseph.laycock@4sightimaging.com>2019-09-12 14:18:21 +0100
committerj.laycock <joseph.laycock@4sightimaging.com>2019-09-12 14:18:21 +0100
commit6fc6322c904eeca4d7e73258cd99c04f65aa5eba (patch)
treef68de8f0009f7319fec5d3a51d6549087e7d496b /weed/replication
parentd8c34b032fb6dbfb89359da6e5e002429ad42fc2 (diff)
downloadseaweedfs-6fc6322c904eeca4d7e73258cd99c04f65aa5eba.tar.xz
seaweedfs-6fc6322c904eeca4d7e73258cd99c04f65aa5eba.zip
Change joeslay paths to chrislusf paths
Diffstat (limited to 'weed/replication')
-rw-r--r--weed/replication/replicator.go10
-rw-r--r--weed/replication/sink/azuresink/azure_sink.go12
-rw-r--r--weed/replication/sink/b2sink/b2_sink.go10
-rw-r--r--weed/replication/sink/filersink/fetch_write.go10
-rw-r--r--weed/replication/sink/filersink/filer_sink.go14
-rw-r--r--weed/replication/sink/gcssink/gcs_sink.go12
-rw-r--r--weed/replication/sink/replication_sink.go6
-rw-r--r--weed/replication/sink/s3sink/s3_sink.go12
-rw-r--r--weed/replication/sink/s3sink/s3_write.go8
-rw-r--r--weed/replication/source/filer_source.go8
-rw-r--r--weed/replication/sub/notification_aws_sqs.go6
-rw-r--r--weed/replication/sub/notification_gocdk_pub_sub.go6
-rw-r--r--weed/replication/sub/notification_google_pub_sub.go6
-rw-r--r--weed/replication/sub/notification_kafka.go6
-rw-r--r--weed/replication/sub/notifications.go4
15 files changed, 65 insertions, 65 deletions
diff --git a/weed/replication/replicator.go b/weed/replication/replicator.go
index 1b868defc..7353cdc91 100644
--- a/weed/replication/replicator.go
+++ b/weed/replication/replicator.go
@@ -6,11 +6,11 @@ import (
"path/filepath"
"strings"
- "github.com/joeslay/seaweedfs/weed/glog"
- "github.com/joeslay/seaweedfs/weed/pb/filer_pb"
- "github.com/joeslay/seaweedfs/weed/replication/sink"
- "github.com/joeslay/seaweedfs/weed/replication/source"
- "github.com/joeslay/seaweedfs/weed/util"
+ "github.com/chrislusf/seaweedfs/weed/glog"
+ "github.com/chrislusf/seaweedfs/weed/pb/filer_pb"
+ "github.com/chrislusf/seaweedfs/weed/replication/sink"
+ "github.com/chrislusf/seaweedfs/weed/replication/source"
+ "github.com/chrislusf/seaweedfs/weed/util"
)
type Replicator struct {
diff --git a/weed/replication/sink/azuresink/azure_sink.go b/weed/replication/sink/azuresink/azure_sink.go
index c64d3c4f1..6381908a1 100644
--- a/weed/replication/sink/azuresink/azure_sink.go
+++ b/weed/replication/sink/azuresink/azure_sink.go
@@ -8,12 +8,12 @@ import (
"strings"
"github.com/Azure/azure-storage-blob-go/azblob"
- "github.com/joeslay/seaweedfs/weed/filer2"
- "github.com/joeslay/seaweedfs/weed/glog"
- "github.com/joeslay/seaweedfs/weed/pb/filer_pb"
- "github.com/joeslay/seaweedfs/weed/replication/sink"
- "github.com/joeslay/seaweedfs/weed/replication/source"
- "github.com/joeslay/seaweedfs/weed/util"
+ "github.com/chrislusf/seaweedfs/weed/filer2"
+ "github.com/chrislusf/seaweedfs/weed/glog"
+ "github.com/chrislusf/seaweedfs/weed/pb/filer_pb"
+ "github.com/chrislusf/seaweedfs/weed/replication/sink"
+ "github.com/chrislusf/seaweedfs/weed/replication/source"
+ "github.com/chrislusf/seaweedfs/weed/util"
)
type AzureSink struct {
diff --git a/weed/replication/sink/b2sink/b2_sink.go b/weed/replication/sink/b2sink/b2_sink.go
index 14cc0b12f..35c2230fa 100644
--- a/weed/replication/sink/b2sink/b2_sink.go
+++ b/weed/replication/sink/b2sink/b2_sink.go
@@ -4,11 +4,11 @@ import (
"context"
"strings"
- "github.com/joeslay/seaweedfs/weed/filer2"
- "github.com/joeslay/seaweedfs/weed/pb/filer_pb"
- "github.com/joeslay/seaweedfs/weed/replication/sink"
- "github.com/joeslay/seaweedfs/weed/replication/source"
- "github.com/joeslay/seaweedfs/weed/util"
+ "github.com/chrislusf/seaweedfs/weed/filer2"
+ "github.com/chrislusf/seaweedfs/weed/pb/filer_pb"
+ "github.com/chrislusf/seaweedfs/weed/replication/sink"
+ "github.com/chrislusf/seaweedfs/weed/replication/source"
+ "github.com/chrislusf/seaweedfs/weed/util"
"github.com/kurin/blazer/b2"
)
diff --git a/weed/replication/sink/filersink/fetch_write.go b/weed/replication/sink/filersink/fetch_write.go
index c167707c0..97e9671a3 100644
--- a/weed/replication/sink/filersink/fetch_write.go
+++ b/weed/replication/sink/filersink/fetch_write.go
@@ -7,11 +7,11 @@ import (
"strings"
"sync"
- "github.com/joeslay/seaweedfs/weed/glog"
- "github.com/joeslay/seaweedfs/weed/operation"
- "github.com/joeslay/seaweedfs/weed/pb/filer_pb"
- "github.com/joeslay/seaweedfs/weed/security"
- "github.com/joeslay/seaweedfs/weed/util"
+ "github.com/chrislusf/seaweedfs/weed/glog"
+ "github.com/chrislusf/seaweedfs/weed/operation"
+ "github.com/chrislusf/seaweedfs/weed/pb/filer_pb"
+ "github.com/chrislusf/seaweedfs/weed/security"
+ "github.com/chrislusf/seaweedfs/weed/util"
)
func (fs *FilerSink) replicateChunks(ctx context.Context, sourceChunks []*filer_pb.FileChunk) (replicatedChunks []*filer_pb.FileChunk, err error) {
diff --git a/weed/replication/sink/filersink/filer_sink.go b/weed/replication/sink/filersink/filer_sink.go
index ce88ba63a..f99c7fdf6 100644
--- a/weed/replication/sink/filersink/filer_sink.go
+++ b/weed/replication/sink/filersink/filer_sink.go
@@ -3,16 +3,16 @@ package filersink
import (
"context"
"fmt"
- "github.com/joeslay/seaweedfs/weed/security"
+ "github.com/chrislusf/seaweedfs/weed/security"
"github.com/spf13/viper"
"google.golang.org/grpc"
- "github.com/joeslay/seaweedfs/weed/filer2"
- "github.com/joeslay/seaweedfs/weed/glog"
- "github.com/joeslay/seaweedfs/weed/pb/filer_pb"
- "github.com/joeslay/seaweedfs/weed/replication/sink"
- "github.com/joeslay/seaweedfs/weed/replication/source"
- "github.com/joeslay/seaweedfs/weed/util"
+ "github.com/chrislusf/seaweedfs/weed/filer2"
+ "github.com/chrislusf/seaweedfs/weed/glog"
+ "github.com/chrislusf/seaweedfs/weed/pb/filer_pb"
+ "github.com/chrislusf/seaweedfs/weed/replication/sink"
+ "github.com/chrislusf/seaweedfs/weed/replication/source"
+ "github.com/chrislusf/seaweedfs/weed/util"
)
type FilerSink struct {
diff --git a/weed/replication/sink/gcssink/gcs_sink.go b/weed/replication/sink/gcssink/gcs_sink.go
index 48bdea3a9..abd7c49b9 100644
--- a/weed/replication/sink/gcssink/gcs_sink.go
+++ b/weed/replication/sink/gcssink/gcs_sink.go
@@ -6,12 +6,12 @@ import (
"os"
"cloud.google.com/go/storage"
- "github.com/joeslay/seaweedfs/weed/filer2"
- "github.com/joeslay/seaweedfs/weed/glog"
- "github.com/joeslay/seaweedfs/weed/pb/filer_pb"
- "github.com/joeslay/seaweedfs/weed/replication/sink"
- "github.com/joeslay/seaweedfs/weed/replication/source"
- "github.com/joeslay/seaweedfs/weed/util"
+ "github.com/chrislusf/seaweedfs/weed/filer2"
+ "github.com/chrislusf/seaweedfs/weed/glog"
+ "github.com/chrislusf/seaweedfs/weed/pb/filer_pb"
+ "github.com/chrislusf/seaweedfs/weed/replication/sink"
+ "github.com/chrislusf/seaweedfs/weed/replication/source"
+ "github.com/chrislusf/seaweedfs/weed/util"
"google.golang.org/api/option"
)
diff --git a/weed/replication/sink/replication_sink.go b/weed/replication/sink/replication_sink.go
index fcf604c79..dd54f0005 100644
--- a/weed/replication/sink/replication_sink.go
+++ b/weed/replication/sink/replication_sink.go
@@ -2,9 +2,9 @@ package sink
import (
"context"
- "github.com/joeslay/seaweedfs/weed/pb/filer_pb"
- "github.com/joeslay/seaweedfs/weed/replication/source"
- "github.com/joeslay/seaweedfs/weed/util"
+ "github.com/chrislusf/seaweedfs/weed/pb/filer_pb"
+ "github.com/chrislusf/seaweedfs/weed/replication/source"
+ "github.com/chrislusf/seaweedfs/weed/util"
)
type ReplicationSink interface {
diff --git a/weed/replication/sink/s3sink/s3_sink.go b/weed/replication/sink/s3sink/s3_sink.go
index 80a898239..d5cad3541 100644
--- a/weed/replication/sink/s3sink/s3_sink.go
+++ b/weed/replication/sink/s3sink/s3_sink.go
@@ -11,12 +11,12 @@ import (
"github.com/aws/aws-sdk-go/aws/session"
"github.com/aws/aws-sdk-go/service/s3"
"github.com/aws/aws-sdk-go/service/s3/s3iface"
- "github.com/joeslay/seaweedfs/weed/filer2"
- "github.com/joeslay/seaweedfs/weed/glog"
- "github.com/joeslay/seaweedfs/weed/pb/filer_pb"
- "github.com/joeslay/seaweedfs/weed/replication/sink"
- "github.com/joeslay/seaweedfs/weed/replication/source"
- "github.com/joeslay/seaweedfs/weed/util"
+ "github.com/chrislusf/seaweedfs/weed/filer2"
+ "github.com/chrislusf/seaweedfs/weed/glog"
+ "github.com/chrislusf/seaweedfs/weed/pb/filer_pb"
+ "github.com/chrislusf/seaweedfs/weed/replication/sink"
+ "github.com/chrislusf/seaweedfs/weed/replication/source"
+ "github.com/chrislusf/seaweedfs/weed/util"
)
type S3Sink struct {
diff --git a/weed/replication/sink/s3sink/s3_write.go b/weed/replication/sink/s3sink/s3_write.go
index 80a54d1e8..0a190b27d 100644
--- a/weed/replication/sink/s3sink/s3_write.go
+++ b/weed/replication/sink/s3sink/s3_write.go
@@ -9,10 +9,10 @@ import (
"github.com/aws/aws-sdk-go/aws"
"github.com/aws/aws-sdk-go/aws/awserr"
"github.com/aws/aws-sdk-go/service/s3"
- "github.com/joeslay/seaweedfs/weed/filer2"
- "github.com/joeslay/seaweedfs/weed/glog"
- "github.com/joeslay/seaweedfs/weed/pb/filer_pb"
- "github.com/joeslay/seaweedfs/weed/util"
+ "github.com/chrislusf/seaweedfs/weed/filer2"
+ "github.com/chrislusf/seaweedfs/weed/glog"
+ "github.com/chrislusf/seaweedfs/weed/pb/filer_pb"
+ "github.com/chrislusf/seaweedfs/weed/util"
)
func (s3sink *S3Sink) deleteObject(key string) error {
diff --git a/weed/replication/source/filer_source.go b/weed/replication/source/filer_source.go
index 27729acaf..d7b5ebc4d 100644
--- a/weed/replication/source/filer_source.go
+++ b/weed/replication/source/filer_source.go
@@ -3,16 +3,16 @@ package source
import (
"context"
"fmt"
- "github.com/joeslay/seaweedfs/weed/security"
+ "github.com/chrislusf/seaweedfs/weed/security"
"github.com/spf13/viper"
"google.golang.org/grpc"
"io"
"net/http"
"strings"
- "github.com/joeslay/seaweedfs/weed/glog"
- "github.com/joeslay/seaweedfs/weed/pb/filer_pb"
- "github.com/joeslay/seaweedfs/weed/util"
+ "github.com/chrislusf/seaweedfs/weed/glog"
+ "github.com/chrislusf/seaweedfs/weed/pb/filer_pb"
+ "github.com/chrislusf/seaweedfs/weed/util"
)
type ReplicationSource interface {
diff --git a/weed/replication/sub/notification_aws_sqs.go b/weed/replication/sub/notification_aws_sqs.go
index 5f5d79de9..f0100f4de 100644
--- a/weed/replication/sub/notification_aws_sqs.go
+++ b/weed/replication/sub/notification_aws_sqs.go
@@ -8,9 +8,9 @@ import (
"github.com/aws/aws-sdk-go/aws/credentials"
"github.com/aws/aws-sdk-go/aws/session"
"github.com/aws/aws-sdk-go/service/sqs"
- "github.com/joeslay/seaweedfs/weed/glog"
- "github.com/joeslay/seaweedfs/weed/pb/filer_pb"
- "github.com/joeslay/seaweedfs/weed/util"
+ "github.com/chrislusf/seaweedfs/weed/glog"
+ "github.com/chrislusf/seaweedfs/weed/pb/filer_pb"
+ "github.com/chrislusf/seaweedfs/weed/util"
"github.com/golang/protobuf/proto"
)
diff --git a/weed/replication/sub/notification_gocdk_pub_sub.go b/weed/replication/sub/notification_gocdk_pub_sub.go
index 96516ea71..eddba9ff8 100644
--- a/weed/replication/sub/notification_gocdk_pub_sub.go
+++ b/weed/replication/sub/notification_gocdk_pub_sub.go
@@ -3,9 +3,9 @@ package sub
import (
"context"
- "github.com/joeslay/seaweedfs/weed/glog"
- "github.com/joeslay/seaweedfs/weed/pb/filer_pb"
- "github.com/joeslay/seaweedfs/weed/util"
+ "github.com/chrislusf/seaweedfs/weed/glog"
+ "github.com/chrislusf/seaweedfs/weed/pb/filer_pb"
+ "github.com/chrislusf/seaweedfs/weed/util"
"github.com/golang/protobuf/proto"
"gocloud.dev/pubsub"
_ "gocloud.dev/pubsub/awssnssqs"
diff --git a/weed/replication/sub/notification_google_pub_sub.go b/weed/replication/sub/notification_google_pub_sub.go
index a3d9f43f0..ad6b42a2e 100644
--- a/weed/replication/sub/notification_google_pub_sub.go
+++ b/weed/replication/sub/notification_google_pub_sub.go
@@ -6,9 +6,9 @@ import (
"os"
"cloud.google.com/go/pubsub"
- "github.com/joeslay/seaweedfs/weed/glog"
- "github.com/joeslay/seaweedfs/weed/pb/filer_pb"
- "github.com/joeslay/seaweedfs/weed/util"
+ "github.com/chrislusf/seaweedfs/weed/glog"
+ "github.com/chrislusf/seaweedfs/weed/pb/filer_pb"
+ "github.com/chrislusf/seaweedfs/weed/util"
"github.com/golang/protobuf/proto"
"google.golang.org/api/option"
)
diff --git a/weed/replication/sub/notification_kafka.go b/weed/replication/sub/notification_kafka.go
index dbf1fd130..1a86a8307 100644
--- a/weed/replication/sub/notification_kafka.go
+++ b/weed/replication/sub/notification_kafka.go
@@ -8,9 +8,9 @@ import (
"time"
"github.com/Shopify/sarama"
- "github.com/joeslay/seaweedfs/weed/glog"
- "github.com/joeslay/seaweedfs/weed/pb/filer_pb"
- "github.com/joeslay/seaweedfs/weed/util"
+ "github.com/chrislusf/seaweedfs/weed/glog"
+ "github.com/chrislusf/seaweedfs/weed/pb/filer_pb"
+ "github.com/chrislusf/seaweedfs/weed/util"
"github.com/golang/protobuf/proto"
)
diff --git a/weed/replication/sub/notifications.go b/weed/replication/sub/notifications.go
index 106812b37..66fbef824 100644
--- a/weed/replication/sub/notifications.go
+++ b/weed/replication/sub/notifications.go
@@ -1,8 +1,8 @@
package sub
import (
- "github.com/joeslay/seaweedfs/weed/pb/filer_pb"
- "github.com/joeslay/seaweedfs/weed/util"
+ "github.com/chrislusf/seaweedfs/weed/pb/filer_pb"
+ "github.com/chrislusf/seaweedfs/weed/util"
)
type NotificationInput interface {