tests

Documentation

Index

• func CorruptFile(t *testing.T, file string)
• func CorruptFiles(t *testing.T, dir string)
• func OpenStore(t *testing.T, options ...store.Option) *store.Store
• func ReadData(t *testing.T, s *store.Store, options ...store.ReaderOption) []byte
• func TempDir(t *testing.T) string
• func TouchFile(t *testing.T, path string)
• func UpdateFiles(t *testing.T, dir, extension string, newContent string)
• func WriteData(t *testing.T, s *store.Store, bytes []byte, ...) store.Version
• type Async
  • func RunAsync(f func()) Async
  • func (a *Async) WaitOrFailAfter(t *testing.T, timeout time.Duration)
• type FakeDecoder
  • func (f *FakeDecoder) DataRead() []byte
  • func (f *FakeDecoder) Decode(reader io.Reader) error
• type ReaderFailingOnClose
  • func (r *ReaderFailingOnClose) Close() error
• type ReaderFailingOnRead
  • func (r *ReaderFailingOnRead) Read([]byte) (n int, err error)
• type ReaderMock
  • func (r *ReaderMock) Close() error
  • func (r *ReaderMock) Read(p []byte) (n int, err error)
  • func (r *ReaderMock) Version() store.Version
• type StoreMock
  • func (s *StoreMock) Reader(...store.ReaderOption) (store.Reader, error)
  • func (s *StoreMock) Versions() ([]store.Version, error)
  • func (s *StoreMock) Writer(...store.WriterOption) (store.Writer, error)
• type WriterMock
  • func (w *WriterMock) AbortAndClose()
  • func (w *WriterMock) Close() error
  • func (w *WriterMock) IsAborted() bool
  • func (w *WriterMock) Version() store.Version
  • func (w *WriterMock) Write(p []byte) (n int, err error)

Functions

func CorruptFile

func CorruptFile(t *testing.T, file string)

func CorruptFiles

func CorruptFiles(t *testing.T, dir string)

func OpenStore

func OpenStore(t *testing.T, options ...store.Option) *store.Store

func ReadData

func ReadData(t *testing.T, s *store.Store, options ...store.ReaderOption) []byte

func TempDir

func TempDir(t *testing.T) string

func TouchFile

func TouchFile(t *testing.T, path string)

func UpdateFiles

func UpdateFiles(t *testing.T, dir, extension string, newContent string)

func WriteData

func WriteData(t *testing.T, s *store.Store, bytes []byte, writerOptions ...store.WriterOption) store.Version

Types

type Async

type Async struct {
	// contains filtered or unexported fields
}

func RunAsync

func RunAsync(f func()) Async

func (*Async) WaitOrFailAfter

func (a *Async) WaitOrFailAfter(t *testing.T, timeout time.Duration)

type FakeDecoder

type FakeDecoder struct {
	// contains filtered or unexported fields
}

func (*FakeDecoder) DataRead

func (f *FakeDecoder) DataRead() []byte

func (*FakeDecoder) Decode

func (f *FakeDecoder) Decode(reader io.Reader) error

type ReaderFailingOnClose

type ReaderFailingOnClose struct {
	ReaderMock
}

func (*ReaderFailingOnClose) Close

func (r *ReaderFailingOnClose) Close() error

type ReaderFailingOnRead

type ReaderFailingOnRead struct {
	ReaderMock
}

func (*ReaderFailingOnRead) Read

func (r *ReaderFailingOnRead) Read([]byte) (n int, err error)

type ReaderMock

type ReaderMock struct{}

func (*ReaderMock) Close

func (r *ReaderMock) Close() error

func (*ReaderMock) Read

func (r *ReaderMock) Read(p []byte) (n int, err error)

func (*ReaderMock) Version

func (r *ReaderMock) Version() store.Version

type StoreMock

type StoreMock struct {
	ReturnReader        store.Reader
	ReturnReaderError   error
	ReturnVersions      []store.Version
	ReturnVersionsError error
	ReturnWriter        store.Writer
}

func (*StoreMock) Reader

func (s *StoreMock) Reader(...store.ReaderOption) (store.Reader, error)

func (*StoreMock) Versions

func (s *StoreMock) Versions() ([]store.Version, error)

func (*StoreMock) Writer

func (s *StoreMock) Writer(...store.WriterOption) (store.Writer, error)

type WriterMock

type WriterMock struct {
	// contains filtered or unexported fields
}

func (*WriterMock) AbortAndClose

func (w *WriterMock) AbortAndClose()

func (*WriterMock) Close

func (w *WriterMock) Close() error

func (*WriterMock) IsAborted

func (w *WriterMock) IsAborted() bool

func (*WriterMock) Version

func (w *WriterMock) Version() store.Version

func (*WriterMock) Write

func (w *WriterMock) Write(p []byte) (n int, err error)