bingyi/gf
1
0
Fork 0
mirror of https://gitee.com/johng/gf synced 2026-06-27 01:43:33 +08:00
Code Issues Packages Projects Releases Wiki Activity

change gitee.com/johng/gf -> github.com/gogf/gf

Browse Source
This commit is contained in:
John
2019-02-02 16:18:25 +08:00
parent 150aa7e2c2
commit 76c49170bd
706 changed files with 1697 additions and 1697 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
third/github.com/Shopify/sarama/async_producer.go
View File

@ -6,8 +6,8 @@ import (
"sync"
"time"
"gitee.com/johng/gf/third/github.com/eapache/go-resiliency/breaker"
"gitee.com/johng/gf/third/github.com/eapache/queue"
"github.com/gogf/gf/third/github.com/eapache/go-resiliency/breaker"
"github.com/gogf/gf/third/github.com/eapache/queue"
)
// AsyncProducer publishes Kafka messages using a non-blocking API. It routes messages

2
third/github.com/Shopify/sarama/broker.go
View File

@ -11,7 +11,7 @@ import (
"sync/atomic"
"time"
"gitee.com/johng/gf/third/github.com/rcrowley/go-metrics"
"github.com/gogf/gf/third/github.com/rcrowley/go-metrics"
)
// Broker represents a single Kafka broker connection. All operations on this object are entirely concurrency-safe.

4
third/github.com/Shopify/sarama/compress.go
View File

@ -6,8 +6,8 @@ import (
"fmt"
"sync"
"gitee.com/johng/gf/third/github.com/eapache/go-xerial-snappy"
"gitee.com/johng/gf/third/github.com/pierrec/lz4"
"github.com/gogf/gf/third/github.com/eapache/go-xerial-snappy"
"github.com/gogf/gf/third/github.com/pierrec/lz4"
)
var (

2
third/github.com/Shopify/sarama/config.go
View File

@ -9,7 +9,7 @@ import (
"regexp"
"time"
"gitee.com/johng/gf/third/github.com/rcrowley/go-metrics"
"github.com/gogf/gf/third/github.com/rcrowley/go-metrics"
)
const defaultClientID = "sarama"

2
third/github.com/Shopify/sarama/config_test.go
View File

@ -4,7 +4,7 @@ import (
"os"
"testing"
"gitee.com/johng/gf/third/github.com/rcrowley/go-metrics"
"github.com/gogf/gf/third/github.com/rcrowley/go-metrics"
)
func TestDefaultConfigValidates(t *testing.T) {

4
third/github.com/Shopify/sarama/decompress.go
View File

@ -7,8 +7,8 @@ import (
"io/ioutil"
"sync"
"gitee.com/johng/gf/third/github.com/eapache/go-xerial-snappy"
"gitee.com/johng/gf/third/github.com/pierrec/lz4"
"github.com/gogf/gf/third/github.com/eapache/go-xerial-snappy"
"github.com/gogf/gf/third/github.com/pierrec/lz4"
)
var (

2
third/github.com/Shopify/sarama/encoder_decoder.go
View File

@ -3,7 +3,7 @@ package sarama
import (
"fmt"
"gitee.com/johng/gf/third/github.com/rcrowley/go-metrics"
"github.com/gogf/gf/third/github.com/rcrowley/go-metrics"
)
// Encoder is the interface that wraps the basic Encode method.

4
third/github.com/Shopify/sarama/functional_producer_test.go
View File

@ -7,8 +7,8 @@ import (
"testing"
"time"
toxiproxy "gitee.com/johng/gf/third/github.com/Shopify/toxiproxy/client"
"gitee.com/johng/gf/third/github.com/rcrowley/go-metrics"
toxiproxy "github.com/gogf/gf/third/github.com/Shopify/toxiproxy/client"
"github.com/gogf/gf/third/github.com/rcrowley/go-metrics"
)
const TestBatchSize = 1000

2
third/github.com/Shopify/sarama/functional_test.go
View File

@ -10,7 +10,7 @@ import (
"testing"
"time"
toxiproxy "gitee.com/johng/gf/third/github.com/Shopify/toxiproxy/client"
toxiproxy "github.com/gogf/gf/third/github.com/Shopify/toxiproxy/client"
)
const (

2
third/github.com/Shopify/sarama/metrics.go
View File

@ -4,7 +4,7 @@ import (
"fmt"
"strings"
"gitee.com/johng/gf/third/github.com/rcrowley/go-metrics"
"github.com/gogf/gf/third/github.com/rcrowley/go-metrics"
)
// Use exponentially decaying reservoir for sampling histograms with the same defaults as the Java library:

2
third/github.com/Shopify/sarama/metrics_test.go
View File

@ -3,7 +3,7 @@ package sarama
import (
"testing"
"gitee.com/johng/gf/third/github.com/rcrowley/go-metrics"
"github.com/gogf/gf/third/github.com/rcrowley/go-metrics"
)
func TestGetOrRegisterHistogram(t *testing.T) {

2
third/github.com/Shopify/sarama/mockbroker.go
View File

@ -11,7 +11,7 @@ import (
"sync"
"time"
"gitee.com/johng/gf/third/github.com/davecgh/go-spew/spew"
"github.com/gogf/gf/third/github.com/davecgh/go-spew/spew"
)
const (

2
third/github.com/Shopify/sarama/mocks/async_producer.go
View File

@ -3,7 +3,7 @@ package mocks
import (
"sync"
"gitee.com/johng/gf/third/github.com/Shopify/sarama"
"github.com/gogf/gf/third/github.com/Shopify/sarama"
)
// AsyncProducer implements sarama's Producer interface for testing purposes.

2
third/github.com/Shopify/sarama/mocks/async_producer_test.go
View File

@ -7,7 +7,7 @@ import (
"strings"
"testing"
"gitee.com/johng/gf/third/github.com/Shopify/sarama"
"github.com/gogf/gf/third/github.com/Shopify/sarama"
)
func generateRegexpChecker(re string) func([]byte) error {

2
third/github.com/Shopify/sarama/mocks/consumer.go
View File

@ -4,7 +4,7 @@ import (
"sync"
"sync/atomic"
"gitee.com/johng/gf/third/github.com/Shopify/sarama"
"github.com/gogf/gf/third/github.com/Shopify/sarama"
)
// Consumer implements sarama's Consumer interface for testing purposes.

2
third/github.com/Shopify/sarama/mocks/consumer_test.go
View File

@ -4,7 +4,7 @@ import (
"sort"
"testing"
"gitee.com/johng/gf/third/github.com/Shopify/sarama"
"github.com/gogf/gf/third/github.com/Shopify/sarama"
)
func TestMockConsumerImplementsConsumerInterface(t *testing.T) {

2
third/github.com/Shopify/sarama/mocks/mocks.go
View File

@ -16,7 +16,7 @@ package mocks
import (
"errors"
"gitee.com/johng/gf/third/github.com/Shopify/sarama"
"github.com/gogf/gf/third/github.com/Shopify/sarama"
)
// ErrorReporter is a simple interface that includes the testing.T methods we use to report

2
third/github.com/Shopify/sarama/mocks/sync_producer.go
View File

@ -3,7 +3,7 @@ package mocks
import (
"sync"
"gitee.com/johng/gf/third/github.com/Shopify/sarama"
"github.com/gogf/gf/third/github.com/Shopify/sarama"
)
// SyncProducer implements sarama's SyncProducer interface for testing purposes.

2
third/github.com/Shopify/sarama/mocks/sync_producer_test.go
View File

@ -5,7 +5,7 @@ import (
"strings"
"testing"
"gitee.com/johng/gf/third/github.com/Shopify/sarama"
"github.com/gogf/gf/third/github.com/Shopify/sarama"
)
func TestMockSyncProducerImplementsSyncProducerInterface(t *testing.T) {

2
third/github.com/Shopify/sarama/packet_encoder.go
View File

@ -1,6 +1,6 @@
package sarama
import "gitee.com/johng/gf/third/github.com/rcrowley/go-metrics"
import "github.com/gogf/gf/third/github.com/rcrowley/go-metrics"
// PacketEncoder is the interface providing helpers for writing with Kafka's encoding rules.
// Types implementing Encoder only need to worry about calling methods like PutString,

2
third/github.com/Shopify/sarama/prep_encoder.go
View File

@ -5,7 +5,7 @@ import (
"fmt"
"math"
"gitee.com/johng/gf/third/github.com/rcrowley/go-metrics"
"github.com/gogf/gf/third/github.com/rcrowley/go-metrics"
)
type prepEncoder struct {

2
third/github.com/Shopify/sarama/produce_request.go
View File

@ -1,6 +1,6 @@
package sarama
import "gitee.com/johng/gf/third/github.com/rcrowley/go-metrics"
import "github.com/gogf/gf/third/github.com/rcrowley/go-metrics"
// RequiredAcks is used in Produce Requests to tell the broker how many replica acknowledgements
// it must see before responding. Any of the constants defined here are valid. On broker versions

2
third/github.com/Shopify/sarama/real_encoder.go
View File

@ -3,7 +3,7 @@ package sarama
import (
"encoding/binary"
"gitee.com/johng/gf/third/github.com/rcrowley/go-metrics"
"github.com/gogf/gf/third/github.com/rcrowley/go-metrics"
)
type realEncoder struct {

2
third/github.com/Shopify/sarama/record_test.go
View File

@ -8,7 +8,7 @@ import (
"testing"
"time"
"gitee.com/johng/gf/third/github.com/davecgh/go-spew/spew"
"github.com/gogf/gf/third/github.com/davecgh/go-spew/spew"
)
var recordBatchTestCases = []struct {

2
third/github.com/Shopify/sarama/request_test.go
View File

@ -5,7 +5,7 @@ import (
"reflect"
"testing"
"gitee.com/johng/gf/third/github.com/davecgh/go-spew/spew"
"github.com/gogf/gf/third/github.com/davecgh/go-spew/spew"
)
type testRequestBody struct {

2
third/github.com/Shopify/sarama/tools/kafka-console-consumer/kafka-console-consumer.go
View File

@ -10,7 +10,7 @@ import (
"strings"
"sync"
"gitee.com/johng/gf/third/github.com/Shopify/sarama"
"github.com/gogf/gf/third/github.com/Shopify/sarama"
)
var (

2
third/github.com/Shopify/sarama/tools/kafka-console-partitionconsumer/kafka-console-partitionconsumer.go
View File

@ -9,7 +9,7 @@ import (
"strconv"
"strings"
"gitee.com/johng/gf/third/github.com/Shopify/sarama"
"github.com/gogf/gf/third/github.com/Shopify/sarama"
)
var (

4
third/github.com/Shopify/sarama/tools/kafka-console-producer/kafka-console-producer.go
View File

@ -8,8 +8,8 @@ import (
"os"
"strings"
"gitee.com/johng/gf/third/github.com/Shopify/sarama"
"gitee.com/johng/gf/third/github.com/rcrowley/go-metrics"
"github.com/gogf/gf/third/github.com/Shopify/sarama"
"github.com/gogf/gf/third/github.com/rcrowley/go-metrics"
)
var (

2
third/github.com/Shopify/sarama/zstd_cgo.go
View File

@ -2,7 +2,7 @@
package sarama
import "gitee.com/johng/gf/third/github.com/DataDog/zstd"
import "github.com/gogf/gf/third/github.com/DataDog/zstd"
func zstdDecompress(dst, src []byte) ([]byte, error) {
return zstd.Decompress(dst, src)