Versions in this module Expand all Collapse all v1 v1.3.3 Jul 5, 2022 v1.3.2 Jul 19, 2021 v1.3.1 Jul 19, 2021 v1.3.0 Jul 16, 2021 v1.2.0 Jul 14, 2021 Changes in this version + const JobReaderLabel + const KB + const MB + const NoDuration + const NoIOBytes + const ReadOperation + const WriteOperation + func GetSummaryHeader() []string + type DirectoryManager struct + func InitializeDirectoryManager() *DirectoryManager + func (d *DirectoryManager) EnsureDirectory(path string) error + type IOStatistics struct + FailureMessage string + FileCloseTimeNS time.Duration + FileOpenTimeNS time.Duration + Hostname string + IOBytes int + IOTimeNS time.Duration + IsSuccess bool + Label string + Operation Operation + Path string + RunName string + StartTime time.Time + UniqueName string + func InitializeIOStatistics(startTime time.Time, uniqueName string, runName string, label string, ...) *IOStatistics + func InitializeIOStatisticsFromString(jsonString string) (*IOStatistics, error) + func (i *IOStatistics) CSVHeader() []string + func (i *IOStatistics) GetCategoryKey() string + func (i *IOStatistics) GetJSON() ([]byte, error) + func (i *IOStatistics) ToStringArray() []string + type IOStatsCollector struct + BatchMap map[string]map[string]*IOStatsRows + IOMap map[string]map[string]*IOStatsRows + JobCount map[string]map[string]int + UniqueName string + func InitializeIOStatsCollector(uniqueName string) *IOStatsCollector + func (i *IOStatsCollector) RecordEvent(eMsg string) + func (i *IOStatsCollector) WriteBatchSummaryFiles(statsPath string, uniqueName string) + func (i *IOStatsCollector) WriteIOSummaryFiles(statsPath string, uniqueName string) + func (i *IOStatsCollector) WriteRAWFiles(statsPath string, uniqueName string) + type IOStatsRows struct + func InitializeIOStatsRows() *IOStatsRows + func (i *IOStatsRows) AddIOStats(ios *IOStatistics) + func (i *IOStatsRows) GetRowCount() int + func (i *IOStatsRows) GetRows() []*IOStatistics + func (i *IOStatsRows) GetSuccessCount() int + func (i *IOStatsRows) WriteCSVFile(filename string) + func (i *IOStatsRows) WriteSummaryLines(writer *csv.Writer) + func (i *IOStatsRows) WriteSummaryRow(writer *csv.Writer, batchName string, label string, sampleSize int, ...) + type Operation string + type ReaderWriter struct + func InitializeReaderWriter(label string, profiler log.Profiler) *ReaderWriter + func (r *ReaderWriter) ReadFile(filename string, uniqueName string, runName string) ([]byte, error) + func (r *ReaderWriter) WriteFile(filename string, data []byte, uniqueName string, runName string) error + type RoundRobinPathManager struct + func InitializeRoundRobinPathManager(paths []string) *RoundRobinPathManager + func (r *RoundRobinPathManager) GetNextPath() string + type SimpleProfiler struct + func InitializeSimpleProfiler() *SimpleProfiler + func (s *SimpleProfiler) GetSummary() string + func (s *SimpleProfiler) RecordTiming(bytes []byte)