63 Star 183 Fork 3

Gitee 极速下载/hyperledger-fabric

Create your Gitee Account
Explore and code with more than 12 million developers,Free private repositories !:)
Sign up
文件
此仓库是为了提升国内下载速度的镜像仓库,每日同步一次。 原始仓库: https://github.com/hyperledger/fabric
Clone or Download
sync_producer.go 7.05 KB
Copy Edit Raw Blame History
Saad Karim authored 2019-02-04 15:27 . [FAB-13341] Kafka health check
// Code generated by counterfeiter. DO NOT EDIT.
package mock
import (
sync "sync"
sarama "github.com/Shopify/sarama"
)
type SyncProducer struct {
CloseStub func() error
closeMutex sync.RWMutex
closeArgsForCall []struct {
}
closeReturns struct {
result1 error
}
closeReturnsOnCall map[int]struct {
result1 error
}
SendMessageStub func(*sarama.ProducerMessage) (int32, int64, error)
sendMessageMutex sync.RWMutex
sendMessageArgsForCall []struct {
arg1 *sarama.ProducerMessage
}
sendMessageReturns struct {
result1 int32
result2 int64
result3 error
}
sendMessageReturnsOnCall map[int]struct {
result1 int32
result2 int64
result3 error
}
SendMessagesStub func([]*sarama.ProducerMessage) error
sendMessagesMutex sync.RWMutex
sendMessagesArgsForCall []struct {
arg1 []*sarama.ProducerMessage
}
sendMessagesReturns struct {
result1 error
}
sendMessagesReturnsOnCall map[int]struct {
result1 error
}
invocations map[string][][]interface{}
invocationsMutex sync.RWMutex
}
func (fake *SyncProducer) Close() error {
fake.closeMutex.Lock()
ret, specificReturn := fake.closeReturnsOnCall[len(fake.closeArgsForCall)]
fake.closeArgsForCall = append(fake.closeArgsForCall, struct {
}{})
fake.recordInvocation("Close", []interface{}{})
fake.closeMutex.Unlock()
if fake.CloseStub != nil {
return fake.CloseStub()
}
if specificReturn {
return ret.result1
}
fakeReturns := fake.closeReturns
return fakeReturns.result1
}
func (fake *SyncProducer) CloseCallCount() int {
fake.closeMutex.RLock()
defer fake.closeMutex.RUnlock()
return len(fake.closeArgsForCall)
}
func (fake *SyncProducer) CloseCalls(stub func() error) {
fake.closeMutex.Lock()
defer fake.closeMutex.Unlock()
fake.CloseStub = stub
}
func (fake *SyncProducer) CloseReturns(result1 error) {
fake.closeMutex.Lock()
defer fake.closeMutex.Unlock()
fake.CloseStub = nil
fake.closeReturns = struct {
result1 error
}{result1}
}
func (fake *SyncProducer) CloseReturnsOnCall(i int, result1 error) {
fake.closeMutex.Lock()
defer fake.closeMutex.Unlock()
fake.CloseStub = nil
if fake.closeReturnsOnCall == nil {
fake.closeReturnsOnCall = make(map[int]struct {
result1 error
})
}
fake.closeReturnsOnCall[i] = struct {
result1 error
}{result1}
}
func (fake *SyncProducer) SendMessage(arg1 *sarama.ProducerMessage) (int32, int64, error) {
fake.sendMessageMutex.Lock()
ret, specificReturn := fake.sendMessageReturnsOnCall[len(fake.sendMessageArgsForCall)]
fake.sendMessageArgsForCall = append(fake.sendMessageArgsForCall, struct {
arg1 *sarama.ProducerMessage
}{arg1})
fake.recordInvocation("SendMessage", []interface{}{arg1})
fake.sendMessageMutex.Unlock()
if fake.SendMessageStub != nil {
return fake.SendMessageStub(arg1)
}
if specificReturn {
return ret.result1, ret.result2, ret.result3
}
fakeReturns := fake.sendMessageReturns
return fakeReturns.result1, fakeReturns.result2, fakeReturns.result3
}
func (fake *SyncProducer) SendMessageCallCount() int {
fake.sendMessageMutex.RLock()
defer fake.sendMessageMutex.RUnlock()
return len(fake.sendMessageArgsForCall)
}
func (fake *SyncProducer) SendMessageCalls(stub func(*sarama.ProducerMessage) (int32, int64, error)) {
fake.sendMessageMutex.Lock()
defer fake.sendMessageMutex.Unlock()
fake.SendMessageStub = stub
}
func (fake *SyncProducer) SendMessageArgsForCall(i int) *sarama.ProducerMessage {
fake.sendMessageMutex.RLock()
defer fake.sendMessageMutex.RUnlock()
argsForCall := fake.sendMessageArgsForCall[i]
return argsForCall.arg1
}
func (fake *SyncProducer) SendMessageReturns(result1 int32, result2 int64, result3 error) {
fake.sendMessageMutex.Lock()
defer fake.sendMessageMutex.Unlock()
fake.SendMessageStub = nil
fake.sendMessageReturns = struct {
result1 int32
result2 int64
result3 error
}{result1, result2, result3}
}
func (fake *SyncProducer) SendMessageReturnsOnCall(i int, result1 int32, result2 int64, result3 error) {
fake.sendMessageMutex.Lock()
defer fake.sendMessageMutex.Unlock()
fake.SendMessageStub = nil
if fake.sendMessageReturnsOnCall == nil {
fake.sendMessageReturnsOnCall = make(map[int]struct {
result1 int32
result2 int64
result3 error
})
}
fake.sendMessageReturnsOnCall[i] = struct {
result1 int32
result2 int64
result3 error
}{result1, result2, result3}
}
func (fake *SyncProducer) SendMessages(arg1 []*sarama.ProducerMessage) error {
var arg1Copy []*sarama.ProducerMessage
if arg1 != nil {
arg1Copy = make([]*sarama.ProducerMessage, len(arg1))
copy(arg1Copy, arg1)
}
fake.sendMessagesMutex.Lock()
ret, specificReturn := fake.sendMessagesReturnsOnCall[len(fake.sendMessagesArgsForCall)]
fake.sendMessagesArgsForCall = append(fake.sendMessagesArgsForCall, struct {
arg1 []*sarama.ProducerMessage
}{arg1Copy})
fake.recordInvocation("SendMessages", []interface{}{arg1Copy})
fake.sendMessagesMutex.Unlock()
if fake.SendMessagesStub != nil {
return fake.SendMessagesStub(arg1)
}
if specificReturn {
return ret.result1
}
fakeReturns := fake.sendMessagesReturns
return fakeReturns.result1
}
func (fake *SyncProducer) SendMessagesCallCount() int {
fake.sendMessagesMutex.RLock()
defer fake.sendMessagesMutex.RUnlock()
return len(fake.sendMessagesArgsForCall)
}
func (fake *SyncProducer) SendMessagesCalls(stub func([]*sarama.ProducerMessage) error) {
fake.sendMessagesMutex.Lock()
defer fake.sendMessagesMutex.Unlock()
fake.SendMessagesStub = stub
}
func (fake *SyncProducer) SendMessagesArgsForCall(i int) []*sarama.ProducerMessage {
fake.sendMessagesMutex.RLock()
defer fake.sendMessagesMutex.RUnlock()
argsForCall := fake.sendMessagesArgsForCall[i]
return argsForCall.arg1
}
func (fake *SyncProducer) SendMessagesReturns(result1 error) {
fake.sendMessagesMutex.Lock()
defer fake.sendMessagesMutex.Unlock()
fake.SendMessagesStub = nil
fake.sendMessagesReturns = struct {
result1 error
}{result1}
}
func (fake *SyncProducer) SendMessagesReturnsOnCall(i int, result1 error) {
fake.sendMessagesMutex.Lock()
defer fake.sendMessagesMutex.Unlock()
fake.SendMessagesStub = nil
if fake.sendMessagesReturnsOnCall == nil {
fake.sendMessagesReturnsOnCall = make(map[int]struct {
result1 error
})
}
fake.sendMessagesReturnsOnCall[i] = struct {
result1 error
}{result1}
}
func (fake *SyncProducer) Invocations() map[string][][]interface{} {
fake.invocationsMutex.RLock()
defer fake.invocationsMutex.RUnlock()
fake.closeMutex.RLock()
defer fake.closeMutex.RUnlock()
fake.sendMessageMutex.RLock()
defer fake.sendMessageMutex.RUnlock()
fake.sendMessagesMutex.RLock()
defer fake.sendMessagesMutex.RUnlock()
copiedInvocations := map[string][][]interface{}{}
for key, value := range fake.invocations {
copiedInvocations[key] = value
}
return copiedInvocations
}
func (fake *SyncProducer) recordInvocation(key string, args []interface{}) {
fake.invocationsMutex.Lock()
defer fake.invocationsMutex.Unlock()
if fake.invocations == nil {
fake.invocations = map[string][][]interface{}{}
}
if fake.invocations[key] == nil {
fake.invocations[key] = [][]interface{}{}
}
fake.invocations[key] = append(fake.invocations[key], args)
}
马建仓 AI 助手
尝试更多
代码解读
代码找茬
代码优化
Go
1
https://gitee.com/mirrors/hyperledger-fabric.git
git@gitee.com:mirrors/hyperledger-fabric.git
mirrors
hyperledger-fabric
hyperledger-fabric
v1.4.12

Search

0d507c66 1850385 C8b1a773 1850385