testing

Documentation

Index

• type FakeLogWatcher
  • func NewFakeLogWatcher(bufferSize int) *FakeLogWatcher
  • func (f *FakeLogWatcher) InjectError(err error)
  • func (f *FakeLogWatcher) InjectLog(log *logtypes.Log)
  • func (f *FakeLogWatcher) Stop()
  • func (f *FakeLogWatcher) Watch() (<-chan *logtypes.Log, error)

Types

type FakeLogWatcher

type FakeLogWatcher struct {
	sync.Mutex
	// contains filtered or unexported fields
}

FakeLogWatcher is a fake mock of log watcher.

func NewFakeLogWatcher

func NewFakeLogWatcher(bufferSize int) *FakeLogWatcher

func (*FakeLogWatcher) InjectError

func (f *FakeLogWatcher) InjectError(err error)

InjectError injects an error of Watch function.

func (*FakeLogWatcher) InjectLog

func (f *FakeLogWatcher) InjectLog(log *logtypes.Log)

InjectLog injects a fake log into the watch channel

func (*FakeLogWatcher) Stop

func (f *FakeLogWatcher) Stop()

Stop is the fake stop function.

func (*FakeLogWatcher) Watch

func (f *FakeLogWatcher) Watch() (<-chan *logtypes.Log, error)

Watch is the fake watch function.