payloadComputation

type ComputationRuntime struct {
	//number of compute workers to spawn; increase if not cpu gated
	ComputeWorkers int
	//controls buffer (unit trace files) available to FeederWorkers; increase to fill RAM for max performance
	BufferSizeInGB int
	//Amount of files after which a snapshotDeltaShard is created
	SnapshotInterval int
	//constructor for the WorkerPayload that should be computed
	WorkerPayloadCreator WorkerPayloadCreator
	//gets called once the next snapshot is created. Increasing order of snapshots is guaranteed.
	SnapshotSaver SnapshotSaverFunc
	//For detailed status information useful for debugging but not for normal operation
	DebugLog *log.Logger
	//For status information that are useful during normal operations but could be omitted
	InfoLog *log.Logger
	//For critical warnings and errors that may not be omitted
	ErrLog *log.Logger

	//prometheus metrics
	MetricsRegistry  *prometheus.Registry
	MetrMaxTestValue prometheus.Gauge

	MetrXCorrAgainstFixedPrefix             prometheus.Gauge
	MetrXCorrAgainstRandomPrefix            prometheus.Gauge
	MetrInputFileCount                      prometheus.Gauge
	MetrReadFilesCount                      prometheus.Counter
	MetrProcessedFilesCount                 prometheus.Counter
	MetrInputBufferFreeSlots                prometheus.Gauge
	MetrQQBufferFreeSlots                   prometheus.Gauge
	MetrSnapshotterWaitQueueSize            prometheus.Gauge
	MetrSnapshotterDeltaShardQueueFreeSlots prometheus.Gauge
	// contains filtered or unexported fields
}

type Plotable interface {
	//Plot values according to the implementation and store to writer
	Plot(values []float64, writer io.Writer) error
}

type SnapshotSaverFunc func(result []float64, rawSnapshot WorkerPayload, snapshotIDX int) error

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

type WorkerPayload interface {
	//Name returns a descriptive name for the performed computation
	Name() string
	//MaxSubroutines returns an (approximation) for the maximal amount of subroutines used by this payload.
	//It is intended as a hint of how many parallel instances should be spawned
	MaxSubroutines() int
	//Update processes and adds fixed and random to the internal state
	Update(fixed, random [][]float64)
	//Finalize returns the result of the payload computation based on the current state
	Finalize() ([]float64, error)
	//Merge updates the state of this WorkerPayload with the one of other (equal to calling Update on all data
	//that has been added to other)
	Merge(other WorkerPayload) error
	//Reset the internal state to it's initial values to be equal to the state of an object created by the
	//constructor called with the same arguments
	Reset()
	//DeepCopy returns a copy of this worker payload and all of its internal state
	DeepCopy() WorkerPayload
	Encode(w io.Writer) error
	Decode(r io.Reader) error
}

type WorkerPayloadCreator func(datapointsPerTrace int) WorkerPayload

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