inttest

Documentation

Index

• Constants
• type Mode
• type PerfConfigs
• type Reader
  • func NewReader(cfg ReaderConfig) *Reader
  • func (r *Reader) Run()
• type ReaderConfig
• type RecordSpec
• type ResourceManager
  • func NewResourceManager(testParentDir string) *ResourceManager
• type TRConfig
• type TestConfigs
• type TestRunner
  • func NewTestRunner(ctx context.Context, cancel context.CancelFunc, wg *sync.WaitGroup, ...) *TestRunner
  • func (tr *TestRunner) RunTest()
• type Worker
  • func NewWorker(cfg WorkerConfig) *Worker
• type WorkerConfig
• type Writer
  • func NewWriter(cfg WriterConfig) *Writer
  • func (w *Writer) Start()
• type WriterConfig

Constants

const (
	// Indicates that we are passing in a limited key space to use for the id field in each record
	// that we generate.
	LimitedKeySpace = iota
	// Indicated that we are passing in specific records in specific order that we want to have the
	// Writers use for the test.
	SpecificRecords
)

Types

type Mode

type Mode int64

The mode in which we will run the test

type PerfConfigs

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

type Reader

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

func NewReader

func NewReader(cfg ReaderConfig) *Reader

func (*Reader) Run

func (r *Reader) Run()

type ReaderConfig

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

type RecordSpec

type RecordSpec struct {
	Id             string
	CollectionTime int64
}

type ResourceManager

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

func NewResourceManager

func NewResourceManager(testParentDir string) *ResourceManager

type TRConfig

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

type TestConfigs

type TestConfigs struct {
	PerfNumReaders   int
	PerfWriters      int
	PerfWriterWrites int
}

type TestRunner

type TestRunner struct {
	StartTime int64
	EndTime   int64
	// contains filtered or unexported fields
}

func NewTestRunner

func NewTestRunner(ctx context.Context, cancel context.CancelFunc, wg *sync.WaitGroup, cfg TRConfig) *TestRunner

func (*TestRunner) RunTest

func (tr *TestRunner) RunTest()

type Worker

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

func NewWorker

func NewWorker(cfg WorkerConfig) *Worker

type WorkerConfig

type WorkerConfig struct {
	Id       int
	IMDS     *inmemdatastore.InMemDataStore
	Wg       *sync.WaitGroup
	KeySpace []string
}

type Writer

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

func NewWriter

func NewWriter(cfg WriterConfig) *Writer

func (*Writer) Start

func (w *Writer) Start()

type WriterConfig

type WriterConfig struct {
	SpecificRecords []map[string]interface{}
	// contains filtered or unexported fields
}