logsfakes

Documentation

Overview

This file was generated by counterfeiter

This file was generated by counterfeiter

This file was generated by counterfeiter

Index

• type FakeLoggregatorConsumer
  • func (fake *FakeLoggregatorConsumer) Close() error
  • func (fake *FakeLoggregatorConsumer) CloseCallCount() int
  • func (fake *FakeLoggregatorConsumer) CloseReturns(result1 error)
  • func (fake *FakeLoggregatorConsumer) Invocations() map[string][][]interface{}
  • func (fake *FakeLoggregatorConsumer) Recent(appGUID string, authToken string) ([]*logmessage.LogMessage, error)
  • func (fake *FakeLoggregatorConsumer) RecentArgsForCall(i int) (string, string)
  • func (fake *FakeLoggregatorConsumer) RecentCallCount() int
  • func (fake *FakeLoggregatorConsumer) RecentReturns(result1 []*logmessage.LogMessage, result2 error)
  • func (fake *FakeLoggregatorConsumer) SetDebugPrinter(arg1 loggregator_consumer.DebugPrinter)
  • func (fake *FakeLoggregatorConsumer) SetDebugPrinterArgsForCall(i int) loggregator_consumer.DebugPrinter
  • func (fake *FakeLoggregatorConsumer) SetDebugPrinterCallCount() int
  • func (fake *FakeLoggregatorConsumer) SetOnConnectCallback(arg1 func())
  • func (fake *FakeLoggregatorConsumer) SetOnConnectCallbackArgsForCall(i int) func()
  • func (fake *FakeLoggregatorConsumer) SetOnConnectCallbackCallCount() int
  • func (fake *FakeLoggregatorConsumer) Tail(appGUID string, authToken string) (<-chan *logmessage.LogMessage, error)
  • func (fake *FakeLoggregatorConsumer) TailArgsForCall(i int) (string, string)
  • func (fake *FakeLoggregatorConsumer) TailCallCount() int
  • func (fake *FakeLoggregatorConsumer) TailReturns(result1 <-chan *logmessage.LogMessage, result2 error)
• type FakeLogsRepositoryWithTimeout
  • func (fake *FakeLogsRepositoryWithTimeout) Close()
  • func (fake *FakeLogsRepositoryWithTimeout) FlushMessages(c chan<- logs.Loggable)
  • func (fake *FakeLogsRepositoryWithTimeout) RecentLogsFor(appGuid string) ([]logs.Loggable, error)
  • func (fake *FakeLogsRepositoryWithTimeout) TailLogsFor(appGuid string, onConnect func(), logChan chan<- logs.Loggable, ...)
• type FakeNoaaConsumer
  • func (fake *FakeNoaaConsumer) Close() error
  • func (fake *FakeNoaaConsumer) CloseCallCount() int
  • func (fake *FakeNoaaConsumer) CloseReturns(result1 error)
  • func (fake *FakeNoaaConsumer) Invocations() map[string][][]interface{}
  • func (fake *FakeNoaaConsumer) RecentLogs(appGUID string, authToken string) ([]*events.LogMessage, error)
  • func (fake *FakeNoaaConsumer) RecentLogsArgsForCall(i int) (string, string)
  • func (fake *FakeNoaaConsumer) RecentLogsCallCount() int
  • func (fake *FakeNoaaConsumer) RecentLogsReturns(result1 []*events.LogMessage, result2 error)
  • func (fake *FakeNoaaConsumer) RefreshTokenFrom(tr consumer.TokenRefresher)
  • func (fake *FakeNoaaConsumer) RefreshTokenFromArgsForCall(i int) consumer.TokenRefresher
  • func (fake *FakeNoaaConsumer) RefreshTokenFromCallCount() int
  • func (fake *FakeNoaaConsumer) SetOnConnectCallback(cb func())
  • func (fake *FakeNoaaConsumer) SetOnConnectCallbackArgsForCall(i int) func()
  • func (fake *FakeNoaaConsumer) SetOnConnectCallbackCallCount() int
  • func (fake *FakeNoaaConsumer) TailingLogs(arg1 string, arg2 string) (<-chan *events.LogMessage, <-chan error)
  • func (fake *FakeNoaaConsumer) TailingLogsArgsForCall(i int) (string, string)
  • func (fake *FakeNoaaConsumer) TailingLogsCallCount() int
  • func (fake *FakeNoaaConsumer) TailingLogsReturns(result1 <-chan *events.LogMessage, result2 <-chan error)
• type FakeRepository
  • func (fake *FakeRepository) Close()
  • func (fake *FakeRepository) CloseCallCount() int
  • func (fake *FakeRepository) Invocations() map[string][][]interface{}
  • func (fake *FakeRepository) RecentLogsFor(appGUID string) ([]logs.Loggable, error)
  • func (fake *FakeRepository) RecentLogsForArgsForCall(i int) string
  • func (fake *FakeRepository) RecentLogsForCallCount() int
  • func (fake *FakeRepository) RecentLogsForReturns(result1 []logs.Loggable, result2 error)
  • func (fake *FakeRepository) TailLogsFor(appGUID string, onConnect func(), logChan chan<- logs.Loggable, ...)
  • func (fake *FakeRepository) TailLogsForArgsForCall(i int) (string, func(), chan<- logs.Loggable, chan<- error)
  • func (fake *FakeRepository) TailLogsForCallCount() int

Types

type FakeLoggregatorConsumer

type FakeLoggregatorConsumer struct {
	TailStub func(appGUID string, authToken string) (<-chan *logmessage.LogMessage, error)

	RecentStub func(appGUID string, authToken string) ([]*logmessage.LogMessage, error)

	CloseStub func() error

	SetOnConnectCallbackStub func(func())

	SetDebugPrinterStub func(loggregator_consumer.DebugPrinter)
	// contains filtered or unexported fields
}

func (*FakeLoggregatorConsumer) Close

func (fake *FakeLoggregatorConsumer) Close() error

func (*FakeLoggregatorConsumer) CloseCallCount

func (fake *FakeLoggregatorConsumer) CloseCallCount() int

func (*FakeLoggregatorConsumer) CloseReturns

func (fake *FakeLoggregatorConsumer) CloseReturns(result1 error)

func (*FakeLoggregatorConsumer) Invocations

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

func (*FakeLoggregatorConsumer) Recent

func (fake *FakeLoggregatorConsumer) Recent(appGUID string, authToken string) ([]*logmessage.LogMessage, error)

func (*FakeLoggregatorConsumer) RecentArgsForCall

func (fake *FakeLoggregatorConsumer) RecentArgsForCall(i int) (string, string)

func (*FakeLoggregatorConsumer) RecentCallCount

func (fake *FakeLoggregatorConsumer) RecentCallCount() int

func (*FakeLoggregatorConsumer) RecentReturns

func (fake *FakeLoggregatorConsumer) RecentReturns(result1 []*logmessage.LogMessage, result2 error)

func (*FakeLoggregatorConsumer) SetDebugPrinter

func (fake *FakeLoggregatorConsumer) SetDebugPrinter(arg1 loggregator_consumer.DebugPrinter)

func (*FakeLoggregatorConsumer) SetDebugPrinterArgsForCall

func (fake *FakeLoggregatorConsumer) SetDebugPrinterArgsForCall(i int) loggregator_consumer.DebugPrinter

func (*FakeLoggregatorConsumer) SetDebugPrinterCallCount

func (fake *FakeLoggregatorConsumer) SetDebugPrinterCallCount() int

func (*FakeLoggregatorConsumer) SetOnConnectCallback

func (fake *FakeLoggregatorConsumer) SetOnConnectCallback(arg1 func())

func (*FakeLoggregatorConsumer) SetOnConnectCallbackArgsForCall

func (fake *FakeLoggregatorConsumer) SetOnConnectCallbackArgsForCall(i int) func()

func (*FakeLoggregatorConsumer) SetOnConnectCallbackCallCount

func (fake *FakeLoggregatorConsumer) SetOnConnectCallbackCallCount() int

func (*FakeLoggregatorConsumer) Tail

func (fake *FakeLoggregatorConsumer) Tail(appGUID string, authToken string) (<-chan *logmessage.LogMessage, error)

func (*FakeLoggregatorConsumer) TailArgsForCall

func (fake *FakeLoggregatorConsumer) TailArgsForCall(i int) (string, string)

func (*FakeLoggregatorConsumer) TailCallCount

func (fake *FakeLoggregatorConsumer) TailCallCount() int

func (*FakeLoggregatorConsumer) TailReturns

func (fake *FakeLoggregatorConsumer) TailReturns(result1 <-chan *logmessage.LogMessage, result2 error)

type FakeLogsRepositoryWithTimeout

type FakeLogsRepositoryWithTimeout struct{}

func (*FakeLogsRepositoryWithTimeout) Close

func (fake *FakeLogsRepositoryWithTimeout) Close()

func (*FakeLogsRepositoryWithTimeout) FlushMessages

func (fake *FakeLogsRepositoryWithTimeout) FlushMessages(c chan<- logs.Loggable)

func (*FakeLogsRepositoryWithTimeout) RecentLogsFor

func (fake *FakeLogsRepositoryWithTimeout) RecentLogsFor(appGuid string) ([]logs.Loggable, error)

func (*FakeLogsRepositoryWithTimeout) TailLogsFor

func (fake *FakeLogsRepositoryWithTimeout) TailLogsFor(appGuid string, onConnect func(), logChan chan<- logs.Loggable, errChan chan<- error)

type FakeNoaaConsumer

type FakeNoaaConsumer struct {
	TailingLogsStub func(string, string) (<-chan *events.LogMessage, <-chan error)

	RecentLogsStub func(appGUID string, authToken string) ([]*events.LogMessage, error)

	CloseStub func() error

	SetOnConnectCallbackStub func(cb func())

	RefreshTokenFromStub func(tr consumer.TokenRefresher)
	// contains filtered or unexported fields
}

func (*FakeNoaaConsumer) Close

func (fake *FakeNoaaConsumer) Close() error

func (*FakeNoaaConsumer) CloseCallCount

func (fake *FakeNoaaConsumer) CloseCallCount() int

func (*FakeNoaaConsumer) CloseReturns

func (fake *FakeNoaaConsumer) CloseReturns(result1 error)

func (*FakeNoaaConsumer) Invocations

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

func (*FakeNoaaConsumer) RecentLogs

func (fake *FakeNoaaConsumer) RecentLogs(appGUID string, authToken string) ([]*events.LogMessage, error)

func (*FakeNoaaConsumer) RecentLogsArgsForCall

func (fake *FakeNoaaConsumer) RecentLogsArgsForCall(i int) (string, string)

func (*FakeNoaaConsumer) RecentLogsCallCount

func (fake *FakeNoaaConsumer) RecentLogsCallCount() int

func (*FakeNoaaConsumer) RecentLogsReturns

func (fake *FakeNoaaConsumer) RecentLogsReturns(result1 []*events.LogMessage, result2 error)

func (*FakeNoaaConsumer) RefreshTokenFrom

func (fake *FakeNoaaConsumer) RefreshTokenFrom(tr consumer.TokenRefresher)

func (*FakeNoaaConsumer) RefreshTokenFromArgsForCall

func (fake *FakeNoaaConsumer) RefreshTokenFromArgsForCall(i int) consumer.TokenRefresher

func (*FakeNoaaConsumer) RefreshTokenFromCallCount

func (fake *FakeNoaaConsumer) RefreshTokenFromCallCount() int

func (*FakeNoaaConsumer) SetOnConnectCallback

func (fake *FakeNoaaConsumer) SetOnConnectCallback(cb func())

func (*FakeNoaaConsumer) SetOnConnectCallbackArgsForCall

func (fake *FakeNoaaConsumer) SetOnConnectCallbackArgsForCall(i int) func()

func (*FakeNoaaConsumer) SetOnConnectCallbackCallCount

func (fake *FakeNoaaConsumer) SetOnConnectCallbackCallCount() int

func (*FakeNoaaConsumer) TailingLogs

func (fake *FakeNoaaConsumer) TailingLogs(arg1 string, arg2 string) (<-chan *events.LogMessage, <-chan error)

func (*FakeNoaaConsumer) TailingLogsArgsForCall

func (fake *FakeNoaaConsumer) TailingLogsArgsForCall(i int) (string, string)

func (*FakeNoaaConsumer) TailingLogsCallCount

func (fake *FakeNoaaConsumer) TailingLogsCallCount() int

func (*FakeNoaaConsumer) TailingLogsReturns

func (fake *FakeNoaaConsumer) TailingLogsReturns(result1 <-chan *events.LogMessage, result2 <-chan error)

type FakeRepository

type FakeRepository struct {
	RecentLogsForStub func(appGUID string) ([]logs.Loggable, error)

	TailLogsForStub func(appGUID string, onConnect func(), logChan chan<- logs.Loggable, errChan chan<- error)

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

func (*FakeRepository) Close

func (fake *FakeRepository) Close()

func (*FakeRepository) CloseCallCount

func (fake *FakeRepository) CloseCallCount() int

func (*FakeRepository) Invocations

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

func (*FakeRepository) RecentLogsFor

func (fake *FakeRepository) RecentLogsFor(appGUID string) ([]logs.Loggable, error)

func (*FakeRepository) RecentLogsForArgsForCall

func (fake *FakeRepository) RecentLogsForArgsForCall(i int) string

func (*FakeRepository) RecentLogsForCallCount

func (fake *FakeRepository) RecentLogsForCallCount() int

func (*FakeRepository) RecentLogsForReturns

func (fake *FakeRepository) RecentLogsForReturns(result1 []logs.Loggable, result2 error)

func (*FakeRepository) TailLogsFor

func (fake *FakeRepository) TailLogsFor(appGUID string, onConnect func(), logChan chan<- logs.Loggable, errChan chan<- error)

func (*FakeRepository) TailLogsForArgsForCall

func (fake *FakeRepository) TailLogsForArgsForCall(i int) (string, func(), chan<- logs.Loggable, chan<- error)

func (*FakeRepository) TailLogsForCallCount

func (fake *FakeRepository) TailLogsForCallCount() int