Documentation ¶
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)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
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) AcquireArgsForCall ¶
func (*Semaphore) AcquireCalls ¶
func (*Semaphore) AcquireReturnsOnCall ¶
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)
Click to show internal directories.
Click to hide internal directories.