...

Package mock

import "github.com/hyperledger/fabric/core/comm/mock"
Overview
Index

Overview ▾

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Index ▾

type NewSemaphore
    func (fake *NewSemaphore) ArgsForCall(i int) int
    func (fake *NewSemaphore) CallCount() int
    func (fake *NewSemaphore) Calls(stub func(int) comm.Semaphore)
    func (fake *NewSemaphore) Invocations() map[string][][]interface{}
    func (fake *NewSemaphore) Returns(result1 comm.Semaphore)
    func (fake *NewSemaphore) ReturnsOnCall(i int, result1 comm.Semaphore)
    func (fake *NewSemaphore) Spy(arg1 int) comm.Semaphore
type Semaphore
    func (fake *Semaphore) Acquire(arg1 context.Context) error
    func (fake *Semaphore) AcquireArgsForCall(i int) context.Context
    func (fake *Semaphore) AcquireCallCount() int
    func (fake *Semaphore) AcquireCalls(stub func(context.Context) error)
    func (fake *Semaphore) AcquireReturns(result1 error)
    func (fake *Semaphore) AcquireReturnsOnCall(i int, result1 error)
    func (fake *Semaphore) Invocations() map[string][][]interface{}
    func (fake *Semaphore) Release()
    func (fake *Semaphore) ReleaseCallCount() int
    func (fake *Semaphore) ReleaseCalls(stub func())
type ServerStream
    func (fake *ServerStream) Context() context.Context
    func (fake *ServerStream) ContextCallCount() int
    func (fake *ServerStream) ContextCalls(stub func() context.Context)
    func (fake *ServerStream) ContextReturns(result1 context.Context)
    func (fake *ServerStream) ContextReturnsOnCall(i int, result1 context.Context)
    func (fake *ServerStream) Invocations() map[string][][]interface{}
    func (fake *ServerStream) RecvMsg(arg1 interface{}) error
    func (fake *ServerStream) RecvMsgArgsForCall(i int) interface{}
    func (fake *ServerStream) RecvMsgCallCount() int
    func (fake *ServerStream) RecvMsgCalls(stub func(interface{}) error)
    func (fake *ServerStream) RecvMsgReturns(result1 error)
    func (fake *ServerStream) RecvMsgReturnsOnCall(i int, result1 error)
    func (fake *ServerStream) SendHeader(arg1 metadata.MD) error
    func (fake *ServerStream) SendHeaderArgsForCall(i int) metadata.MD
    func (fake *ServerStream) SendHeaderCallCount() int
    func (fake *ServerStream) SendHeaderCalls(stub func(metadata.MD) error)
    func (fake *ServerStream) SendHeaderReturns(result1 error)
    func (fake *ServerStream) SendHeaderReturnsOnCall(i int, result1 error)
    func (fake *ServerStream) SendMsg(arg1 interface{}) error
    func (fake *ServerStream) SendMsgArgsForCall(i int) interface{}
    func (fake *ServerStream) SendMsgCallCount() int
    func (fake *ServerStream) SendMsgCalls(stub func(interface{}) error)
    func (fake *ServerStream) SendMsgReturns(result1 error)
    func (fake *ServerStream) SendMsgReturnsOnCall(i int, result1 error)
    func (fake *ServerStream) SetHeader(arg1 metadata.MD) error
    func (fake *ServerStream) SetHeaderArgsForCall(i int) metadata.MD
    func (fake *ServerStream) SetHeaderCallCount() int
    func (fake *ServerStream) SetHeaderCalls(stub func(metadata.MD) error)
    func (fake *ServerStream) SetHeaderReturns(result1 error)
    func (fake *ServerStream) SetHeaderReturnsOnCall(i int, result1 error)
    func (fake *ServerStream) SetTrailer(arg1 metadata.MD)
    func (fake *ServerStream) SetTrailerArgsForCall(i int) metadata.MD
    func (fake *ServerStream) SetTrailerCallCount() int
    func (fake *ServerStream) SetTrailerCalls(stub func(metadata.MD))
type StreamHandler
    func (fake *StreamHandler) ArgsForCall(i int) (interface{}, grpc.ServerStream)
    func (fake *StreamHandler) CallCount() int
    func (fake *StreamHandler) Calls(stub func(interface{}, grpc.ServerStream) error)
    func (fake *StreamHandler) Invocations() map[string][][]interface{}
    func (fake *StreamHandler) Returns(result1 error)
    func (fake *StreamHandler) ReturnsOnCall(i int, result1 error)
    func (fake *StreamHandler) Spy(arg1 interface{}, arg2 grpc.ServerStream) error
type UnaryHandler
    func (fake *UnaryHandler) ArgsForCall(i int) (context.Context, interface{})
    func (fake *UnaryHandler) CallCount() int
    func (fake *UnaryHandler) Calls(stub func(context.Context, interface{}) (interface{}, error))
    func (fake *UnaryHandler) Invocations() map[string][][]interface{}
    func (fake *UnaryHandler) Returns(result1 interface{}, result2 error)
    func (fake *UnaryHandler) ReturnsOnCall(i int, result1 interface{}, result2 error)
    func (fake *UnaryHandler) Spy(arg1 context.Context, arg2 interface{}) (interface{}, error)

Package files

new_semaphore.go semaphore.go server_stream.go stream_handler.go unary_handler.go

type NewSemaphore

type NewSemaphore struct {
    Stub func(int) comm.Semaphore
    // contains filtered or unexported fields
}

func (*NewSemaphore) ArgsForCall

func (fake *NewSemaphore) ArgsForCall(i int) int

func (*NewSemaphore) CallCount

func (fake *NewSemaphore) CallCount() int

func (*NewSemaphore) Calls

func (fake *NewSemaphore) Calls(stub func(int) comm.Semaphore)

func (*NewSemaphore) Invocations

func (fake *NewSemaphore) Invocations() map[string][][]interface{}

func (*NewSemaphore) Returns

func (fake *NewSemaphore) Returns(result1 comm.Semaphore)

func (*NewSemaphore) ReturnsOnCall

func (fake *NewSemaphore) ReturnsOnCall(i int, result1 comm.Semaphore)

func (*NewSemaphore) Spy

func (fake *NewSemaphore) Spy(arg1 int) comm.Semaphore

type Semaphore

type Semaphore struct {
    AcquireStub func(context.Context) error

    ReleaseStub func()
    // contains filtered or unexported fields
}

func (*Semaphore) Acquire

func (fake *Semaphore) Acquire(arg1 context.Context) error

func (*Semaphore) AcquireArgsForCall

func (fake *Semaphore) AcquireArgsForCall(i int) context.Context

func (*Semaphore) AcquireCallCount

func (fake *Semaphore) AcquireCallCount() int

func (*Semaphore) AcquireCalls

func (fake *Semaphore) AcquireCalls(stub func(context.Context) error)

func (*Semaphore) AcquireReturns

func (fake *Semaphore) AcquireReturns(result1 error)

func (*Semaphore) AcquireReturnsOnCall

func (fake *Semaphore) AcquireReturnsOnCall(i int, result1 error)

func (*Semaphore) Invocations

func (fake *Semaphore) Invocations() map[string][][]interface{}

func (*Semaphore) Release

func (fake *Semaphore) Release()

func (*Semaphore) ReleaseCallCount

func (fake *Semaphore) ReleaseCallCount() int

func (*Semaphore) ReleaseCalls

func (fake *Semaphore) ReleaseCalls(stub func())

type ServerStream

type ServerStream struct {
    ContextStub func() context.Context

    RecvMsgStub func(interface{}) error

    SendHeaderStub func(metadata.MD) error

    SendMsgStub func(interface{}) error

    SetHeaderStub func(metadata.MD) error

    SetTrailerStub func(metadata.MD)
    // contains filtered or unexported fields
}

func (*ServerStream) Context

func (fake *ServerStream) Context() context.Context

func (*ServerStream) ContextCallCount

func (fake *ServerStream) ContextCallCount() int

func (*ServerStream) ContextCalls

func (fake *ServerStream) ContextCalls(stub func() context.Context)

func (*ServerStream) ContextReturns

func (fake *ServerStream) ContextReturns(result1 context.Context)

func (*ServerStream) ContextReturnsOnCall

func (fake *ServerStream) ContextReturnsOnCall(i int, result1 context.Context)

func (*ServerStream) Invocations

func (fake *ServerStream) Invocations() map[string][][]interface{}

func (*ServerStream) RecvMsg

func (fake *ServerStream) RecvMsg(arg1 interface{}) error

func (*ServerStream) RecvMsgArgsForCall

func (fake *ServerStream) RecvMsgArgsForCall(i int) interface{}

func (*ServerStream) RecvMsgCallCount

func (fake *ServerStream) RecvMsgCallCount() int

func (*ServerStream) RecvMsgCalls

func (fake *ServerStream) RecvMsgCalls(stub func(interface{}) error)

func (*ServerStream) RecvMsgReturns

func (fake *ServerStream) RecvMsgReturns(result1 error)

func (*ServerStream) RecvMsgReturnsOnCall

func (fake *ServerStream) RecvMsgReturnsOnCall(i int, result1 error)

func (*ServerStream) SendHeader

func (fake *ServerStream) SendHeader(arg1 metadata.MD) error

func (*ServerStream) SendHeaderArgsForCall

func (fake *ServerStream) SendHeaderArgsForCall(i int) metadata.MD

func (*ServerStream) SendHeaderCallCount

func (fake *ServerStream) SendHeaderCallCount() int

func (*ServerStream) SendHeaderCalls

func (fake *ServerStream) SendHeaderCalls(stub func(metadata.MD) error)

func (*ServerStream) SendHeaderReturns

func (fake *ServerStream) SendHeaderReturns(result1 error)

func (*ServerStream) SendHeaderReturnsOnCall

func (fake *ServerStream) SendHeaderReturnsOnCall(i int, result1 error)

func (*ServerStream) SendMsg

func (fake *ServerStream) SendMsg(arg1 interface{}) error

func (*ServerStream) SendMsgArgsForCall

func (fake *ServerStream) SendMsgArgsForCall(i int) interface{}

func (*ServerStream) SendMsgCallCount

func (fake *ServerStream) SendMsgCallCount() int

func (*ServerStream) SendMsgCalls

func (fake *ServerStream) SendMsgCalls(stub func(interface{}) error)

func (*ServerStream) SendMsgReturns

func (fake *ServerStream) SendMsgReturns(result1 error)

func (*ServerStream) SendMsgReturnsOnCall

func (fake *ServerStream) SendMsgReturnsOnCall(i int, result1 error)

func (*ServerStream) SetHeader

func (fake *ServerStream) SetHeader(arg1 metadata.MD) error

func (*ServerStream) SetHeaderArgsForCall

func (fake *ServerStream) SetHeaderArgsForCall(i int) metadata.MD

func (*ServerStream) SetHeaderCallCount

func (fake *ServerStream) SetHeaderCallCount() int

func (*ServerStream) SetHeaderCalls

func (fake *ServerStream) SetHeaderCalls(stub func(metadata.MD) error)

func (*ServerStream) SetHeaderReturns

func (fake *ServerStream) SetHeaderReturns(result1 error)

func (*ServerStream) SetHeaderReturnsOnCall

func (fake *ServerStream) SetHeaderReturnsOnCall(i int, result1 error)

func (*ServerStream) SetTrailer

func (fake *ServerStream) SetTrailer(arg1 metadata.MD)

func (*ServerStream) SetTrailerArgsForCall

func (fake *ServerStream) SetTrailerArgsForCall(i int) metadata.MD

func (*ServerStream) SetTrailerCallCount

func (fake *ServerStream) SetTrailerCallCount() int

func (*ServerStream) SetTrailerCalls

func (fake *ServerStream) SetTrailerCalls(stub func(metadata.MD))

type StreamHandler

type StreamHandler struct {
    Stub func(interface{}, grpc.ServerStream) error
    // contains filtered or unexported fields
}

func (*StreamHandler) ArgsForCall

func (fake *StreamHandler) ArgsForCall(i int) (interface{}, grpc.ServerStream)

func (*StreamHandler) CallCount

func (fake *StreamHandler) CallCount() int

func (*StreamHandler) Calls

func (fake *StreamHandler) Calls(stub func(interface{}, grpc.ServerStream) error)

func (*StreamHandler) Invocations

func (fake *StreamHandler) Invocations() map[string][][]interface{}

func (*StreamHandler) Returns

func (fake *StreamHandler) Returns(result1 error)

func (*StreamHandler) ReturnsOnCall

func (fake *StreamHandler) ReturnsOnCall(i int, result1 error)

func (*StreamHandler) Spy

func (fake *StreamHandler) Spy(arg1 interface{}, arg2 grpc.ServerStream) error

type UnaryHandler

type UnaryHandler struct {
    Stub func(context.Context, interface{}) (interface{}, error)
    // contains filtered or unexported fields
}

func (*UnaryHandler) ArgsForCall

func (fake *UnaryHandler) ArgsForCall(i int) (context.Context, interface{})

func (*UnaryHandler) CallCount

func (fake *UnaryHandler) CallCount() int

func (*UnaryHandler) Calls

func (fake *UnaryHandler) Calls(stub func(context.Context, interface{}) (interface{}, error))

func (*UnaryHandler) Invocations

func (fake *UnaryHandler) Invocations() map[string][][]interface{}

func (*UnaryHandler) Returns

func (fake *UnaryHandler) Returns(result1 interface{}, result2 error)

func (*UnaryHandler) ReturnsOnCall

func (fake *UnaryHandler) ReturnsOnCall(i int, result1 interface{}, result2 error)

func (*UnaryHandler) Spy

func (fake *UnaryHandler) Spy(arg1 context.Context, arg2 interface{}) (interface{}, error)