Documentation

Overview

    Code generated by counterfeiter. DO NOT EDIT.

    Code generated by counterfeiter. DO NOT EDIT.

    Code generated by counterfeiter. DO NOT EDIT.

    Index

    Constants

    This section is empty.

    Variables

    This section is empty.

    Functions

    This section is empty.

    Types

    type FakeEvent

    type FakeEvent struct{ Token string }

    func (FakeEvent) EventType

    func (FakeEvent) EventType() string

    func (FakeEvent) Key

    func (FakeEvent) Key() string

    func (FakeEvent) Marshal

    func (e FakeEvent) Marshal() ([]byte, error)

    func (FakeEvent) ProtoMessage

    func (FakeEvent) ProtoMessage()

    func (FakeEvent) Reset

    func (FakeEvent) Reset()

    func (FakeEvent) String

    func (FakeEvent) String() string

    type FakeEventSource

    type FakeEventSource struct {
    	CloseStub func() error
    
    	NextStub func() (models.Event, error)
    	// contains filtered or unexported fields
    }

    func (*FakeEventSource) Close

    func (fake *FakeEventSource) Close() error

    func (*FakeEventSource) CloseCallCount

    func (fake *FakeEventSource) CloseCallCount() int

    func (*FakeEventSource) CloseCalls

    func (fake *FakeEventSource) CloseCalls(stub func() error)

    func (*FakeEventSource) CloseReturns

    func (fake *FakeEventSource) CloseReturns(result1 error)

    func (*FakeEventSource) CloseReturnsOnCall

    func (fake *FakeEventSource) CloseReturnsOnCall(i int, result1 error)

    func (*FakeEventSource) Invocations

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

    func (*FakeEventSource) Next

    func (fake *FakeEventSource) Next() (models.Event, error)

    func (*FakeEventSource) NextCallCount

    func (fake *FakeEventSource) NextCallCount() int

    func (*FakeEventSource) NextCalls

    func (fake *FakeEventSource) NextCalls(stub func() (models.Event, error))

    func (*FakeEventSource) NextReturns

    func (fake *FakeEventSource) NextReturns(result1 models.Event, result2 error)

    func (*FakeEventSource) NextReturnsOnCall

    func (fake *FakeEventSource) NextReturnsOnCall(i int, result1 models.Event, result2 error)

    type FakeHub

    type FakeHub struct {
    	CloseStub func() error
    
    	EmitStub func(models.Event)
    
    	RegisterCallbackStub func(func(count int))
    
    	SubscribeStub func() (events.EventSource, error)
    
    	UnregisterCallbackStub func()
    	// contains filtered or unexported fields
    }

    func (*FakeHub) Close

    func (fake *FakeHub) Close() error

    func (*FakeHub) CloseCallCount

    func (fake *FakeHub) CloseCallCount() int

    func (*FakeHub) CloseCalls

    func (fake *FakeHub) CloseCalls(stub func() error)

    func (*FakeHub) CloseReturns

    func (fake *FakeHub) CloseReturns(result1 error)

    func (*FakeHub) CloseReturnsOnCall

    func (fake *FakeHub) CloseReturnsOnCall(i int, result1 error)

    func (*FakeHub) Emit

    func (fake *FakeHub) Emit(arg1 models.Event)

    func (*FakeHub) EmitArgsForCall

    func (fake *FakeHub) EmitArgsForCall(i int) models.Event

    func (*FakeHub) EmitCallCount

    func (fake *FakeHub) EmitCallCount() int

    func (*FakeHub) EmitCalls

    func (fake *FakeHub) EmitCalls(stub func(models.Event))

    func (*FakeHub) Invocations

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

    func (*FakeHub) RegisterCallback

    func (fake *FakeHub) RegisterCallback(arg1 func(count int))

    func (*FakeHub) RegisterCallbackArgsForCall

    func (fake *FakeHub) RegisterCallbackArgsForCall(i int) func(count int)

    func (*FakeHub) RegisterCallbackCallCount

    func (fake *FakeHub) RegisterCallbackCallCount() int

    func (*FakeHub) RegisterCallbackCalls

    func (fake *FakeHub) RegisterCallbackCalls(stub func(func(count int)))

    func (*FakeHub) Subscribe

    func (fake *FakeHub) Subscribe() (events.EventSource, error)

    func (*FakeHub) SubscribeCallCount

    func (fake *FakeHub) SubscribeCallCount() int

    func (*FakeHub) SubscribeCalls

    func (fake *FakeHub) SubscribeCalls(stub func() (events.EventSource, error))

    func (*FakeHub) SubscribeReturns

    func (fake *FakeHub) SubscribeReturns(result1 events.EventSource, result2 error)

    func (*FakeHub) SubscribeReturnsOnCall

    func (fake *FakeHub) SubscribeReturnsOnCall(i int, result1 events.EventSource, result2 error)

    func (*FakeHub) UnregisterCallback

    func (fake *FakeHub) UnregisterCallback()

    func (*FakeHub) UnregisterCallbackCallCount

    func (fake *FakeHub) UnregisterCallbackCallCount() int

    func (*FakeHub) UnregisterCallbackCalls

    func (fake *FakeHub) UnregisterCallbackCalls(stub func())

    type FakeRawEventSource

    type FakeRawEventSource struct {
    	CloseStub func() error
    
    	NextStub func() (sse.Event, error)
    	// contains filtered or unexported fields
    }

    func (*FakeRawEventSource) Close

    func (fake *FakeRawEventSource) Close() error

    func (*FakeRawEventSource) CloseCallCount

    func (fake *FakeRawEventSource) CloseCallCount() int

    func (*FakeRawEventSource) CloseCalls

    func (fake *FakeRawEventSource) CloseCalls(stub func() error)

    func (*FakeRawEventSource) CloseReturns

    func (fake *FakeRawEventSource) CloseReturns(result1 error)

    func (*FakeRawEventSource) CloseReturnsOnCall

    func (fake *FakeRawEventSource) CloseReturnsOnCall(i int, result1 error)

    func (*FakeRawEventSource) Invocations

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

    func (*FakeRawEventSource) Next

    func (fake *FakeRawEventSource) Next() (sse.Event, error)

    func (*FakeRawEventSource) NextCallCount

    func (fake *FakeRawEventSource) NextCallCount() int

    func (*FakeRawEventSource) NextCalls

    func (fake *FakeRawEventSource) NextCalls(stub func() (sse.Event, error))

    func (*FakeRawEventSource) NextReturns

    func (fake *FakeRawEventSource) NextReturns(result1 sse.Event, result2 error)

    func (*FakeRawEventSource) NextReturnsOnCall

    func (fake *FakeRawEventSource) NextReturnsOnCall(i int, result1 sse.Event, result2 error)

    type UnmarshalableEvent

    type UnmarshalableEvent struct{ Fn func() }

    func (UnmarshalableEvent) EventType

    func (UnmarshalableEvent) EventType() string

    func (UnmarshalableEvent) Key

    func (UnmarshalableEvent) Key() string

    func (UnmarshalableEvent) Marshal

    func (UnmarshalableEvent) Marshal() ([]byte, error)

    func (UnmarshalableEvent) ProtoMessage

    func (UnmarshalableEvent) ProtoMessage()

    func (UnmarshalableEvent) Reset

    func (UnmarshalableEvent) Reset()

    func (UnmarshalableEvent) String

    func (UnmarshalableEvent) String() string