filestreamtest

Documentation

Index

• type FakeFileStream
  • func NewFakeFileStream() *FakeFileStream
  • func (fs *FakeFileStream) Close()
  • func (fs *FakeFileStream) GetUpdates() []filestream.Update
  • func (fs *FakeFileStream) Start(entity string, project string, runID string, ...)
  • func (fs *FakeFileStream) StreamUpdate(update filestream.Update)

Types

type FakeFileStream

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

A fake implementation of FileStream.

func NewFakeFileStream

func NewFakeFileStream() *FakeFileStream

func (*FakeFileStream) Close

func (fs *FakeFileStream) Close()

func (*FakeFileStream) GetUpdates

func (fs *FakeFileStream) GetUpdates() []filestream.Update

GetUpdates returns all updates passed to `StreamUpdate`.

func (*FakeFileStream) Start

func (fs *FakeFileStream) Start(
	entity string,
	project string,
	runID string,
	offsetMap filestream.FileStreamOffsetMap,
)

func (*FakeFileStream) StreamUpdate

func (fs *FakeFileStream) StreamUpdate(update filestream.Update)