internal

Documentation

Overview

Package internal contains internal logic.

Index

• func ComputeGoroutineOffsets(totalBytes, maxGoroutines, minBytesReadByAGoroutine int) [][2]int
• type Logger
• type NopLogger
  • func (NopLogger) Debug(...interface{})
  • func (NopLogger) Error(...interface{})

Functions

func ComputeGoroutineOffsets

func ComputeGoroutineOffsets(totalBytes, maxGoroutines, minBytesReadByAGoroutine int) [][2]int

ComputeGoroutineOffsets computes how many goroutines will handle totalBytes, and their [start, end] offset intervals. First arguments represents the total bytes to be handled. Second argument represents the maximum goroutines that will handle total bytes. Third argument represents the minimum bytes a goroutine should handle. It returns a slice (up to maxGoroutines in length) of [start, end] intervals each goroutine should handle.

Types

type Logger

type Logger interface {
	// Debug logs debug information.
	Debug(keyValues ...interface{})
	// Error logs any error occurred.
	Error(keyValues ...interface{})
}

Logger logs information while processing a CSV file.

type NopLogger

type NopLogger struct{}

NopLogger does not log anything.

func (NopLogger) Debug

func (NopLogger) Debug(...interface{})

Debug does nothing.

func (NopLogger) Error

func (NopLogger) Error(...interface{})

Error does nothing.