aboutsummaryrefslogtreecommitdiff
path: root/weed/notification
diff options
context:
space:
mode:
Diffstat (limited to 'weed/notification')
-rw-r--r--weed/notification/aws_sqs/aws_sqs_pub.go2
-rw-r--r--weed/notification/configuration.go2
-rw-r--r--weed/notification/gocdk_pub_sub/gocdk_pub_sub.go2
-rw-r--r--weed/notification/google_pub_sub/google_pub_sub.go2
-rw-r--r--weed/notification/kafka/kafka_queue.go2
-rw-r--r--weed/notification/log/log_queue.go2
6 files changed, 6 insertions, 6 deletions
diff --git a/weed/notification/aws_sqs/aws_sqs_pub.go b/weed/notification/aws_sqs/aws_sqs_pub.go
index 36b883544..f647134c7 100644
--- a/weed/notification/aws_sqs/aws_sqs_pub.go
+++ b/weed/notification/aws_sqs/aws_sqs_pub.go
@@ -8,10 +8,10 @@ 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/golang/protobuf/proto"
"github.com/seaweedfs/seaweedfs/weed/glog"
"github.com/seaweedfs/seaweedfs/weed/notification"
"github.com/seaweedfs/seaweedfs/weed/util"
+ "google.golang.org/protobuf/proto"
)
func init() {
diff --git a/weed/notification/configuration.go b/weed/notification/configuration.go
index 497b2a74b..1c620f2e6 100644
--- a/weed/notification/configuration.go
+++ b/weed/notification/configuration.go
@@ -1,9 +1,9 @@
package notification
import (
- "github.com/golang/protobuf/proto"
"github.com/seaweedfs/seaweedfs/weed/glog"
"github.com/seaweedfs/seaweedfs/weed/util"
+ "google.golang.org/protobuf/proto"
)
type MessageQueue interface {
diff --git a/weed/notification/gocdk_pub_sub/gocdk_pub_sub.go b/weed/notification/gocdk_pub_sub/gocdk_pub_sub.go
index dfe2ff061..58ee43767 100644
--- a/weed/notification/gocdk_pub_sub/gocdk_pub_sub.go
+++ b/weed/notification/gocdk_pub_sub/gocdk_pub_sub.go
@@ -20,11 +20,11 @@ package gocdk_pub_sub
import (
"context"
"fmt"
- "github.com/golang/protobuf/proto"
"github.com/streadway/amqp"
"gocloud.dev/pubsub"
_ "gocloud.dev/pubsub/awssnssqs"
"gocloud.dev/pubsub/rabbitpubsub"
+ "google.golang.org/protobuf/proto"
"net/url"
"path"
"time"
diff --git a/weed/notification/google_pub_sub/google_pub_sub.go b/weed/notification/google_pub_sub/google_pub_sub.go
index 0b6ec2dba..f5593fa48 100644
--- a/weed/notification/google_pub_sub/google_pub_sub.go
+++ b/weed/notification/google_pub_sub/google_pub_sub.go
@@ -6,11 +6,11 @@ import (
"os"
"cloud.google.com/go/pubsub"
- "github.com/golang/protobuf/proto"
"github.com/seaweedfs/seaweedfs/weed/glog"
"github.com/seaweedfs/seaweedfs/weed/notification"
"github.com/seaweedfs/seaweedfs/weed/util"
"google.golang.org/api/option"
+ "google.golang.org/protobuf/proto"
)
func init() {
diff --git a/weed/notification/kafka/kafka_queue.go b/weed/notification/kafka/kafka_queue.go
index 4d4616e38..64cb4eaa9 100644
--- a/weed/notification/kafka/kafka_queue.go
+++ b/weed/notification/kafka/kafka_queue.go
@@ -2,10 +2,10 @@ package kafka
import (
"github.com/Shopify/sarama"
- "github.com/golang/protobuf/proto"
"github.com/seaweedfs/seaweedfs/weed/glog"
"github.com/seaweedfs/seaweedfs/weed/notification"
"github.com/seaweedfs/seaweedfs/weed/util"
+ "google.golang.org/protobuf/proto"
)
func init() {
diff --git a/weed/notification/log/log_queue.go b/weed/notification/log/log_queue.go
index 60d586106..cc3557fee 100644
--- a/weed/notification/log/log_queue.go
+++ b/weed/notification/log/log_queue.go
@@ -1,10 +1,10 @@
package kafka
import (
- "github.com/golang/protobuf/proto"
"github.com/seaweedfs/seaweedfs/weed/glog"
"github.com/seaweedfs/seaweedfs/weed/notification"
"github.com/seaweedfs/seaweedfs/weed/util"
+ "google.golang.org/protobuf/proto"
)
func init() {