func getLeastLoadedStream()

in out_writeapi.go [397:407]

• 11 lines of code
• 3 McCabe index (conditional complexity)

func getLeastLoadedStream(streamSlice *[]*streamConfig) int {
	min := len(*(*streamSlice)[0].appendResults)
	minStreamIndex := 0
	for streamIndex, stream := range *streamSlice {
		if len(*stream.appendResults) < min {
			min = len(*stream.appendResults)
			minStreamIndex = streamIndex
		}
	}
	return minStreamIndex
}