testtools

package
v1.1.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 12, 2021 License: Apache-2.0 Imports: 38 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	SimplePath      = "/simple"
	SkippedPath     = "/skipped"
	IncrementedPath = "/incremented"
)

Variables

View Source 
var ErrorMockClose = errors.New("mock close: close error")
View Source 
var ErrorMockRead = errors.New("mock reader: read error")
View Source 
var ErrorMockWrite = errors.New("mock writer: write error")
View Source 
var IncrementedDescription = *internal.NewBackupFileDescription(true, false, time.Time{})
View Source 
var SimpleDescription = *internal.NewBackupFileDescription(false, false, time.Time{})
View Source 
var SkippedDescription = *internal.NewBackupFileDescription(false, true, time.Time{})

Functions

func AssertReaderIsEmpty 

func AssertReaderIsEmpty(t *testing.T, reader io.Reader)

func Cleanup added in v0.2.22 

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

func CreateMockStorageFolder added in v0.2.10 

func CreateMockStorageFolder() storage.Folder

nolint:errcheck

func CreateMockStorageFolderWithDeltaBackups added in v0.2.17 

func CreateMockStorageFolderWithDeltaBackups(t *testing.T) storage.Folder

func CreateMockStorageFolderWithPermanentBackups added in v0.2.17 

func CreateMockStorageFolderWithPermanentBackups(t *testing.T) storage.Folder

func CreateMockStorageWalFolder added in v0.2.22 

func CreateMockStorageWalFolder() storage.Folder

func CreateNamedTar added in v1.1.1 

func CreateNamedTar(w io.Writer, r *io.LimitedReader, name string)

func CreatePostgresMockStorageFolderWithTimeMetadata added in v1.1.1 

func CreatePostgresMockStorageFolderWithTimeMetadata(t *testing.T, dataFilling DataFilling) storage.Folder

func CreateTar 

func CreateTar(w io.Writer, r *io.LimitedReader)

CreateTar creates a new tarball from the passed in reader and writes to a destination writer.

func CreateWalPageWithContinuation added in v0.2.10 

func CreateWalPageWithContinuation() []byte

func GetXLogRecordData added in v0.2.10 

func GetXLogRecordData() (walparser.XLogRecord, []byte)

func MakeDefaultInMemoryStorageFolder added in v0.2.1 

func MakeDefaultInMemoryStorageFolder() *memory.Folder

func MakeDefaultUploader added in v0.2.1 

func MakeDefaultUploader(uploaderAPI s3manageriface.UploaderAPI) *s3.Uploader

func MockLoggers added in v0.2.15 

func MockLoggers() (InfoLoggerMock, ErrorLoggerMock)

func NewMockUploader 

func NewMockUploader(apiMultiErr, apiErr bool) *internal.Uploader

func NewMockWalDirUploader added in v0.2.22 

func NewMockWalDirUploader(apiMultiErr, apiErr bool) *postgres.WalUploader

func NewMockWalUploader added in v0.2.15 

func NewMockWalUploader(apiMultiErr, apiErr bool) *postgres.WalUploader

func NewStoringMockUploader 

func NewStoringMockUploader(storage *memory.Storage, deltaDataFolder fsutil.DataFolder) *internal.Uploader

Types

type BackupFileListBuilder added in v0.2.10 

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

func NewBackupFileListBuilder added in v0.2.10 

func NewBackupFileListBuilder() BackupFileListBuilder

func (BackupFileListBuilder) Build added in v0.2.10 

func (listBuilder BackupFileListBuilder) Build() internal.BackupFileList

func (BackupFileListBuilder) WithIncremented added in v0.2.10 

func (listBuilder BackupFileListBuilder) WithIncremented() BackupFileListBuilder

func (BackupFileListBuilder) WithSimple added in v0.2.10 

func (listBuilder BackupFileListBuilder) WithSimple() BackupFileListBuilder

func (BackupFileListBuilder) WithSkipped added in v0.2.10 

func (listBuilder BackupFileListBuilder) WithSkipped() BackupFileListBuilder

type BufCloser added in v0.2.10 

type BufCloser struct {
	*bytes.Buffer
	Err bool
}

func (*BufCloser) Close added in v0.2.10 

func (w *BufCloser) Close() error

type BufferTarBall 

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

BufferTarBall represents a tarball that is written to buffer.

func (*BufferTarBall) AddSize 

func (tarBall *BufferTarBall) AddSize(add int64)

func (*BufferTarBall) AwaitUploads 

func (tarBall *BufferTarBall) AwaitUploads()

func (*BufferTarBall) CloseTar 

func (tarBall *BufferTarBall) CloseTar() error

func (*BufferTarBall) Name added in v0.2.18 

func (tarBall *BufferTarBall) Name() string

func (*BufferTarBall) SetUp 

func (tarBall *BufferTarBall) SetUp(crypter crypto.Crypter, args ...string)

func (*BufferTarBall) Size 

func (tarBall *BufferTarBall) Size() int64

func (*BufferTarBall) TarWriter 

func (tarBall *BufferTarBall) TarWriter() *tar.Writer

type BufferTarBallMaker 

type BufferTarBallMaker struct {
	Size          *int64
	BufferToWrite *bytes.Buffer
	// contains filtered or unexported fields
}

func (*BufferTarBallMaker) Make 

func (tarBallMaker *BufferTarBallMaker) Make(dedicatedUploader bool) internal.TarBall

type BufferTarInterpreter 

type BufferTarInterpreter struct {
	Out []byte
}

BufferTarInterpreter extracts data to a byte slice. Used for testing purposes.

func (*BufferTarInterpreter) Interpret 

func (tarInterpreter *BufferTarInterpreter) Interpret(reader io.Reader, header *tar.Header) error

Interpret handles in memory tar formats. Used for testing purposes.

type ConcurrentConcatBufferTarInterpreter added in v1.1.1 

type ConcurrentConcatBufferTarInterpreter struct {
	Out map[string][]byte
	// contains filtered or unexported fields
}

Extracts data (possibly from multiple sources concurrently) and stores it in dictionary. Used for testing purposes only.

func NewConcurrentConcatBufferTarInterpreter added in v1.1.1 

func NewConcurrentConcatBufferTarInterpreter() *ConcurrentConcatBufferTarInterpreter

func (*ConcurrentConcatBufferTarInterpreter) Interpret added in v1.1.1 

func (tarInterpreter *ConcurrentConcatBufferTarInterpreter) Interpret(reader io.Reader, header *tar.Header) error

Interpret handles in memory tar formats. Used for testing purposes.

type DataFilling added in v1.1.1 

type DataFilling int
const (
	CreationTimeGaps DataFilling = iota
	NoCreationTime
	ModificationTimeGaps
	NoModificationTime
	CreationAndModificationTimeGaps
	NoTimeGaps
)

type ErrorLoggerMock added in v0.2.22 

type ErrorLoggerMock struct {
	Stats *callingFatalOnErrorFuncStats
}

func (ErrorLoggerMock) FatalOnError added in v0.2.22 

func (loggerMock ErrorLoggerMock) FatalOnError(err error)

type ErrorReader added in v0.2.10 

type ErrorReader struct{}

ErrorReader struct implements io.Reader interface. Its Read method returns zero and non-nil error on every call

func (ErrorReader) Read added in v0.2.10 

func (r ErrorReader) Read(b []byte) (int, error)

type ErrorWriteCloser added in v0.2.10 

type ErrorWriteCloser struct{}

func (ErrorWriteCloser) Close added in v0.2.10 

func (ew ErrorWriteCloser) Close() error

func (ErrorWriteCloser) Write added in v0.2.10 

func (ew ErrorWriteCloser) Write(p []byte) (int, error)

type ErrorWriter added in v0.2.10 

type ErrorWriter struct{}

ErrorWriter struct implements io.Writer interface. Its Write method returns zero and non-nil error on every call

func (ErrorWriter) Write added in v0.2.10 

func (w ErrorWriter) Write(b []byte) (int, error)

type FileReaderMaker 

type FileReaderMaker struct {
	Key string
}

FileReaderMaker decompresses lzop tarballs from the passed in file.

func (*FileReaderMaker) Path 

func (f *FileReaderMaker) Path() string

func (*FileReaderMaker) Reader 

func (f *FileReaderMaker) Reader() (io.ReadCloser, error)

Reader creates a new reader from the passed in file.

type FileTarBall 

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

FileTarBall represents a tarball that is written to disk.

func (*FileTarBall) AddSize 

func (tarBall *FileTarBall) AddSize(i int64)

func (*FileTarBall) AwaitUploads 

func (tarBall *FileTarBall) AwaitUploads()

func (*FileTarBall) CloseTar 

func (tarBall *FileTarBall) CloseTar() error

CloseTar closes the tar writer and file, flushing any unwritten data to the file before closing.

func (*FileTarBall) Name added in v0.2.18 

func (tarBall *FileTarBall) Name() string

func (*FileTarBall) SetUp 

func (tarBall *FileTarBall) SetUp(crypter crypto.Crypter, names ...string)

SetUp creates a new LZ4 writer, tar writer and file for writing bundled compressed bytes to.

func (*FileTarBall) Size 

func (tarBall *FileTarBall) Size() int64

func (*FileTarBall) TarWriter 

func (tarBall *FileTarBall) TarWriter() *tar.Writer

type FileTarBallMaker 

type FileTarBallMaker struct {
	Size *int64
	Out  string
	// contains filtered or unexported fields
}

FileTarBallMaker creates a new FileTarBall with the directory that files should be extracted to.

func (*FileTarBallMaker) Make 

func (tarBallMaker *FileTarBallMaker) Make(inheritState bool) internal.TarBall

Make creates a new FileTarBall.

type InfoLoggerMock added in v0.2.22 

type InfoLoggerMock struct {
	Stats *callingPrintFuncStats
}

func (InfoLoggerMock) Println added in v0.2.22 

func (loggerMock InfoLoggerMock) Println(v ...interface{})

type MockCompressor 

type MockCompressor struct{}

func (*MockCompressor) FileExtension 

func (compressor *MockCompressor) FileExtension() string

func (*MockCompressor) NewWriter 

func (compressor *MockCompressor) NewWriter(writer io.Writer) io.WriteCloser

type MockDataFolder 

type MockDataFolder map[string]*bytes.Buffer

func NewMockDataFolder 

func NewMockDataFolder() *MockDataFolder

func (*MockDataFolder) CleanFolder 

func (folder *MockDataFolder) CleanFolder() error

func (*MockDataFolder) CreateFile added in v0.2.10 

func (folder *MockDataFolder) CreateFile(filename string) error

func (*MockDataFolder) DeleteFile added in v0.2.10 

func (folder *MockDataFolder) DeleteFile(filename string) error

func (*MockDataFolder) FileExists added in v0.2.10 

func (folder *MockDataFolder) FileExists(filename string) bool

func (*MockDataFolder) IsEmpty 

func (folder *MockDataFolder) IsEmpty() bool

func (*MockDataFolder) OpenReadonlyFile 

func (folder *MockDataFolder) OpenReadonlyFile(filename string) (io.ReadCloser, error)

func (*MockDataFolder) OpenWriteOnlyFile 

func (folder *MockDataFolder) OpenWriteOnlyFile(filename string) (io.WriteCloser, error)

func (*MockDataFolder) RenameFile added in v1.1.1 

func (folder *MockDataFolder) RenameFile(oldFilename string, newFilename string) error

type MockFlusher added in v0.2.12 

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

MockFlusher is a mock of Flusher interface

func NewMockFlusher added in v0.2.12 

func NewMockFlusher(ctrl *gomock.Controller) *MockFlusher

NewMockFlusher creates a new mock instance

func (*MockFlusher) EXPECT added in v0.2.12 

func (m *MockFlusher) EXPECT() *MockFlusherMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockFlusher) Flush added in v0.2.12 

func (m *MockFlusher) Flush() error

Flush mocks base method

type MockFlusherMockRecorder added in v0.2.12 

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

MockFlusherMockRecorder is the mock recorder for MockFlusher

func (*MockFlusherMockRecorder) Flush added in v0.2.12 

func (mr *MockFlusherMockRecorder) Flush() *gomock.Call

Flush indicates an expected call of Flush

type MockReadSeekCloser added in v0.2.12 

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

MockReadSeekCloser is a mock of ReadSeekCloser interface

func NewMockReadSeekCloser added in v0.2.12 

func NewMockReadSeekCloser(ctrl *gomock.Controller) *MockReadSeekCloser

NewMockReadSeekCloser creates a new mock instance

func (*MockReadSeekCloser) Close added in v0.2.12 

func (m *MockReadSeekCloser) Close() error

Close mocks base method

func (*MockReadSeekCloser) EXPECT added in v0.2.12 

func (m *MockReadSeekCloser) EXPECT() *MockReadSeekCloserMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockReadSeekCloser) Read added in v0.2.12 

func (m *MockReadSeekCloser) Read(p []byte) (int, error)

Read mocks base method

func (*MockReadSeekCloser) Seek added in v0.2.12 

func (m *MockReadSeekCloser) Seek(offset int64, whence int) (int64, error)

Seek mocks base method

type MockReadSeekCloserMockRecorder added in v0.2.12 

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

MockReadSeekCloserMockRecorder is the mock recorder for MockReadSeekCloser

func (*MockReadSeekCloserMockRecorder) Close added in v0.2.12 

func (mr *MockReadSeekCloserMockRecorder) Close() *gomock.Call

Close indicates an expected call of Close

func (*MockReadSeekCloserMockRecorder) Read added in v0.2.12 

func (mr *MockReadSeekCloserMockRecorder) Read(p interface{}) *gomock.Call

Read indicates an expected call of Read

func (*MockReadSeekCloserMockRecorder) Seek added in v0.2.12 

func (mr *MockReadSeekCloserMockRecorder) Seek(offset, whence interface{}) *gomock.Call

Seek indicates an expected call of Seek

type MockReadWriteCloser 

type MockReadWriteCloser struct{}

func (*MockReadWriteCloser) Close 

func (readWriterCloser *MockReadWriteCloser) Close() error

func (*MockReadWriteCloser) Read 

func (readWriterCloser *MockReadWriteCloser) Read(p []byte) (n int, err error)

func (*MockReadWriteCloser) Write 

func (readWriterCloser *MockReadWriteCloser) Write(p []byte) (n int, err error)

type MockS3Client added in v0.2.22 

type MockS3Client struct {
	s3iface.S3API
	// contains filtered or unexported fields
}

Mock out S3 client. Includes these methods: ListObjects(*ListObjectsV2Input) GetObject(*GetObjectInput) HeadObject(*HeadObjectInput)

func NewMockS3Client 

func NewMockS3Client(err, notFound bool) *MockS3Client

func (*MockS3Client) GetObject added in v0.2.22 

func (client *MockS3Client) GetObject(input *s3.GetObjectInput) (*s3.GetObjectOutput, error)

func (*MockS3Client) HeadObject added in v0.2.22 

func (client *MockS3Client) HeadObject(input *s3.HeadObjectInput) (*s3.HeadObjectOutput, error)

func (*MockS3Client) ListObjectsV2Pages added in v0.2.22 

func (client *MockS3Client) ListObjectsV2Pages(input *s3.ListObjectsV2Input,
	callback func(*s3.ListObjectsV2Output, bool) bool) error

type MockS3Uploader added in v0.2.22 

type MockS3Uploader struct {
	s3manageriface.UploaderAPI
	// contains filtered or unexported fields
}

Mock out uploader client for S3. Includes these methods: Upload(*UploadInput, ...func(*s3manager.Uploader))

func NewMockS3Uploader 

func NewMockS3Uploader(multiErr, err bool, storage *memory.Storage) *MockS3Uploader

func (*MockS3Uploader) Upload added in v0.2.22 

func (uploader *MockS3Uploader) Upload(input *s3manager.UploadInput,
	f ...func(*s3manager.Uploader)) (*s3manager.UploadOutput, error)

type NOPTarInterpreter 

type NOPTarInterpreter struct{}

NOPTarInterpreter mocks a tar extractor.

func (*NOPTarInterpreter) Interpret 

func (tarInterpreter *NOPTarInterpreter) Interpret(tr io.Reader, header *tar.Header) error

Interpret does not do anything except print the 'tar member' name.

type NopCloser 

type NopCloser struct{}

func (*NopCloser) Close 

func (closer *NopCloser) Close() error

type NopCloserWriter added in v0.2.10 

type NopCloserWriter struct {
	io.Writer
}

func (NopCloserWriter) Close added in v0.2.10 

func (NopCloserWriter) Close() error

type NopSeeker 

type NopSeeker struct{}

func (*NopSeeker) Seek 

func (seeker *NopSeeker) Seek(offset int64, whence int) (int64, error)

type ReadWriteNopCloser 

type ReadWriteNopCloser struct {
	io.ReadWriter
}

func (*ReadWriteNopCloser) Close 

func (readWriteNopCloser *ReadWriteNopCloser) Close() error

type StrideByteReader 

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

StrideByteReader allows for customizable "strides" of random bytes. Creates an infinite stream.

func NewStrideByteReader 

func NewStrideByteReader(s int) *StrideByteReader

NewStrideByteReader creates a new random byte stride generator with a seed of 0.

func (*StrideByteReader) Read 

func (sb *StrideByteReader) Read(p []byte) (int, error)

Read creates randomly generated bytes of 'stride' length.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.