streamfakes

Documentation

Overview

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Index

• type FakeAdapterBuilder
  • func (fake *FakeAdapterBuilder) Build(arg1 chan<- stream.Provider, arg2 chan<- int, arg3 *zap.Logger) stream.Adapter
  • func (fake *FakeAdapterBuilder) BuildArgsForCall(i int) (chan<- stream.Provider, chan<- int, *zap.Logger)
  • func (fake *FakeAdapterBuilder) BuildCallCount() int
  • func (fake *FakeAdapterBuilder) BuildCalls(stub func(chan<- stream.Provider, chan<- int, *zap.Logger) stream.Adapter)
  • func (fake *FakeAdapterBuilder) BuildReturns(result1 stream.Adapter)
  • func (fake *FakeAdapterBuilder) BuildReturnsOnCall(i int, result1 stream.Adapter)
  • func (fake *FakeAdapterBuilder) Invocations() map[string][][]interface{}
  • func (fake *FakeAdapterBuilder) LoadConfig(arg1 config.Config) error
  • func (fake *FakeAdapterBuilder) LoadConfigArgsForCall(i int) config.Config
  • func (fake *FakeAdapterBuilder) LoadConfigCallCount() int
  • func (fake *FakeAdapterBuilder) LoadConfigCalls(stub func(config.Config) error)
  • func (fake *FakeAdapterBuilder) LoadConfigReturns(result1 error)
  • func (fake *FakeAdapterBuilder) LoadConfigReturnsOnCall(i int, result1 error)
• type FakeProvider
  • func (fake *FakeProvider) Invocations() map[string][][]interface{}
  • func (fake *FakeProvider) SendRequest(arg1 []byte) ([]byte, error)
  • func (fake *FakeProvider) SendRequestArgsForCall(i int) []byte
  • func (fake *FakeProvider) SendRequestCallCount() int
  • func (fake *FakeProvider) SendRequestCalls(stub func([]byte) ([]byte, error))
  • func (fake *FakeProvider) SendRequestReturns(result1 []byte, result2 error)
  • func (fake *FakeProvider) SendRequestReturnsOnCall(i int, result1 []byte, result2 error)
  • func (fake *FakeProvider) StreamID() int
  • func (fake *FakeProvider) StreamIDCallCount() int
  • func (fake *FakeProvider) StreamIDCalls(stub func() int)
  • func (fake *FakeProvider) StreamIDReturns(result1 int)
  • func (fake *FakeProvider) StreamIDReturnsOnCall(i int, result1 int)
  • func (fake *FakeProvider) SubscribeEgress() <-chan *xivnet.Frame
  • func (fake *FakeProvider) SubscribeEgressCallCount() int
  • func (fake *FakeProvider) SubscribeEgressCalls(stub func() <-chan *xivnet.Frame)
  • func (fake *FakeProvider) SubscribeEgressReturns(result1 <-chan *xivnet.Frame)
  • func (fake *FakeProvider) SubscribeEgressReturnsOnCall(i int, result1 <-chan *xivnet.Frame)
  • func (fake *FakeProvider) SubscribeIngress() <-chan *xivnet.Frame
  • func (fake *FakeProvider) SubscribeIngressCallCount() int
  • func (fake *FakeProvider) SubscribeIngressCalls(stub func() <-chan *xivnet.Frame)
  • func (fake *FakeProvider) SubscribeIngressReturns(result1 <-chan *xivnet.Frame)
  • func (fake *FakeProvider) SubscribeIngressReturnsOnCall(i int, result1 <-chan *xivnet.Frame)

Types

type FakeAdapterBuilder

type FakeAdapterBuilder struct {
	BuildStub func(chan<- stream.Provider, chan<- int, *zap.Logger) stream.Adapter

	LoadConfigStub func(config.Config) error
	// contains filtered or unexported fields
}

func (*FakeAdapterBuilder) Build

func (fake *FakeAdapterBuilder) Build(arg1 chan<- stream.Provider, arg2 chan<- int, arg3 *zap.Logger) stream.Adapter

func (*FakeAdapterBuilder) BuildArgsForCall

func (fake *FakeAdapterBuilder) BuildArgsForCall(i int) (chan<- stream.Provider, chan<- int, *zap.Logger)

func (*FakeAdapterBuilder) BuildCallCount

func (fake *FakeAdapterBuilder) BuildCallCount() int

func (*FakeAdapterBuilder) BuildCalls

func (fake *FakeAdapterBuilder) BuildCalls(stub func(chan<- stream.Provider, chan<- int, *zap.Logger) stream.Adapter)

func (*FakeAdapterBuilder) BuildReturns

func (fake *FakeAdapterBuilder) BuildReturns(result1 stream.Adapter)

func (*FakeAdapterBuilder) BuildReturnsOnCall

func (fake *FakeAdapterBuilder) BuildReturnsOnCall(i int, result1 stream.Adapter)

func (*FakeAdapterBuilder) Invocations

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

func (*FakeAdapterBuilder) LoadConfig

func (fake *FakeAdapterBuilder) LoadConfig(arg1 config.Config) error

func (*FakeAdapterBuilder) LoadConfigArgsForCall

func (fake *FakeAdapterBuilder) LoadConfigArgsForCall(i int) config.Config

func (*FakeAdapterBuilder) LoadConfigCallCount

func (fake *FakeAdapterBuilder) LoadConfigCallCount() int

func (*FakeAdapterBuilder) LoadConfigCalls

func (fake *FakeAdapterBuilder) LoadConfigCalls(stub func(config.Config) error)

func (*FakeAdapterBuilder) LoadConfigReturns

func (fake *FakeAdapterBuilder) LoadConfigReturns(result1 error)

func (*FakeAdapterBuilder) LoadConfigReturnsOnCall

func (fake *FakeAdapterBuilder) LoadConfigReturnsOnCall(i int, result1 error)

type FakeProvider

type FakeProvider struct {
	SendRequestStub func([]byte) ([]byte, error)

	StreamIDStub func() int

	SubscribeEgressStub func() <-chan *xivnet.Frame

	SubscribeIngressStub func() <-chan *xivnet.Frame
	// contains filtered or unexported fields
}

func (*FakeProvider) Invocations

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

func (*FakeProvider) SendRequest

func (fake *FakeProvider) SendRequest(arg1 []byte) ([]byte, error)

func (*FakeProvider) SendRequestArgsForCall

func (fake *FakeProvider) SendRequestArgsForCall(i int) []byte

func (*FakeProvider) SendRequestCallCount

func (fake *FakeProvider) SendRequestCallCount() int

func (*FakeProvider) SendRequestCalls

func (fake *FakeProvider) SendRequestCalls(stub func([]byte) ([]byte, error))

func (*FakeProvider) SendRequestReturns

func (fake *FakeProvider) SendRequestReturns(result1 []byte, result2 error)

func (*FakeProvider) SendRequestReturnsOnCall

func (fake *FakeProvider) SendRequestReturnsOnCall(i int, result1 []byte, result2 error)

func (*FakeProvider) StreamID

func (fake *FakeProvider) StreamID() int

func (*FakeProvider) StreamIDCallCount

func (fake *FakeProvider) StreamIDCallCount() int

func (*FakeProvider) StreamIDCalls

func (fake *FakeProvider) StreamIDCalls(stub func() int)

func (*FakeProvider) StreamIDReturns

func (fake *FakeProvider) StreamIDReturns(result1 int)

func (*FakeProvider) StreamIDReturnsOnCall

func (fake *FakeProvider) StreamIDReturnsOnCall(i int, result1 int)

func (*FakeProvider) SubscribeEgress

func (fake *FakeProvider) SubscribeEgress() <-chan *xivnet.Frame

func (*FakeProvider) SubscribeEgressCallCount

func (fake *FakeProvider) SubscribeEgressCallCount() int

func (*FakeProvider) SubscribeEgressCalls

func (fake *FakeProvider) SubscribeEgressCalls(stub func() <-chan *xivnet.Frame)

func (*FakeProvider) SubscribeEgressReturns

func (fake *FakeProvider) SubscribeEgressReturns(result1 <-chan *xivnet.Frame)

func (*FakeProvider) SubscribeEgressReturnsOnCall

func (fake *FakeProvider) SubscribeEgressReturnsOnCall(i int, result1 <-chan *xivnet.Frame)

func (*FakeProvider) SubscribeIngress

func (fake *FakeProvider) SubscribeIngress() <-chan *xivnet.Frame

func (*FakeProvider) SubscribeIngressCallCount

func (fake *FakeProvider) SubscribeIngressCallCount() int

func (*FakeProvider) SubscribeIngressCalls

func (fake *FakeProvider) SubscribeIngressCalls(stub func() <-chan *xivnet.Frame)

func (*FakeProvider) SubscribeIngressReturns

func (fake *FakeProvider) SubscribeIngressReturns(result1 <-chan *xivnet.Frame)

func (*FakeProvider) SubscribeIngressReturnsOnCall

func (fake *FakeProvider) SubscribeIngressReturnsOnCall(i int, result1 <-chan *xivnet.Frame)