testhelper

package
v1.0.2 Latest Latest
Warning

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

Go to latest
Published: Feb 22, 2023 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var ErrChunker = fmt.Errorf("Chunker Error")

Functions

func GetChunker

func GetChunker(input []string) func(string, io.Reader) (chunker.Chunker, error)

func NewTestChunker

func NewTestChunker(d []string, e bool) chunker.Chunker

Types

type DeltaValidator

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

func NewDeltaValidator

func NewDeltaValidator(t *testing.T, v []*proto.DeltaEntry) *DeltaValidator

func (*DeltaValidator) Dump

func (d *DeltaValidator) Dump(entry *proto.DeltaEntry)

func (*DeltaValidator) EndDump

func (d *DeltaValidator) EndDump()

func (*DeltaValidator) Err

func (d *DeltaValidator) Err() error

func (*DeltaValidator) StartDump

func (d *DeltaValidator) StartDump(ctx context.Context, entryWriter func(io.Writer, *proto.DeltaEntry) error)

type StringBuilder

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

func (*StringBuilder) String

func (sb *StringBuilder) String() string

func (*StringBuilder) Write

func (sb *StringBuilder) Write(p []byte) (int, error)

func (*StringBuilder) WriteAt

func (sb *StringBuilder) WriteAt(p []byte, off int64) (n int, err error)

type TestChunker

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

func (*TestChunker) Name

func (t *TestChunker) Name() string

func (*TestChunker) Next

func (t *TestChunker) Next() (chunk *chunker.Chunk, err error)

type TestDeltaLoader

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

func NewTestDeltaLoader

func NewTestDeltaLoader(entries []*proto.DeltaEntry) *TestDeltaLoader

func (*TestDeltaLoader) Err

func (l *TestDeltaLoader) Err() error

func (*TestDeltaLoader) Next

func (l *TestDeltaLoader) Next() <-chan *proto.DeltaEntry

func (*TestDeltaLoader) StartLoad

func (l *TestDeltaLoader) StartLoad(ctx context.Context, entryLoader func(io.Reader) (*proto.DeltaEntry, error))

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL